MQTT---HiveMQ源码详解(一)概览

2017-10-22 本文已影响333人西安PP

面向群体

HiveMQ是企业级MQTT Broker，提供高性能、高可用、高扩展、高安全性的企业级服务。

它是纯Java实现的。

官网地址:http://www.hivemq.com

基于它如上的描述，所以后续我们就是基于它的高性能、高可用、高扩展、高安全性这几个特点来分析它的源码。

注意：本篇源码都是基于HiveMQ 3.1.2版本源码讲解。

这里写图片描述

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是处理消息在当前节点的信息存储。