Struct MessageRouter 

pub struct MessageRouter { /* private fields */ }

消息路由

根据消息类型将消息路由到不同的处理器

Implementations

impl MessageRouter

pub fn new() -> Self

创建新的消息路由

pub fn register( &mut self, route: impl Into<String>, handler: Arc<dyn MessageHandler>, )

注册处理器

参数

• route: 路由键（例如 “system.ping”, “message.chat” 等）
• handler: 消息处理器

pub fn set_default_handler(&mut self, handler: Arc<dyn MessageHandler>)

设置默认处理器

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

路由消息

参数

• frame: 要路由的消息帧

返回

所有处理器的回复（如果有）

pub fn remove_route(&mut self, route: &str)

移除指定路由的所有处理器

pub fn clear(&mut self)

清除所有路由

Trait Implementations

impl Default for MessageRouter

fn default() -> Self

Returns the “default value” for a type.