Struct WsServer 

pub struct WsServer { /* private fields */ }

WebSocket 服务端

Implementations

impl WsServer

pub fn new( listen_addr: String, config: ServerConfig, connections: Arc<DashMap<u64, ClientConn>>, router: Arc<RequestRouter>, subscriptions: Option<Arc<SubscriptionManager>>, ) -> Self

创建 WsServer，共享 TCP 的连接池、路由器、订阅管理器（无鉴权，向后兼容）

pub fn with_auth( listen_addr: String, config: ServerConfig, connections: Arc<DashMap<u64, ClientConn>>, router: Arc<RequestRouter>, subscriptions: Option<Arc<SubscriptionManager>>, key_store: Option<Arc<KeyStore>>, counters: Option<Arc<RuntimeCounters>>, ) -> Self

v1.0 入口：同时接入 KeyStore + 共享 RuntimeCounters 做握手鉴权和 per-message scope / 限额检查。key_store = None 或未配置时保持 legacy（全放行）。

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

启动 WebSocket 服务端监听