开源软件名称：

jo-mqtt

开源软件地址：

https://gitee.com/jo-happy/jo-mqtt

开源软件介绍：

此项目不在维护新功能开发及bug修复请访问：https://github.com/joey-happy/jo-mqtt

jo-mqtt-server

项目介绍

轻量级物联网MQTT服务器, 快速部署, 支持集群.

软件架构说明

基于netty+springboot+redis+hazelcast技术栈实现

使用netty实现通信及协议解析
使用springboot提供依赖注入及属性配置,方便打包及快速部署
推荐使用默认配置RedisExtendProvider实现，支持所有Qos等级消息及cleanSession为false的配置.默认采用pub-sub方式实现集群间通信,可自定义扩展实现
默认ExtendProviderAdapter实现只支持Qos等级为0的消息及cleanSession为true的配置.

不支持

暂且不支持tcp-ssl配置

不支持topic如下

* 不支持为空* 不支持以'/'开始或结束* 不支持命名为'joRootTopic'* 不支持分隔符之间无字符 例如：ab///c* 不支持包含禁用字符 例如：ab/+11 或者c/12#1

项目结构

jo-mqtt  ├── mqtt-broker -- MQTT服务器功能的核心实现  ├── mqtt-springboot -- springboot集成mqtt启动  ├── mqtt-test -- MQTT服务器测试用例

功能说明

参考MQTT3.1.1规范实现
完整的QoS服务质量等级实现
遗嘱消息, 保留消息及消息分发重试
心跳机制
集群功能

快速开始

本地运行
- 代码clone到本地，启动MqttApplication程序即可，tcp连接默认端口1883，websocket连接默认端口2883，配置详情：application-local.properties
jar保运行（本地环境）
- 代码clone到本地，修改application-production.properties的相关配置，用maven达成jar包
- nohup java -jar -Dspring.profiles.active=local mqtt-springboot-1.0.0-SNAPSHOT.jar 2>&1 &

日志文件配置

采用log4j2日志框架，可自行定义日志格式，修改log4j2.xml文件中相关配置即可

集群使用

目前集群默认使用RedisExtendProvider实现扩展，则集群间通信依赖redis的pubsub功能

配置参数

#server configmqtt.serverConfig.tcpPort=1883#-1表示不开启mqtt.serverConfig.webSocketPort=2883mqtt.serverConfig.hostname=mqtt.serverConfig.extendProviderClass=joey.mqtt.broker.provider.redis.RedisExtendProvider#mqtt.serverConfig.extendProviderClass=joey.mqtt.broker.provider.adapter.ExtendProviderAdapter#password 采用sha256hex加密 例子中密码明文和用户名一致mqtt.serverConfig.enableAuth=truemqtt.serverConfig.authUsers[0].userName=localmqtt.serverConfig.authUsers[0].password=25bf8e1a2393f1108d37029b3df5593236c755742ec93465bbafa9b290bddcf6mqtt.serverConfig.authUsers[1].userName=adminmqtt.serverConfig.authUsers[1].password=8c6976e5b5410415bde908bd4dee15dfb167a9c873fc4bb8a81f6f2ab448a918#netty configmqtt.nettyConfig.bossThreads=0mqtt.nettyConfig.workerThreads=0mqtt.nettyConfig.epoll=falsemqtt.nettyConfig.soBacklog=1024mqtt.nettyConfig.soReuseAddress=truemqtt.nettyConfig.tcpNoDelay=truemqtt.nettyConfig.soSndBuf=65536mqtt.nettyConfig.soRcvBuf=65536mqtt.nettyConfig.soKeepAlive=truemqtt.nettyConfig.channelTimeoutSeconds=200#customer config#inner traffic config 如果mqtt.serverConfig.extendProviderClass配置的实现类实现了initInnerTraffic方法 则如下配置无效mqtt.customConfig.innerTrafficConfig.enableHazelcast=falsemqtt.customConfig.innerTrafficConfig.hazelcastConfigFile=classpath:hazelcast/hazelcast-local.xml#mqtt.customConfig.innerTrafficConfig.hazelcastConfigFile=file:/home/hazelcast-local.xml#如果使用了RedisExtendProvider 则必须配置redisConfigmqtt.customConfig.redisConfig.host=localhostmqtt.customConfig.redisConfig.password=mqtt.customConfig.redisConfig.port=6379mqtt.customConfig.redisConfig.database=0mqtt.customConfig.redisConfig.timeout=3000mqtt.customConfig.redisConfig.pool.maxActive=200mqtt.customConfig.redisConfig.pool.maxWait=1000mqtt.customConfig.redisConfig.pool.maxIdle=50mqtt.customConfig.redisConfig.pool.minIdle=20

自定义扩展

若当前功能不能满足用户需求可以自行扩展，使用者只需继承ExtendProviderAdapter复写相应的方法，同时也可以自己实现配置(继承CustomerConfig类,自定义参数)
修改配置文件mqtt.serverConfig.extendProviderClass=joey.mqtt.broker.provider.adapter.XXXXProvider
扩展方法说明（扩展接口：IExtendProvider）
1. 获取messageId存储实现: IMessageIdStore initMessageIdStore();
2. 获取session存储实现: ISessionStore initSessionStore();
3. 获取主题订阅存储实现: ISubscriptionStore initSubscriptionStore(ISessionStore sessionStore);
4. 获取retain消息存储实现: IRetainMessageStore initRetainMessageStore();
5. 获取pubMessage消息存储实现: IDupPubMessageStore initDupPubMessageStore();
6. 获取pubRelMessage消息存储实现: IDupPubRelMessageStore initDupPubRelMessageStore();
7. 获取授权管理实现: IAuth initAuthManager(List userList);
8. 获取集群间通信实现: IInnerTraffic initInnerTraffic(InnerPublishEventProcessor innerPublishEventProcessor);
9. 获取事件监听器列表: List initEventListeners();

参考实现

https://github.com/moquette-io/moquette
https://gitee.com/recallcode/iot-mqtt-server
https://github.com/Cicizz/jmqtt
https://github.com/Wizzercn/MqttWk
https://github.com/daoshenzzg/socket-mqtt
https://github.com/1ssqq1lxr/iot_push

压测工具

https://github.com/takanorig/mqtt-bench 拷贝mqtt-test工程下mqtt-mock文件到测试机执行即可
https://github.com/daoshenzzg/mqtt-mock

工具推荐

https://github.com/looly/hutool Hutool是一个小而全的Java工具类库作者有问必答强烈推荐
http://www.tongxinmao.com/txm/webmqtt.php 在线mqtt测试
https://blog.csdn.net/Just_shunjian/article/details/78288229 Linux 内核优化-调大TCP最大连接数
https://github.com/xiaojiaqi/C1000kPracticeGuide C1000k优化实践