iot-mqttJava 和 Netty 实现的 MQTT 代理
iot-mqtt,由 java 和 netty 实现的 MQTT 代理,支持持久性。
本项目完全借鉴 jmqtt 项目 https://github.com/Cicizz/jmqtt
目前只是对部分代码进行了梳理重构,去除了集群部分, 修正了一些 bug,并加入简单的 $SYS/实现,后期会加入原创的集群的实现。
现在已对 mqtt3.1.1 协议有完整的实现。 本项目默认采用 rocksdb 做消息的持久化,所以即使项目故障推出,也不会丢失数据,恢复项目后可以自动重连发送。 运行方法:
- maven build 出相应 jar 包,放入release/bin。
- cd release/bin 目录 执行相应方法 ,相关配置在 config 目录下。
- server 启动 broker,默认1883 端口,用户名 admin 密码 123456。
- subscribe_test启动接受服务,默认监听/QOS0,/QOS1,/QOS2,三个主题。
- send_test启动发送服务,向/QOS0,/QOS1,/QOS2三个主题,并发1000个线程发送消息,共200万个消息。
- subscribe_sys启动监控服务,默认监听$SYS/主题.并显示当前所有client信息,包含每个client 接受消息数,发送消息数,关注的主题,等信息。
评论
Moquette-mqttJava 的 MQTT 代理
Moquette是Java的MQTT代理实现,支持QoS0,QoS1和QoS2。Moquette设计为事件,使用Netty作为协议编码和解码,协议逻辑本质上是单线程,并且通过LMAXdisruptor
Moquette-mqttJava 的 MQTT 代理
0
HiveMQ企业级的 MQTT 代理
HiveMQ是一个企业级的MQTT代理,主要用于企业和新兴的机器到机器M2M通讯和内部传输,最大程度的满足可伸缩性、易管理和安全特性。提供免费的个人版。HiveMQ提供了开源的插件开发包。
HiveMQ企业级的 MQTT 代理
0
smqtt高性能的 MQTT 消息代理
SMQTT基于Netty开发,底层采用Reactor3反应堆模型,支持单机、集群和容器化部署,具备低延迟、高吞吐量,支持百万TCP连接,同时支持多种协议交互、规则引擎,是一款非常优秀的消息中间件!sm
smqtt高性能的 MQTT 消息代理
0
MQTT.Chat开源的MQTT 消息传递代理
MQTT.Chat是一个完全开源、扩展强、高可用、面向物联网的分布式Mqtt 消息传递代理。它是基于MQTTnet 并集成了X509证书进行双向通讯加密和验证!1、安全连接,访问控制 SSL/TL
MQTT.Chat开源的MQTT 消息传递代理
0