Struct ServerWrapper 

pub struct ServerWrapper { /* private fields */ }

服务端包装器

提供统一的 ServerHandle 访问接口，所有构建模式都使用此包装器。

设计原则

• 统一接口：所有模式（简单、观察者、Flare）都通过 ServerWrapper 访问服务端功能
• 共享底层：基于 HybridServer，共享所有核心能力
• 类型安全：通过 Rust 类型系统保证接口的正确性

Implementations

impl ServerWrapper

pub fn new(server: HybridServer) -> Self

创建新的服务端包装器

pub fn server(&self) -> &Arc<Mutex<HybridServer>>

获取内部的 HybridServer（用于实现 Server trait）

pub fn get_server_handle_components( &self, ) -> Option<Arc<dyn ConnectionManagerTrait>>

获取 ServerHandle 组件（用于创建 DefaultServerHandle）

返回

返回 ConnectionManagerTrait，如果 ServerCore 未初始化则返回 None

pub fn get_server_handle(&self) -> Option<Arc<dyn ServerHandle>>

获取 ServerHandle（直接使用 HybridServer 作为 ServerHandle）

返回

返回 ServerHandle trait object，如果 ServerCore 未初始化则返回 None

pub async fn start(&self) -> Result<()>

启动服务器

pub async fn stop(&self) -> Result<()>

停止服务器

pub fn is_running(&self) -> bool

检查服务器是否运行

pub fn connection_count(&self) -> usize

获取连接数量

pub fn user_count(&self) -> usize

获取用户数量

pub async fn send_to(&self, connection_id: &str, frame: &Frame) -> Result<()>

向指定连接发送消息

pub async fn send_to_user(&self, user_id: &str, frame: &Frame) -> Result<()>

向指定用户的所有连接发送消息

pub async fn broadcast(&self, frame: &Frame) -> Result<()>

广播消息到所有连接

pub async fn broadcast_except( &self, frame: &Frame, exclude_connection_id: &str, ) -> Result<()>

广播消息到所有连接，排除指定连接

pub async fn disconnect(&self, connection_id: &str) -> Result<()>

断开指定连接

pub fn protocols(&self) -> Vec<TransportProtocol>

获取协议列表