Struct ObserverServer 

pub struct ObserverServer { /* private fields */ }

观察者模式服务器实例

Implementations

impl ObserverServer

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

启动服务器

pub async fn stop(&mut 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>

获取协议列表

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

获取连接管理器（用于创建 DefaultServerHandle）

返回

返回 ConnectionManagerTrait

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

获取 ServerHandle（用于消息发送和连接管理）