Struct WebSocketChannel 

pub struct WebSocketChannel { /* private fields */ }

WebSocket 渠道适配器

Implementations

impl WebSocketChannel

pub fn new( channel_id: impl Into<String>, config: WebSocketChannelConfig, ) -> Self

创建新的 WebSocket 渠道

pub fn default_channel() -> Self

创建默认 WebSocket 渠道

pub async fn connect(&self) -> Layer4Result<()>

建立 WebSocket 连接

pub async fn connect_with_retry(&self) -> Layer4Result<()>

带重连的连接

pub async fn send_raw(&self, message: WsMessage) -> Layer4Result<()>

发送原始 WebSocket 消息

pub async fn send_text(&self, text: &str) -> Layer4Result<()>

发送文本消息

pub async fn send_binary(&self, data: Vec<u8>) -> Layer4Result<()>

发送二进制消息

pub fn register_session(&self, session_id: &str, user_id: &str)

注册会话

pub fn unregister_session(&self, session_id: &str)

注销会话

pub fn receive_message(&self, session_id: &str, content: &str)

接收 WebSocket 消息（模拟）

pub fn active_sessions(&self) -> usize

获取活跃会话数量

Trait Implementations

impl Channel for WebSocketChannel

fn id(&self) -> &str

获取渠道 ID

fn channel_type(&self) -> ChannelType

获取渠道类型

fn send<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 OutboundMessage, ) -> Pin<Box<dyn Future<Output = Layer4Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

发送消息

fn try_receive<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Layer4Result<Option<InboundMessage>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

接收消息（非阻塞）

fn is_connected(&self) -> bool

检查是否连接

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Layer4Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

关闭渠道