Struct ConnectionInfo 

pub struct ConnectionInfo {

    pub connection_id: String,
    pub user_id: Option<String>,
    pub created_at: Instant,
    pub last_active: Instant,
    pub metadata: HashMap<String, String>,
    pub device_info: Option<DeviceInfo>,
    pub serialization_format: SerializationFormat,
    pub compression: CompressionAlgorithm,
    pub encryption: EncryptionAlgorithm,
    pub authenticated: bool,
    pub authenticated_at: Option<u64>,
    pub negotiation_completed: bool,
    pub negotiation_confirmed: bool,
    pub cached_parser: Option<Arc<MessageParser>>,
    pub cached_pipeline: Option<Arc<MessagePipeline>>,
}

连接信息

Fields

connection_id: String

连接 ID（唯一标识符）

user_id: Option<String>

用户 ID（如果已认证）

created_at: Instant

创建时间

last_active: Instant

最后活跃时间

metadata: HashMap<String, String>

连接元数据

device_info: Option<DeviceInfo>

设备信息（如果已提供）

serialization_format: SerializationFormat

序列化格式（由客户端协商决定，默认 JSON）

compression: CompressionAlgorithm

压缩算法（由客户端协商决定，默认不压缩）

encryption: EncryptionAlgorithm

加密凡事（协商决定）

authenticated: bool

是否已验证（如果启用认证，只有已验证的连接才能收发消息）

authenticated_at: Option<u64>

认证时间戳（Unix 时间戳，秒，如果已验证）

negotiation_completed: bool

协商是否已完成（CONNECT 和 CONNECT_ACK 完成）

negotiation_confirmed: bool

协商是否已确认（客户端收到 CONNECT_ACK 后发送确认，服务端收到后标记） 确认后，消息必须严格按照协商好的方式处理，不再容错

cached_parser: Option<Arc<MessageParser>>

缓存的 MessageParser（协商完成后创建，避免每次消息处理都创建新的 parser）

cached_pipeline: Option<Arc<MessagePipeline>>

缓存的 MessagePipeline（协商完成后创建，如果配置了中间件或处理器）

Implementations

impl ConnectionInfo

pub fn new(connection_id: String, requires_auth: bool) -> Self

创建新的连接信息

参数

• connection_id: 连接 ID
• requires_auth: 是否需要认证（如果为 false，连接直接标记为已验证）

pub fn set_authenticated(&mut self, user_id: Option<String>)

标记为已验证

pub fn is_authenticated(&self) -> bool

检查连接是否已验证

pub fn with_device_info(self, device_info: DeviceInfo) -> Self

设置设备信息

pub fn with_serialization_format(self, format: SerializationFormat) -> Self

设置序列化格式

pub fn with_compression(self, compression: CompressionAlgorithm) -> Self

设置压缩算法

pub fn is_timeout(&self, timeout: Duration) -> bool

检查连接是否超时

pub fn update_active(&mut self)

更新最后活跃时间

Trait Implementations

impl Clone for ConnectionInfo

fn clone(&self) -> ConnectionInfo

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.