Struct WebSocketServer

pub struct WebSocketServer { /* private fields */ }

Implementations

impl WebSocketServer

pub fn new(yrs_manager: Arc<YrsManager>) -> Self

pub async fn start( self: Arc<Self>, addr: SocketAddr, sync_service: Arc<SyncService>, runtime: Arc<Mutex<ForgeRuntime>>, ) -> Result<()>

启动 WebSocket 服务器

pub fn client_count(&self) -> usize

获取在线客户端数量

pub fn room_count(&self) -> usize

获取房间数量

pub fn broadcast_to_room( &self, room_id: &str, message: String, exclude_client: Option<String>, ) -> Result<()>

🚀 主动推送消息到房间

pub fn broadcast_binary_to_room( &self, room_id: &str, data: Vec<u8>, exclude_client: Option<String>, ) -> Result<()>

🚀 主动推送二进制数据到房间

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

🚀 主动推送消息到特定客户端

pub fn send_binary_to_client( &self, client_id: &str, data: Vec<u8>, ) -> Result<()>

🚀 主动推送二进制数据到特定客户端