iot-mqtt,由 java 和 netty 实现的 MQTT 代理,支持持久性。
本项目完全借鉴 jmqtt 项目 https://github.com/Cicizz/jmqtt 目前只是对部分代码进行了梳理重构,去除了集群部分, 修正了一些 bug,并加入简单的 $SYS/实现,后期会加入原创的集群的实现。 现在已对 mqtt3.1.1 协议有完整的实现。 本项目默认采用 rocksdb 做消息的持久化,所以即使项目故障推出,也不会丢失数据,恢复项目后可以自动重连发送。 运行方法: