Struct pi_mqtt_proxy::service::MqttConnectHandle

pub struct MqttConnectHandle<S: Socket> { /* private fields */ }

Mqtt连接句柄

Implementations

impl<S: Socket> MqttConnectHandle<S>

pub fn get_token(&self) -> Option<usize>

获取连接的连接令牌

pub fn get_uid(&self) -> Option<usize>

获取连接的唯一id

pub fn get_local_addr(&self) -> Option<SocketAddr>

获取连接的本地地址

pub fn get_local_ip(&self) -> Option<String>

获取连接的本地ip

pub fn get_local_port(&self) -> Option<u16>

获取连接的本地端口

pub fn get_remote_addr(&self) -> Option<SocketAddr>

获取连接的对端地址

pub fn get_remote_ip(&self) -> Option<String>

获取连接的对端ip

pub fn get_remote_port(&self) -> Option<u16>

获取连接的对端端口

pub fn is_security(&self) -> bool

判断是否是安全的Mqtt连接

pub fn is_passive(&self) -> bool

判断是否是被动接收消息

pub fn set_passive(&self, b: bool)

设置是否被动接收消息

pub fn hibernate(&self, ready: Ready) -> Option<Hibernate<S>>

休眠当前连接，直到被唤醒，返回空表示连接已关闭

pub fn wakeup(&self, result: Result<()>) -> bool

唤醒连接

pub fn sub(&self, topic: String)

为当前的Mqtt客户端订阅指定的主题

pub fn unsub(&self, topic: String)

为当前的Mqtt客户端退订指定的主题

pub fn get_session(&self) -> Option<ContextHandle<BrokerSession>>

获取连接会话上下文的只读引用

pub fn send(&self, topic: &String, bin: Vec<u8>)

发送指定主题的数据

pub fn reply(&self, bin: Vec<u8>)

回应指定请求

pub fn close(&self, reason: Result<()>) -> Result<()>

关闭当前连接

Trait Implementations

impl<S: Socket> GrayVersion for MqttConnectHandle<S>

fn get_gray(&self) -> &Option<usize>

fn set_gray(&mut self, gray: Option<usize>)

fn get_id(&self) -> usize

impl<S: Socket> Send for MqttConnectHandle<S>

impl<S: Socket> Sync for MqttConnectHandle<S>