概述

消息队列遥测传输（Message Queuing Telemetry Transport，简称MQTT）是一种基于发布/订阅范式的轻量级即时通讯协议，专为低带宽和不可靠网络环境设计，它通过减少网络带宽和资源的消耗，同时提供可靠的消息传递机制，广泛应用于物联网（IoT）、消息通知、智能设备远程控制等领域，本文将详细介绍目前市场上几种主流的MQTT Broker。

主流MQTT Broker

EMQX

简介

EMQX是一款高性能、可伸缩、高可靠性的分布式MQTT消息服务器，基于Erlang/OTP平台开发，具备处理百万级MQTT连接的能力，单机支持500万连接，集群可扩展至1亿并发连接。

主要功能

高性能：单节点支持500万连接，集群支持1亿连接。

高可用性：支持多节点集群、自动故障迁移和高可用性。

可扩展性：支持水平扩展，可根据需求动态添加或删除节点。

安全性：支持SSL/TLS加密、X.509证书认证、客户端认证等。

数据持久化：支持多种数据库后端，如Redis、MySQL等。

规则引擎：内置规则引擎，支持SQL、Java、JavaScript等多种语言进行数据处理。

桥接功能：支持与其他MQTT Broker或不同集群之间的消息桥接。

适用场景

适用于需要高吞吐量、低延迟和高可用性的场景，如智慧城市、车联网、工业互联网等。

Mosquitto

简介

Eclipse Mosquitto是一个轻量级的开源MQTT broker，实现了MQTT 3.1和MQTT 5.0协议，它使用C语言开发，具有低资源占用和高性能的特点。

主要功能

轻量级：资源占用少，适合在嵌入式设备上运行。

高兼容性：支持MQTT 3.1和MQTT 5.0协议。

持久化：支持消息持久化，确保消息在Broker重启后不会丢失。

插件机制：支持多种插件，如身份验证、授权、消息过滤等。

桥接功能：支持与其他MQTT broker的桥接。

适用场景

适用于资源受限的环境，如智能家居、智能农业、小型物联网项目等。

HiveMQ

简介

HiveMQ是一个企业级的MQTT broker，基于Java开发，提供了丰富的功能和强大的扩展性。

主要功能

高性能：支持高吞吐量和低延迟的消息传递。

集群部署：支持多节点集群部署，实现高可用性和水平扩展。

安全机制：支持SSL/TLS加密、细粒度的访问控制和用户认证。

可视化管理：提供Web控制台，用于监控和管理broker。

数据持久化：支持消息持久化到多种数据库后端。

扩展性：支持插件机制，可以根据需求定制功能。

适用场景

适用于中大型企业的物联网项目，如智能制造、智慧城市、车联网等。

VerneMQ

简介

VerneMQ是一个高性能的分布式MQTT broker，基于Erlang/OTP平台开发，专注于高吞吐量和低延迟的消息传递。

主要功能

高吞吐量：支持高并发连接和消息传递。

低延迟：优化了网络协议栈，降低消息传递延迟。

高可用性：支持多节点集群部署，实现高可用性。

水平扩展：支持动态添加或删除节点，实现无缝扩展。

数据持久化：支持消息持久化到多种数据库后端。

桥接功能：支持与其他MQTT broker的桥接。

适用场景

适用于对性能要求极高的场景，如高频交易系统、实时监控系统等。

RabbitMQ（MQTT插件）

简介

RabbitMQ本身是一款流行的消息代理软件，但它也通过插件支持MQTT协议，这使得RabbitMQ可以作为MQTT broker使用，结合其现有的消息队列功能，提供更灵活的消息传递机制。

主要功能

多功能集成：结合了RabbitMQ的AMQP协议与MQTT协议，提供更灵活的消息传递机制。

持久化：支持消息持久化到磁盘，确保消息在Broker重启后不会丢失。

高可用性：支持镜像队列，确保消息的高可用性。

可视化管理：提供Web管理界面，用于监控和管理消息队列。

插件机制：支持多种插件，如延迟消息、死信队列等。

适用场景

适用于需要同时使用AMQP和MQTT协议的场景，如复杂的消息传递系统、混合协议应用等。

介绍了当前市场上几种主流的MQTT Broker，包括EMQX、Mosquitto、HiveMQ、VerneMQ和RabbitMQ（MQTT插件），每种Broker都有其独特的优势和适用场景，选择合适的Broker需要根据具体的应用场景和需求来决定，无论是追求高性能、高可用性，还是注重轻量化和易用性，都能找到相应的解决方案来满足物联网项目中的消息传递需求。