架构图
这里写图片描述
- Handlers由实现Netty ChannelHandlerAdapter。处理SSL;处理MQTT协议的codec；处理监控数据收集;处理流量限制;扩展点回调触发等客户端长链接。
- SPI是HiveMQ扩展出来为做HiveMQ Broker端二次开发,提供各种Callback、 Cache、Scheduler、Authentication、Authorization、Configuration等等扩展点;还提供了各种异步/同步的接口Service。以便开发人员基于HiveMQ开发属于自己的业务；
- Plugins是基于SPI提供出来的扩展点，按照HiveMQ的Plugin开发要求，注册属于客户自己的Plugin，HiveMQ官方也给我们提供出来了一些基础插件及各种插件的示例。
- ClusterServices是处理集群连接、数据备份、数据交换、节点状态、一致性has虚拟节点等处理的一堆Service
- Persistences是处理消息的存储、Cluster节点间的数据存储／同步。
- LocalPersistences是处理消息在当前节点的信息存储。
开源框架使用
- 使用Guice做DI
- 使用Netty 4做网络框架
- 使用JGroups做Cluster Node之间的集群通讯
- 使用Exodus做Broker信息文件持久化存储
- 使用Dropwizard Metrics做Broker的统计、监控
- 使用Kryo做序列化/反序列化
- 使用Jetty做Broker端servlet容器
- 使用Resteasy做Broker端restfull框架
- 使用Quartz/做Broker端任务的调度
其他还有一些使用的框架不一一列举
Why?
为什么研究MQTT Broker
- 想自己实现手机app推送
- MQTT协议轻量/QoS保证
为什么选择HiveMQ
- 它支持Plugin开发
- 它支持Cluster
- 它的代码相当严谨，包括性能考虑/内存考虑
源码从哪来的？
- 博主花了一年的业余时间，将hivemq混淆过的源码反编译了
MQTT交流群:221405150
RocketMQ交流群:10648794
NewSQL交流群:153575008
注：本文内容来自互联网，旨在为开发者提供分享、交流的平台。如有涉及文章版权等事宜，请你联系站长进行处理。