📝 梳理文档

lets-mica · Feb 20, 2024 · 97548a9 · 97548a9
1 parent fcb00a1
commit 97548a9
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/...ple/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/client/MqttClientGlobalTest.java b/...ple/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/client/MqttClientGlobalTest.java
@@ -33,6 +33,9 @@ public static void main(String[] args) {
 			.port(1883)
 			.username("admin")
 			.password("123456")
+			// 采用 globalSubscribe，保留 session 停机重启后，可以接受到离线消息，注意：clientId 要不能变化。
+			.clientId("globalTest")
+			.cleanSession(false)
 			// 全局订阅的 topic
 			.globalSubscribe("/test", "/test/123", "/debug/#")
 			// 全局监听，也会监听到服务端 http api 订阅的数据

diff --git a/mica-mqtt-client/README.md b/mica-mqtt-client/README.md
@@ -88,6 +88,9 @@ MqttClient.create()
     .port(1883)
     .username("admin")
     .password("123456")
+    // 采用 globalSubscribe，保留 session 停机重启后，可以接受到离线消息，注意：clientId 要不能变化。
+    .clientId("globalTest")
+    .cleanSession(false)
     // 全局订阅的 topic
     .globalSubscribe("/test", "/test/123", "/debug/#")
     // 全局监听，也会监听到服务端 http api 订阅的数据