This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
The following commit(s) were added to refs/heads/new-official-website by this
push:
new 3133235ab7 improve docs of rocketmq-mqtt (#727)
3133235ab7 is described below
commit 3133235ab75ac362c9b9e3f6a5fd9d0d04565726
Author: Li Feiyang <[email protected]>
AuthorDate: Wed May 21 15:47:01 2025 +0800
improve docs of rocketmq-mqtt (#727)
Co-authored-by: lifeiyang <[email protected]>
---
README.md | 1 +
docs/08-mqtt/01RocketMQMQTTOverview.md | 17 +++++++++--------
.../current/08-mqtt/01RocketMQMQTTOverview.md | 9 +++++----
.../version-5.0/08-mqtt/01RocketMQMQTTOverview.md | 9 +++++----
4 files changed, 20 insertions(+), 16 deletions(-)
diff --git a/README.md b/README.md
index ad1977b2f2..836c8fbb8c 100644
--- a/README.md
+++ b/README.md
@@ -15,6 +15,7 @@ For those of you who have contributed documentation and wish
to see the results
### Local Development
```
+$ npm install
$ npm start
```
This command starts a local development server and opens up a browser window.
Most changes are reflected live without having to restart the server.
diff --git a/docs/08-mqtt/01RocketMQMQTTOverview.md
b/docs/08-mqtt/01RocketMQMQTTOverview.md
index 264657e529..67827f294b 100644
--- a/docs/08-mqtt/01RocketMQMQTTOverview.md
+++ b/docs/08-mqtt/01RocketMQMQTTOverview.md
@@ -1,18 +1,19 @@
# RocketMQ MQTT 概览
-传统的消息队列MQ主要应用于服务(端)之间的消息通信,比如电商领域的交易消息、支付消息、物流消息等等。然而在消息这个大类下,还有一个非常重要且常见的消息领域,即IoT类终端设备消息。近些年,我们看到随着智能家居、工业互联而兴起的面向IoT设备类的消息正在呈爆炸式增长,而且已经发展十余年的移动互联网的手机APP端消息仍然是数量级庞大。面向终端设备的消息数量级比传统服务端的消息要大很多量级并仍然在快速增长。
+传统消息队列MQ主要应用于服务端之间的消息通信,如电商领域的交易、支付、物流等消息。然而,随着物联网(IoT)及移动互联网的发展,来自IoT设备和手机APP端的消息呈爆炸式增长,规模远远超出了传统的服务端消息。这类终端设备消息需要更高效、更统一的消息系统来管理。
-如果可以有一个统一的消息系统(产品)来提供多场景计算(如stream、event)、多场景(IoT、APP)接入,其实是非常有价值的,因为消息也是一种重要数据,数据如果只存在一个系统内,可以最大地降低存储成本,同时可以有效地避免数据因在不同系统间同步带来的一致性难题和挑战。
+通过建立统一的消息系统,可实现多场景计算(如流式计算和事件驱动计算),并实现多场景(如IoT设备、手机APP和服务端)消息的统一接入与管理。数据统一存储于同一系统,能有效降低存储成本,避免跨系统数据同步带来的数据一致性问题。

-基于此,我们引入了RocketMQ-MQTT这个扩展项目来实现RocketMQ统一接入IoT设备和服务端的消息,提供一体化消息存储和互通能力。
+因此,我们引入了 RocketMQ-MQTT 扩展项目,以实现 RocketMQ 统一接入 IoT 设备与服务端消息,提供一体化消息存储与互通能力。
-## MQTT协议
-在IoT终端场景,目前业界广泛使用的是MQTT协议,是起源于物联网IoT场景,OASIS联盟定义的标准的开放式协议。因为IoT设备种类繁多,运行环境各异,一个标准的接入协议尤为关键。
+## MQTT协议简介
+在IoT终端场景,目前业界广泛使用的是MQTT协议。MQTT
起源于物联网IoT场景,是一种基于发布/订阅(Pub/Sub)模式的轻量级消息传输协议,专为低带宽和网络不稳定的物联网环境设计。它最初由IBM开发,现由OASIS联盟作为开放标准维护。MQTT
广泛应用于物联网、智能硬件、车联网、智慧城市、远程医疗、电力、石油与能源等多个领域。
-MQTT协议定义的是一个Pub/Sub的通信模型,这个与RocketMQ是类似的,不过其在订阅方式上比较灵活,可以支持多级Topic订阅(如
“/t/t1/t2”),甚至可以支持通配符订阅(如 “/t/t1/+”)。
+MQTT 的核心通信模型也是 Pub/Sub,与 RocketMQ 比较类似,但在订阅方式上更为灵活,支持多级 Topic 订阅(如
/t/t1/t2)和通配符订阅(如 /t/t1/+)。通过 MQTT,我们可以轻松实现消息的广播、组播及单播。
-## 模型介绍
+## RocketMQ MQTT 架构设计
+RocketMQ MQTT 架构的目标是实现消息存储与分发的统一管理,并在不侵入 RocketMQ Broker
核心逻辑的前提下实现多协议接入。为此,我们设计了两大核心模型:队列存储模型和推拉模型。
### 队列存储模型

@@ -23,7 +24,7 @@ MQTT协议定义的是一个Pub/Sub的通信模型,这个与RocketMQ是类似
### 推拉模型

-上图展示的是一个推拉模型,图中的P节点是一个协议网关或broker插件,终端设备通过MQTT协议连到这个网关节点。消息可以来自多种场景(MQ/AMQP/MQTT)发送过来,存到Topic队列后会有一个notify逻辑模块来实时感知这个新消息到达,然后会生成消息事件(就是消息的Topic名称),将该事件推送至网关节点,网关节点根据其连上的终端设备订阅情况进行内部匹配,找到哪些终端设备能匹配上,然后会触发pull请求去存储层读取消息再推送至终端设备。
+上图展示的是一个推拉模型,图中的P节点是一个协议网关或broker插件,终端设备通过MQTT协议连到这个网关节点。消息可以来自多种场景(MQ/AMQP/MQTT)发送过来,存到Topic队列后会有一个notify逻辑模块来实时感知这个新消息到达,然后会生成消息事件(就是消息的Topic名称),将该事件推送至网关节点,网关节点根据终端订阅的主题匹配消息事件,并触发
pull 请求至存储层,最终将消息推送至订阅终端。
## 架构概览

diff --git
a/i18n/en/docusaurus-plugin-content-docs/current/08-mqtt/01RocketMQMQTTOverview.md
b/i18n/en/docusaurus-plugin-content-docs/current/08-mqtt/01RocketMQMQTTOverview.md
index 61a9042268..9fc0f78dd8 100644
---
a/i18n/en/docusaurus-plugin-content-docs/current/08-mqtt/01RocketMQMQTTOverview.md
+++
b/i18n/en/docusaurus-plugin-content-docs/current/08-mqtt/01RocketMQMQTTOverview.md
@@ -7,12 +7,13 @@ If there is a unified message system (product) to provide
multi-scenario computi
Based on this, we introduced the RocketMQ-MQTT extension project to realize
RocketMQ's unified access to the messages of IoT devices and servers, and
provide integrated message storage and intercommunication capabilities.
-## MQTT Protocol
-In the IoT terminal scenario, the MQTT protocol is widely used in the industry
at present, which is a standard open protocol defined by the OASIS Alliance
that originated from the IoT scenario of the Internet of Things. Because there
are many types of IoT devices and different operating environments, a standard
access protocol is particularly critical.
+## MQTT Protocol Introduction
+In IoT terminal scenarios, the MQTT protocol is widely adopted across the
industry. MQTT originated in IoT contexts as a lightweight message transport
protocol based on the publish/subscribe (Pub/Sub) model, specifically designed
for low-bandwidth and unreliable network environments. It was originally
developed by IBM and is now maintained as an open standard by the OASIS
consortium. MQTT is extensively used in IoT, smart hardware, vehicle
networking, smart cities, telemedicine, power, o [...]
-The MQTT protocol defines a Pub/Sub communication model, which is similar to
RocketMQ, but it is more flexible in the way of subscription, and can support
multi-level Topic subscriptions (such as "/t/t1/t2"), and can even support
Wildcard subscription (such as "/t/t1/+").
+Its core communication model is also Pub/Sub—similar to RocketMQ.But it
provides greater flexibility in subscription patterns, supporting multi-level
topic subscriptions (e.g., `/t/t1/t2`) and wildcard subscriptions (e.g.,
`/t/t1/+`). With MQTT, you can easily implement message broadcasting,
multicasting, and unicasting.
-## Model introduction
+## RocketMQ MQTT Architecture Design
+The goal of the RocketMQ MQTT architecture is to achieve unified management of
message storage and distribution while enabling multi-protocol integration
without intruding into the core logic of the RocketMQ broker. To this end, we
have designed two fundamental models: the queue storage model and the push-pull
model.
### Queue Storage Model

diff --git
a/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-mqtt/01RocketMQMQTTOverview.md
b/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-mqtt/01RocketMQMQTTOverview.md
index 61a9042268..99262a7799 100644
---
a/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-mqtt/01RocketMQMQTTOverview.md
+++
b/i18n/en/docusaurus-plugin-content-docs/version-5.0/08-mqtt/01RocketMQMQTTOverview.md
@@ -7,12 +7,13 @@ If there is a unified message system (product) to provide
multi-scenario computi
Based on this, we introduced the RocketMQ-MQTT extension project to realize
RocketMQ's unified access to the messages of IoT devices and servers, and
provide integrated message storage and intercommunication capabilities.
-## MQTT Protocol
-In the IoT terminal scenario, the MQTT protocol is widely used in the industry
at present, which is a standard open protocol defined by the OASIS Alliance
that originated from the IoT scenario of the Internet of Things. Because there
are many types of IoT devices and different operating environments, a standard
access protocol is particularly critical.
+## MQTT Protocol Introduction
+In IoT terminal scenarios, the MQTT protocol is widely adopted across the
industry. MQTT originated in IoT contexts as a lightweight message transport
protocol based on the publish/subscribe (Pub/Sub) model, specifically designed
for low-bandwidth and unreliable network environments. It was originally
developed by IBM and is now maintained as an open standard by the OASIS
consortium. MQTT is extensively used in IoT, smart hardware, vehicle
networking, smart cities, telemedicine, power, o [...]
-The MQTT protocol defines a Pub/Sub communication model, which is similar to
RocketMQ, but it is more flexible in the way of subscription, and can support
multi-level Topic subscriptions (such as "/t/t1/t2"), and can even support
Wildcard subscription (such as "/t/t1/+").
+Its core communication model is also Pub/Sub—similar to RocketMQ. But it
provides greater flexibility in subscription patterns, supporting multi-level
topic subscriptions (e.g., `/t/t1/t2`) and wildcard subscriptions (e.g.,
`/t/t1/+`). With MQTT, you can easily implement message broadcasting,
multicasting, and unicasting.
-## Model introduction
+## RocketMQ MQTT Architecture Design
+The goal of the RocketMQ MQTT architecture is to achieve unified management of
message storage and distribution while enabling multi-protocol integration
without intruding into the core logic of the RocketMQ broker. To this end, we
have designed two fundamental models: the queue storage model and the push-pull
model.
### Queue Storage Model
