修改topic为kf/+/wr/#

pom.xml

@@ -108,7 +108,7 @@
 		<dependency>
 			<groupId>net.dreamlu</groupId>
 			<artifactId>mica-mqtt-client-spring-boot-starter</artifactId>
-			<version>2.2.3</version>
+			<version>2.2.8</version>
 		</dependency>
 		<dependency>
 			<groupId>com.alibaba.fastjson2</groupId>

src/main/java/com/kingfore/listener/MqttClientConnectListener.java

@@ -23,6 +23,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.event.EventListener;
+import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
 
 /**
@@ -31,9 +32,9 @@ import org.springframework.stereotype.Service;
  * @author L.cm
  */
 @Service
+@Component
 public class MqttClientConnectListener {
     private static final Logger logger = LoggerFactory.getLogger(MqttClientConnectListener.class);
-
     @Autowired
     private MqttClientCreator mqttClientCreator;
 
@@ -47,8 +48,8 @@ public class MqttClientConnectListener {
         logger.info("MqttDisconnectEvent:{}", event);
         // 在断线时更新 clientId、username、password
         mqttClientCreator.clientId("newClient" + System.currentTimeMillis())
-                .username("liruoxiu_test")
-                .password("123456");
+                .username(mqttClientCreator.getUsername())
+                .password(mqttClientCreator.getPassword());
     }
 
 }

src/main/resources/application.yml

@@ -1,5 +1,5 @@
 server:
-  port: 15250
+  port: 15251
 spring:
   application:
     name: ali-iot-amqp-temp-warning
@@ -22,9 +22,9 @@ mqtt:
     enabled: true
     ip: 47.93.59.86
     port: 1883
-    name: Mica-Mqtt-Client-energy11
-    clientId: wrzs-mqtt-prod
-    user-name: liruoxiu_test
+    name: Mica-Mqtt-Client-wrzs
+    clientId: Mica-Mqtt-Client-wrzs-prod
+    user-name: kf_admin
     password: 123456
     timeout: 5
     reconnect: true
@@ -37,4 +37,4 @@ mqtt:
     clean-session: true
     ssl:
       enabled: false
-topic1: kf/bj/wr/#
+topic1: kf/+/wr/#