提交 c9e512b6 编写于 作者: 浅梦2013's avatar 浅梦2013

📝 添加集群处理步骤。

上级 ae72a4dc
......@@ -47,7 +47,7 @@
**配置详见**[mica-mqtt 使用文档](docs/docs.md)
## 文档
- [mica-mqtt-spring-boot-starter 使用文档](docs/starter.md)
- [mica-mqtt-spring-boot-starter 使用文档](mica-mqtt-spring-boot-starter/README.md)
- [mica-mqtt 使用文档](docs/docs.md)
- [mica-mqtt 发行版本](CHANGELOG.md)
- [t-io 官方文档](https://www.tiocloud.com/doc/tio/85)
......
......@@ -107,4 +107,12 @@ mqttServer.publishAll("/test/123", ByteBuffer.wrap("mica最牛皮".getBytes()),
// 停止服务
mqttServer.stop();
```
\ No newline at end of file
```
## 基于 mq 消息广播集群处理
- 实现 `IMqttConnectStatusListener` 处理设备状态存储。
- 实现 `IMqttMessageListener` 将消息转发到 mq,业务按需处理 mq 消息。
- 实现 `IMqttMessageStore` 存储遗嘱和保留消息。
- 实现 `AbstractMqttMessageDispatcher` 将消息发往 mq,mq 再广播回 mqtt 集群,mqtt 将消息发送到设备。
- 业务消息发送到 mq,mq 广播到 mqtt 集群,mqtt 将消息发送到设备。
......@@ -112,7 +112,15 @@ public class ServerService {
}
```
### 2.7 Prometheus + Grafana 监控对接
### 2.7 基于 mq 消息广播集群处理
- 实现 `IMqttConnectStatusListener` 处理设备状态存储。
- 实现 `IMqttMessageListener` 将消息转发到 mq,业务按需处理 mq 消息。
- 实现 `IMqttMessageStore` 存储遗嘱和保留消息。
- 实现 `AbstractMqttMessageDispatcher` 将消息发往 mq,mq 再广播回 mqtt 集群,mqtt 将消息发送到设备。
- 业务消息发送到 mq,mq 广播到 mqtt 集群,mqtt 将消息发送到设备。
### 2.8 Prometheus + Grafana 监控对接
```xml
<!-- 开启 prometheus 指标收集 -->
<dependency>
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册