为什么需要订阅标识符 在大部分MQTT客户端的实现中，都会通过回调机制来实现对新到达消息的处理。 但是在回调函数中，我们只能知道消息的主题名是什么。如果是非通配符订阅，订阅时使用的主题过滤器将和消息中的主题名完全一致，所以我们可以直接建立订阅主题与回调函数的映射关系。然后在消息到达时，根据消息中的主题名查找并执行对应的回调函数。 但如果是通配符订阅，消息中的主题名和订阅时的主题过滤器将是两个不同的字符串，我们只有将消息中的主题名与原始的订阅挨个进行主题匹配，才能确定应该执行哪个回调函数。这显然极大地影响了客户端的处理效率。 另外，因为MQTT允许一个客户端建立多个订阅，那么当客户端使用通配符...

在MQTT发布/订阅模式介绍这篇博客中，我们已经了解到，我们需要先向服务端发起订阅，才能从服务端接收对应的消息。如果说订阅时指定的主题过滤器决定了服务端将向我们转发哪些主题下的消息，那么订阅选项则是允许我们进一步定制服务端的转发行为。 在本文中，我们将重点介绍在MQTT中哪些订阅选项可供我们使用，以及它们的使用方法。 订阅选项 在MQTT中，一个订阅由一个主题过滤器和对应的订阅选项组成。所以理论上，我们可以为每个订阅都设置不同的订阅选项。 MQTT5.0提供了4个订阅选项，分别是QoS、NoLocal、RetainAsPublished、RetainHandling，而MQTT3.1.1则仅提...

MQTT如何与Kafka一起使用？ MQTT(MessageQueuingTelemetryTransport)是一种轻量级的消息传输协议，专为受限网络环境下的设备通信而设计。ApacheKafka是一个分布式流处理平台，旨在处理大规模的实时数据流。 Kafka和MQTT是实现物联网数据端到端集成的互补技术。通过结合使用Kafka和MQTT，企业可以构建一个强大的物联网架构，实现设备和物联网平台之间的稳定连接和高效数据传输。同时，它还能支持整个物联网系统高吞吐量数据的实时处理和分析。 MQTT和Kafka的集成可以为许多物联网场景带来重要价值，例如网联汽车和车联网、智能城市基础设施、工业物联网...

ReasonCode ReasonCode在MQTT中的主要作用是为客户端和服务端提供更详细的反馈。比如我们可以在CONNACK报文中将用户名或密码错误对应的ReasonCode反馈给客户端，这样客户端就能够知道自己无法连接的原因。 MQTT3.1.1中的ReasonCode 虽然MQTT3.1.1就已经支持了ReasonCode，但它并没有定义太多可用的ReasonCode。 在仅有的两个支持ReasonCode的报文中，CONNACK报文只有5个用于指示失败的ReasonCode，SUBACK报文则仅仅只有一个用于指示失败的ReasonCode，无法进一步指示订阅失败的原因。而对于发布、取...

在之前的文章中，我们探讨了认证和访问控制机制。接下来，我们将介绍传输层安全协议（TLS）在提升MQTT通信安全方面的重要作用。本文将着重介绍TLS以及它如何保证MQTT通信的完整性、机密性和真实性。 概念解释 在开始之前，让我们先来了解几个关键概念。 握手：TLS握手是客户端和服务器之间建立安全连接的一个过程。在这个过程中，客户端和服务器互相交换信息，以确定安全连接的参数，比如加密算法、会话密钥和认证方法。 密码套件：密码套件是一种安全方案，结合了加密、散列和密钥交换算法，用来保障连接的安全。TLS支持多种密码套件，客户端和服务器可以在握手过程中协商选择密码套件。 证书：证书是用来证明服务器...

EMQXEnterprise5.2.0版本现已正式发布！ 新版本带来了一系列重磅更新，最令人瞩目的是可拖拽的可视化Flow设计器，它可以帮助企业快速创建、测试和部署数据集成。同时，我们新增了对AmazonKinesis和AzureEventHubs的支持，实现了海量物联网设备数据与云服务的无缝连接。此外，新版本还进行了多项改进以及BUG修复，进一步提升了整体性能和稳定性。 Flow设计器，拖拽和可视化界面快速创建、测试和部署数据集成 Flow设计器是一个可视化界面，它在早些发布的数据集成可视化查看工具Flows基础上，增加了创建和编辑的能力。 它允许用户使用更简单的方式，通过拖拽的方式自由编排...

摘要 物联网设备连接和部署规模的不断扩大，对物联网消息平台的可扩展性和健壮性提出了更高的要求。为了确认云原生分布式​​MQTT消息服务器EMQX​​的性能表现可以充分满足当今物联网连接规模的需求，我们在23个节点的EMQX集群上建立了1亿个MQTT连接，对EMQX的可扩展性进行了压力测试。 在本测试中，每个MQTT客户端订阅了一个唯一的通配符主题，这比直接主题需要更多的CPU资源。消息发布时，我们选择了一对一的发布者-订阅者拓扑模型，每秒处理消息可达100万条。此外，我们还比较了在使用两个不同的数据库后端——RLOGDB和Mnesia时，最大订阅率如何随着集群大小的增加而变化。本文将详细介绍测...