Struct Gateway 

pub struct Gateway { /* private fields */ }

Gateway API 客户端 — 对齐 PHP GatewayWorker\Gateway

提供 WebSocket 客户端管理、群组广播、消息推送等能力。 通过 GatewayTransport trait 抽象底层通信。

PHP 对齐

PHP Gateway 全部为静态方法，Rust 通过实例方法表达，配置与传输层通过构造函数注入， 便于测试和多实例隔离。

用法

use sz_rust_auth_facade::gateway::{
    Gateway, GatewayConfig, MemoryGatewayTransport, GatewayTransport,
};
use std::sync::Arc;

let transport = Arc::new(MemoryGatewayTransport::new());
let gateway = Gateway::new(GatewayConfig::new("127.0.0.1:1238"), transport.clone());

transport.register_client("7f00000108fc00000001");
gateway.send_to_client("7f00000108fc00000001", "hello").unwrap();

Implementations

impl Gateway

pub fn new( config: GatewayConfig, transport: Arc<dyn GatewayTransport>, ) -> Gateway

创建 Gateway 客户端

参数

• config: Gateway 配置
• transport: 传输层实现（业务方注入 Redis pub/sub / HTTP / TCP 等具体实现）

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

向指定 client_id 发送消息 — 对齐 Gateway::sendToClient()

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

向所有在线 client_id 发送广播 — 对齐 Gateway::sendToAll()

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

向指定群组发送消息 — 对齐 Gateway::sendToGroup()

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

将 client_id 加入群组 — 对齐 Gateway::joinGroup()

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

将 client_id 离开群组 — 对齐 Gateway::leaveGroup()

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

解散指定群组 — 对齐 Gateway::ungroup()

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

判断 client_id 是否在线 — 对齐 Gateway::isOnline()

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

获取在线 client_id 数量 — 对齐 Gateway::getClientCount()

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

获取指定群组的在线 client_id 数量 — 对齐 Gateway::getClientCountByGroup()

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

获取所有在线 client_id — 对齐 Gateway::getAllClientIds()

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

获取指定群组中的 client_id — 对齐 Gateway::getClientIdListByGroup()

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

关闭指定 client_id 的连接 — 对齐 Gateway::closeClient()

pub fn config(&self) -> &GatewayConfig

获取 Gateway 配置