- 为C/S模式开发封装简单统一的编程模式
- 网络基础问题的解决与支持:如心跳保持、压缩解压缩、编码与解码、加密与解密等
- 各种网络参数、连接池实现、监听器实现等可配置可替换
- 提供数据统计/监控组件
- future: 封装同步和异步调用
- listener: 封装事件监听包括消息、通道、异常三类事件监听器
- service: 封装C/S模型、通道、心跳管理、消息分发等核心模块
单Broker8核16G,支持44万连接;1万客户端 单消息1024B 下行tps: 16万+; 4000客户端 Publish 单消息1024B 上行tps: 17万+千兆网卡流量基本打满。 备注:Mqtt Server启动内存只分配叻5G如果分配到10G,理论上可以支持百万连接还有,测试开启了心跳上报
- 基于内存数据库的模拟订阅推送
// 设置启动信息统计。默认true // 设置啟用心跳功能默认true // 服务状态端口。默认8001 // 设置工作线程数量默认CPU个数+1
// 是否开户业务处理线程池。默认false // 自定义监听器可处理相关事件
- 支歭MQTT主题过滤机制
- 完整的QoS服务质量等级实现DEMO
- 遗嘱消息, 保留消息及消息分发重试