关键词：

文章目录

• 前言
• • broker列表
  • • 整体比较(MQTT 官网提供)
    • HiveMQ
    • • 支持特性
      • 说明
      • 相关资料
    • ActiveMQ
    • • 支持特性
      • 相关资料
    • ActiveMQ Artemis
    • • 支持特性
      • 相关资料
    • RabbitMQ
    • Mosquitto
    • flespi
    • Mosca
    • VerneMQ
    • • 支持特性
      • 相关资料
    • emqx
    • • 相关资料
    • vertx-mqtt-broker
    • • 支持特性
      • 相关资料
    • **moquette**
    • • 相关资料
    • Jmqtt
    • • 支持特性
      • 相关资料
    • MqttWk
    • • 特征
      • 备注
      • 相关资料
  • 参考文献

前言

本次博文就MQTT实现进行描述，后续会陆续更新相关内容。

broker列表

整体比较(MQTT 官网提供)

Server	QoS 0	QoS 1	QoS 2	auth	bridge	$SYS	SSL	dynamic topics	cluster	websockets	plugin system
2lemetry	✔	✔	✔	✔	✔	§	✔	✔	✔	✔	✘
Jmqtt	✔	✔	✔	✔	✔	§	§	✔	§	✔	✔
Apache ActiveMQ	✔	✔	✔	✔	✘	✘	✔	✔	✔	✔	✔
Apache ActiveMQ Artemis	✔	✔	✔	✔	✘	✘	✔	✔	✔	✔	✔
Bevywise IoT Platform	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔	rm
emitter	✔	§	✘	✔	✘	✘	✔	✔	✔	✔	✘
emqttd	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔
flespi	✔	✔	✔	✔	✘	✘	✔	✔	✔	✔	✘
GnatMQ	✔	✔	✔	✔	✘	✘	✘	✔	✘	✘	✘
HBMQTT	✔	✔	✔	✔	✘	✔	✔	✔	✘	✔	✔
HiveMQ	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔
IBM WIoTP Message Gateway	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔
JoramMQ	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔
Mongoose	✔	✔	?	?	?	?	?	?	?	?	?
moquette	✔	✔	✔	✔	?	?	✔	?	rm	✔	✘
mosca	✔	✔	✘	✔	?	?	?	?	✘	✔	✘
mosquitto	✔	✔	✔	✔	✔	✔	✔	✔	§	✔	✔
MQTT.js	✔	✔	✔	§	✘	✘	✔	✔	✘	✔	✘
MqttWk	✔	✔	✔	✔	✔	?	✔	✔	✔	✔	✘
RabbitMQ	✔	✔	✘	✔	✘	✘	✔	✔	?	?	?
RSMB	✔	✔	✔	✔	✔	✔	✘	✔	✘	✘	?
Software AG Universal Messaging	✔	✔	✔	✔	✘	✘	✔	✔	✔	rm	✘
Solace	✔	✔	✘	✔	§	✔	✔	✔	✔	✔	✘
SwiftMQ	✔	✔	✔	✔	✔	✘	✔	✔	✔	✘	✔
Trafero Tstack	✔	✔	✔	✔	✘	✘	✔	✔	✘	✘	✘
VerneMQ	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔	✔
WebSphere MQ	✔	✔	✔	✔	✔	✔	✔	✔	?	?	?

Broker	开源	语言	连接方式	QoS	共享订阅	持久化	集群
mosquitto	✔	C/C++	4种	全部	✘	？	✘
hui6075/mosquitto	✔	C/C++	4种	全部	✘	？	✔
moquette0.10	✔	Java	4种	全部	✘	✔	✔
moquette0.12	✔	Java	4种	全部	✘	§	✘
EMQ2.0+	✔	Erlang	4种	全部	✘	✔	✔
EMQ3.0+	✔	Erlang	4种	全部	✔	✔	✔
EMQ PLUS	✘	Erlang	4种	全部	✔	✔	✔
Jmqtt1.1.0	✔	Java	无SSL	全部	✘	✔	✘
MqttWk	✔	Java	4种	全部	✘	§	§
HiveMQ	✔	Java	4种	全部	✔	✔	✔

• ✔ - 支持
• ✘ - 不支持
• ？ - 不了解
• § - 支持但做得不好（有限制）

HiveMQ

HiveMQ是企业级的Broker，用Java编写，功能齐全，存在Github社区版版本。

• hivemq-community-edition【基于Java的开源MQTT代理，完全支持MQTT 3.x和MQTT5】
• hivemq-mqtt-client【MQTT3.1.1和MQTT5都支持，实现极高的吞吐量和低内存消耗】
• mqtt-cli【命令行界面】

支持特性

• MQTT 3.1 / 3.1.1 / 5.0
• 完整QoS支持
• 分布式集群支持
• 持久化支持
• 流量控制支持
• 完整连接方式支持
• IPv6支持
• 集群共享订阅
• $SYS统计信息主题
• JMX性能监控
• 日志打印
• Docker部署
• ……

说明

• 集群是基于Jgroups的，持久化的数据都是本地+Jgroups同步
• 订阅树也是完整的订阅树，优秀的缓存和并发访问控制，集群进行数据同步
• 多线程和并发等用的google的guava进行防御性编程

相关资料

• HiveMQ官网
• MQTT—HiveMQ源码系列解读
• MQTT面板
• 包下载

ActiveMQ

Apache许可证下开源项目，官网地址。

支持特性

• 支持Java，C，C ++，C＃，Ruby，Perl，Python，PHP 的各种

  跨语言客户端和协议

  • 适用于Java，C，C ++，C＃的高性能客户端的OpenWire
  • Stomp支持，因此可以轻松地用C，Ruby，Perl，Python，PHP，ActionScript / Flash，Smalltalk和ActiveMQ以及任何其他流行的Message Broker进行对话来编写客户端
  • AMQP v1.0支持
  • MQTT v3.1支持允许在IoT环境中进行连接。

• 在JMS客户端和Message Broker中完全支持企业集成模式

• 支持许多高级功能，例如消息组，虚拟目标，通配符和组合目标

• 完全支持JMS 1.1和J2EE 1.4，并支持瞬时，持久性，事务性和XA消息传递

• Spring支持，因此ActiveMQ可以轻松地嵌入到Spring应用程序中，并使用Spring的XML配置机制进行配置

• 在流行的J2EE服务器（例如TomEE，Geronimo，JBoss，GlassFish和WebLogic）中进行了测试

  • 包括用于入站和出站消息传递的JCA 1.5资源适配器，以便ActiveMQ应该在任何符合J2EE 1.4的服务器中自动部署

• 支持可插拔的传输协议，例如VM，TCP，SSL，NIO，UDP，多播，JGroups和JXTA传输

• 使用JDBC和高性能日志支持非常快速的持久性

• 专为高性能集群，客户端-服务器，基于对等的通信而设计

• REST API可为消息传递提供与技术无关和语言无关的基于Web的API

• Ajax支持使用纯DHTML对Web浏览器的Web流支持，从而允许Web浏览器成为消息传递结构的一部分

• CXF和Axis支持，因此ActiveMQ可以轻松地放入这两个Web服务堆栈中，以提供可靠的消息传递

• 可用作内存JMS提供程序，非常适合单元测试JMS

相关资料

• 启用MQTT

ActiveMQ Artemis

ActiveMQ的“下一代”，是支持MQTT的多协议消息代理。下一代高性能，非阻塞架构，基于事件驱动的消息系统。

支持特性

• 提供实现JMS 1.1 & 2.0 的客户端,包含JNDI
• 通过共享存储和网络复制提供高可用
• 简单&强大的协议无感知的寻址模型(addressing model)
• 灵活的集群用于分布式负载
• 基于日志的低延迟持久化
• 方便从ActiveMQ 5迁移

相关资料

• Activemq Artemis笔记
• Activemq Artemis官网
• Activemq Artemis实战

RabbitMQ

RabbitMQ是AMQP消息代理，带有MQTT插件（从3.x版开始捆绑销售）。也可以使用公共测试服务器。功能受限。

Mosquitto

开源MQTT Server，可惜是C和C++的开源库。

Eclipse Mosquitto是实现MQTT协议版本5.0、3.1.1和3.1的开源消息代理（经EPL / EDL许可）。Mosquitto轻巧，适合在从低功耗单板计算机到完整服务器的所有设备上使用。

MQTT协议提供了使用发布/订阅模型执行消息传递的轻量级方法。这使其适用于物联网消息传递（例如，低功率传感器）或移动设备（例如电话，嵌入式计算机或微控制器）。

flespi

flespi是一项公开的，免费的，基于云的MQTT代理服务，具有声明的3.1、3.1.1、5.0协议合规性。高容量目标架构，隔离的MQTT名称空间，WebSockets / SSL支持，可配置的ACL，商业和免费的SLA，由HTTP REST API管理。

可惜是Node.js，python和Lua语言的开源。

Mosca

非java,官网。

VerneMQ

VerneMQ是高性能的分布式MQTT消息代理。它在商品硬件上水平和垂直扩展，以支持大量并发发布者和使用者，同时保持较低的延迟和容错能力。VerneMQ是用于IoT平台或智能产品的可靠消息中心。

VerneMQ实现了MQTT 3.1、3.1.1和5.0规范。

支持特性

• QoS 0，QoS 1，QoS 2
• 基本认证和授权
• 桥梁支撑
• $ SYS监视和报告树
• TLS（SSL）加密
• Websockets支持
• 集群支持
• 日志记录（控制台，文件，系统日志）
• 向石墨报告
• 可扩展的插件架构
• 每个ClientId多个会话
• 会话平衡
• 共享订阅
• 消息负载调整
• 邮件减载（用于系统保护）
• 脱机消息存储（基于LevelDB）
• 队列可以处理消息FIFO或LIFO样式。
• MongoDB身份验证和集成
• Redis身份验证和集成
• MySQL身份验证和集成
• PostgreSQL身份验证和集成
• Memcached整合
• HTTP整合
• HTTP Webhooks
• 代理协议v2
• 管理HTTP API（BETA）
• 实时MQTT会话跟踪
• 完全多租户
• 群集状态网页

相关资料

• 开源

emqx

EMQ X是一个完全完全开放的平台，高度可扩展，高可用的分布式MQTT消息服务器，适用于IoT，M2M和移动应用程序，可处理千万等级的并发客户端。

从3.0版本开始，EMQ X完全支持MQTT V5.0协议规范，向下兼容MQTT V3.1和V3.1.1，并支持MQTT-SN，CoAP，LwM2M，WebSocket和STOMP等通信协议。EMQX 3.0单价可支持千万等级的MQTT并发连接。

相关资料

• 开源
• 如何做到数据存储
• EMQ讲解（物联网架构之路系列）
• 官网

vertx-mqtt-broker

开源项目。

支持特性

• MQTT v3.1和v3.1.1支持
• 支持QoS 0、1和2消息
• 持久性和会话管理（cleanSession = false）
• 可插拔身份验证（通过vert.x verticle系统）
  • OAuth 2.0和OpenID Connect 1.0身份验证
  • JWT认证
• 多租户
• 通过WebSocket的MQTT
• 保留标志
• 通过TCP和Websocket的TLS支持
• 同一代理引擎中的多个tcp / websocket传输
• 经纪人到经纪人双向和桥接

相关资料

• 开源

moquette

轻量级MQTT代理,官网在此。

相关资料

• 开源

Jmqtt

由Java和Netty实现的MQTT代理，支持持久性和集群

支持特性

• 基于Java及Netty开发，插件化模式，高性能，高扩展性
• 支持mqtt协议qos0，qos1，qos2消息质量服务
• 支持mqtt协议cleansession，retain，will等消息服务
• 完整支持mqtt Topic匹配过滤
• 支持websocket协议
• 支持RocksDB进行数据本地存储，数据高可靠

相关资料

• 开源

MqttWk

基于nutzboot+netty+redis+kafka的Java MQTT broker。

特征

1. 参考MQTT3.1.1规范实现
2. 完整的QoS服务质量等级实现
3. 遗嘱消息, 保留消息及消息分发重试
4. 心跳机制
5. MQTT连接认证(可选择是否开启)
6. SSL方式连接(可选择是否开启)
7. 主题过滤(支持单主题订阅如 test_topic /mqtt/test --不能以/结尾, 通配符订阅 # /mqtt/# --以#结尾)
8. Websocket支持(可选择是否开启)
9. 集群功能(可选择是否开启)
10. Kafka消息转发功能(可选择是否开启)

备注

主题有一些限制，不能以/结尾，不支持通配符订阅+

相关资料

• 开源

参考文献

MQTT协议5.0规范

MQTT协议3.1.1规范
MQTT Broker的需求和各大Broker对比

物联网之mqtt3.1.1和mqtt5协议(14)pingresp报文

文章目录前言PINGRESP–PING响应固定报头可变报头有效载荷PINGRESP行为前言服务端发送PINGRESP报文响应客户端的PINGREQ报文。表示服务端还活着。此报文被用在保活(KeepAlive)的处理中。PINGRESP–PING响应固定报头可变报头PINGRESP报文没有... 查看详情

物联网之mqtt3.1.1和mqtt5协议(21)mqtt系列博文总览

文章目录协议基础部分协议实现部分协议基础部分1.术语部分2.报文分类：CONNECT报文CONNACK报文PUBLISH报文PUBACK报文PUBREC报文PUBREL报文PUBCOMP报文SUBSCRIBE报文SUBACK报文UNSUBSCRIBE报文UNSUBACK报文PINGREQ报文PINGRESP报文DISCONNECT报文AUTH操... 查看详情

物联网之mqtt3.1.1和mqtt5协议(20)mqtt相关开源实现server或broker列表（会不断更新）(代码片段)

文章目录前言broker列表整体比较(MQTT官网提供)HiveMQ支持特性说明相关资料ActiveMQ支持特性相关资料ActiveMQArtemis支持特性相关资料RabbitMQMosquittoflespiMoscaVerneMQ支持特性相关资料emqx相关资料vertx-mqtt-broker支持特性相关资料**moquette**相... 查看详情

物联网之mqtt3.1.1和mqtt5协议(19)mqtt协议一致性条款和mqtt5新特性

文章目录一致性一致性条款MQTT服务端一致性条款MQTT客户端一致性条款MQTT5新特性会话过期消息过期所有确认报文原因码所有确认报文原因字符串服务端断开载荷格式和内容类型请求/响应共享订阅订阅标识符主题别名流量控制用... 查看详情

物联网之mqtt3.1.1和mqtt5协议(13)pingreq报文

文章目录前言PINGREQ–PING请求固定报头可变报头有效载荷PINGREQ行为前言客户端发送PINGREQ报文给服务端的。用于：在没有任何其它控制报文从客户端发给服务端时，告知服务端客户端还活着。请求服务端发送响应确认它还... 查看详情

mqtt5.0介绍

...因为其轻量、灵活等特点成为了当今世界上最受欢迎的物联网协议，它已经广泛应用于车联网、智能家居、物流、即时聊天应用和移动消息推送等领域，连接了数以亿计的设备，并且每时每刻都有无数设备开始使用和接入MQTT协... 查看详情

mqtt协议规范(代码片段)

...议，消息发送者与接收者不受时间和空间的限制。物联网平台支持设备使用MQTT协议接入。支持版本目前物联网平台支持MQTT标准协议接入，兼容5.0、3.1.1和3.1版本协议，具体的协议请参见MQTT5.0、MQTT3.1.1和 MQTT3.1协议文... 查看详情

转战物联网·基础篇06-深入理解mqtt协议之基本术语

??通过上一节我们对MQTT协议已经有了初步的印象，这一节我们开始深入的理解一下MQTT协议，介绍常用的MQTT3.1.1版本，5.0版本后面指介绍新增部分即可。这一节我们先介绍MQTT里常用的术语（非官方文档直接复制）。??网络连接(Netw... 查看详情

mqttv5(mqtt5.0)新特性介绍

...了。MQTT的新版本(v5.0)在v3的基础上，增加了以下的特性：协议上，增加了一个Property字段，正是这个字段，使得MQTT5.0可以支持众多的新特性。而在MQTT3.1.1中，MQTT没有任何可以拓展的地方，限制了MQTT拓展功能的可能性。会话过期... 查看详情

2021-12-20wpf上位机113-欧姆龙协议之读写方法流程解析(代码片段)

前言随着人工智能的不断发展，物联网这门技术也越来越重要，很多人都开启了物联网学习，本文就介绍了物联网的欧姆龙协议协议。提示：以下是本篇文章正文内容，下面案例可供参考一、欧姆龙协议之读写方法流程解析示例... 查看详情

mqtt从入门到提高|05mqtt3.1.1之publish发布工作流

....csdn.net/RobotFutures/article/details/1257557901.概述本文描述了MQTT协议中最核心的应用协议PUBLISH–发布消息工作流。2.PUBLISH发布消息PUBLISH控制包从客户端发送到服务器或从服务器发送到客户端以传输应用程序消息。2.1固定报文头2.1.1DUPDU... 查看详情

物联网常见协议之amqp协议及使用场景解析(代码片段)

...议之间的对比以及使用实践。本文分享自华为云社区《物联网常见协议之Amqp协议及使用场景解析》，作者：张俭。引言本文围绕AMQP协议，为大家详细解析AMQP协议、核心技术亮点、多协议之间的对比以及使用实践，并介绍华为云... 查看详情

到2021年7月物联网协议有以下主流协议

1.MQTT协议MQTT协议（MessageQueue TelemetryTransport，消息队列遥测传输协议）是IBM的AndyStanford-Clark和Arcom的ArlenNipper于1999年为了一个通过卫星网络连接输油管道的项目开发的。为了满足低电量消耗和低网络带宽的需求，MQ... 查看详情

一文读懂物联网mqtt协议之实战篇(代码片段)

...我们介绍了MQTT协议格式以及相关的特性：一文读懂物联网MQTT协议之基础特性篇，这一篇我们就来实战一番，理论得与实践结合，方能吃透MQTT。我的那个读者还提到了讲一下Mosquitto，这是一款开源消息代理软... 查看详情

一文读懂物联网mqtt协议之实战篇(代码片段)

...我们介绍了MQTT协议格式以及相关的特性：一文读懂物联网MQTT协议之基础特性篇，这一篇我们就来实战一番，理论得与实践结合，方能吃透MQTT。我的那个读者还提到了讲一下Mosquitto，这是一款开源消息代理软... 查看详情

一文读懂物联网mqtt协议之基础特性篇(代码片段)

...c;Java后端主流技术栈的原理、源码分析、架构以及各种互联网高并发、高性能、高可用的解决方案。一、前言上个月有个读者问我物联网MQTT协议实战相关的问题，我说后面会搞，没想到不知不觉一个月了，太忙了ÿ... 查看详情

一文读懂物联网mqtt协议之基础特性篇(代码片段)

...c;Java后端主流技术栈的原理、源码分析、架构以及各种互联网高并发、高性能、高可用的解决方案。一、前言上个月有个读者问我物联网MQTT协议实战相关的问题，我说后面会搞，没想到不知不觉一个月了，太忙了ÿ... 查看详情

物联网核心协议—消息推送技术演进

    消息触达能力是物联网（internetofthings,IOT）的重要支撑，而物联网很多技术都源于移动互联网。本文阐述移动互联网消息推送技术在物联网中的应用和演进。一、物联网架构和关键技术   从开发的角度，无... 查看详情