WebSocket插件

✨ 核心特性

• 高性能通信：基于 Netty NIO 框架，支持高并发连接
• 责任链处理：认证 → 解密 → 参数增强 → 路由 → 订阅，流程清晰可扩展
• 双路由模式：支持本地路由（单机）和 MQTT 路由（分布式）
• 多消息类型：点对点消息、租户广播、自定义主题
• 安全机制：Token 认证、消息加密（AES/Base64）、限流保护
• 注解驱动：通过 @MqttSubscribeTopic 注解声明主题监听

1️⃣ WebSocket 服务器（MqttNettyServer）

功能：基于 Netty 的 WebSocket 服务器，支持高并发连接

2️⃣ 责任链消息处理流程

消息按顺序经过以下处理链：

3️⃣ 消息类型（MessageTypeEnum）

4️⃣ 主题消息策略

{
  "toUserId": 123,  // 接收者用户ID
  "msg": "Hello!"   // 消息内容
}

🛡️ 限流保护（RateLimitHandler）

基于令牌桶算法的限流机制：

• 默认速率：100 条/秒
• 桶容量：300 条（容忍 3 秒突发流量）
• 特性：每个 Channel 独立限流，连接关闭自动清理

💓 心跳检测（HeartbeatHandler）

基于 Netty IdleStateHandler 的心跳机制：

• 读空闲：2 秒无数据读取触发
• 写空闲：4 秒无数据写入触发
• 全空闲：10 秒无任何活动触发
• Pong 检测：配置最大丢失次数自动断开连接

🌐 MQTT 分布式路由（MqttAutoConfiguration）

支持分布式场景下的消息路由：

• 配置启用： jeelowcode.mqtt.senderType=mqtt
• 发布/订阅：通过 MqttGateway 发送消息到 MQTT Broker
• QoS 支持：0=最多一次、1=至少一次、2=仅一次
• 事件驱动：通过 ApplicationEventPublisher 发布 MqttMessageEvent
• 跨节点通信：多实例之间通过 MQTT Broker 路由消息

配置参数：

• jeelowcode.mqtt.host - MQTT Broker 地址
• jeelowcode.mqtt.username - MQTT 用户名
• jeelowcode.mqtt.password - MQTT 密码

📌 注解驱动订阅（@MqttSubscribeTopic）

通过注解声明式配置主题监听：

@Component
@MqttSubscribeTopic(
    topics = "myTopic@@1",              // 订阅的主题列表
    requireLogin = true,                // 是否需要登录
    kickoutAfter = false,               // 是否踢出之前的订阅者
    enableSysEncrypt = false,           // 是否启用系统加密
    selfParamStrategies = {...},       // 自定义参数策略
    selfCryptoStrategies = {...}       // 自定义加密策略
)
public class MyMessage implements IMessageStrategy {
    @Override
    public void handleMessage(String topic, MqttDataVo vo) {
        // 处理消息逻辑
    }
}

MqttDataVo 消息对象

{
  "header": {
    "sessionId": "channel-session-id",   // 会话ID
    "token": "user-auth-token",          // 认证Token
    "topic": "p2p@@1",                    // 主题
    "messageType": "message"              // 消息类型
  },
  "body": "{...}",                        // 消息体（JSON字符串）
  "enhanceParam": {                       // 增强参数（由参数链添加）
    "key": "value"
  }
}

🔐 自定义加密策略

实现 ICryptoStrategy 接口：

• AesStrategy：AES 对称加密
• Base64Strategy：Base64 编解码
• SystemStrategy：系统默认加密
• 自定义策略：通过 @MqttSubscribeTopic 配置

📊 自定义参数增强策略

实现 IParamStrategy 接口：

• 对消息进行参数验证
• 添加额外的业务参数到 enhanceParam
• 支持多个策略链式执行

🎯 自定义消息处理

实现 IMessageStrategy 接口并使用 @MqttSubscribeTopic 注解：

• 定义自己的主题名称
• 实现自定义的消息处理逻辑
• 配置认证、加密、参数增强策略