Struct MemoryGatewayTransport 

pub struct MemoryGatewayTransport { /* private fields */ }

内存 Gateway 传输实现 — 用于测试和开发环境

不进行实际网络通信，所有状态保存在内存中，供测试断言使用。

数据结构

• client_messages: client_id → messages 队列（键存在即表示 client 在线）
• client_groups: client_id → groups 映射
• group_clients: group → client_ids 映射

线程安全

通过 Arc<Mutex<GatewayState>> 保护，支持并发访问。所有操作在单个锁内完成， 保证多字段状态的一致性。

用法

use sz_rust_auth_facade::gateway::{MemoryGatewayTransport, GatewayTransport};

let transport = MemoryGatewayTransport::new();
transport.register_client("7f00000108fc00000001");
transport.send_to_client("7f00000108fc00000001", "hello").unwrap();
assert_eq!(transport.client_messages("7f00000108fc00000001"), vec!["hello".to_string()]);

Implementations

impl MemoryGatewayTransport

pub fn new() -> MemoryGatewayTransport

创建新的内存传输

pub fn register_client(&self, client_id: &str)

注册客户端（标记为在线）

非 trait 方法，供测试/开发注册在线客户端。对齐 PHP GatewayWorker 中客户端连接 建立后自动上线的行为。重复注册为幂等操作。

参数

• client_id: 客户端 ID

pub fn client_messages(&self, client_id: &str) -> Vec<String>

获取客户端收到的所有消息（快照）

非 trait 方法，供测试断言。客户端不在线时返回空 Vec。

参数

• client_id: 客户端 ID

Trait Implementations

impl Debug for MemoryGatewayTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for MemoryGatewayTransport

fn default() -> MemoryGatewayTransport

Returns the “default value” for a type.

impl GatewayTransport for MemoryGatewayTransport

fn send_to_client( &self, client_id: &str, message: &str, ) -> Result<(), GatewayError>

向指定 client_id 发送消息

fn send_to_clients( &self, client_ids: &[String], message: &str, ) -> Result<(), GatewayError>

向多个 client_id 发送消息

fn send_to_all(&self, message: &str) -> Result<(), GatewayError>

向所有在线 client_id 发送广播

fn send_to_group(&self, group: &str, message: &str) -> Result<(), GatewayError>

向指定群组发送消息

fn get_all_client_ids(&self) -> Result<Vec<String>, GatewayError>

获取所有在线 client_id

fn get_client_id_list_by_group( &self, group: &str, ) -> Result<Vec<String>, GatewayError>

获取指定群组中的 client_id

fn get_groups_by_client_id( &self, client_id: &str, ) -> Result<Vec<String>, GatewayError>

获取 client_id 所在的群组

fn join_group(&self, client_id: &str, group: &str) -> Result<(), GatewayError>

将 client_id 加入群组

fn leave_group(&self, client_id: &str, group: &str) -> Result<(), GatewayError>

将 client_id 离开群组

fn ungroup(&self, group: &str) -> Result<(), GatewayError>

解散指定群组（对齐 PHP Gateway::ungroup()）

fn is_online(&self, client_id: &str) -> Result<bool, GatewayError>

判断 client_id 是否在线

fn get_client_count(&self) -> Result<usize, GatewayError>

获取在线 client_id 数量

fn get_client_count_by_group(&self, group: &str) -> Result<usize, GatewayError>

获取指定群组的在线 client_id 数量

fn close_client(&self, client_id: &str) -> Result<(), GatewayError>

关闭指定 client_id 的连接