feat：本地启动不订阅mq

server-web/src/main/java/com/makeit/mqtt/MqttConfig.java

@@ -24,6 +24,7 @@ public class MqttConfig {
     private String defaultTopic;
     private String defaultTopic;
     private int timeout;
     private int timeout;
     private int keepalive;
     private int keepalive;
+    private Boolean msgSwitch;
 
 
     public MqttConfig() {
     public MqttConfig() {
         super();
         super();
@@ -44,6 +45,9 @@ public class MqttConfig {
 
 
     @Bean
     @Bean
     public MqttPushClient getMqttPushClient() {
     public MqttPushClient getMqttPushClient() {
+        if (!msgSwitch) {
+            return null;
+        }
         clientId = StringUtils.isNotEmpty(clientId) ? clientId : iotTokenService.getIotToken();
         clientId = StringUtils.isNotEmpty(clientId) ? clientId : iotTokenService.getIotToken();
         mqttPushClient.connect(hostUrl, clientId, username, password, timeout, keepalive);
         mqttPushClient.connect(hostUrl, clientId, username, password, timeout, keepalive);
         // 订阅主题
         // 订阅主题
@@ -51,6 +55,14 @@ public class MqttConfig {
         return mqttPushClient;
         return mqttPushClient;
     }
     }
 
 
+    public Boolean getMsgSwitch() {
+        return msgSwitch;
+    }
+
+    public void setMsgSwitch(Boolean msgSwitch) {
+        this.msgSwitch = msgSwitch;
+    }
+
     public String getUsername() {
     public String getUsername() {
         return username;
         return username;
     }
     }

server-web/src/main/resources/application-dev.yml

@@ -119,6 +119,7 @@ mqtt:
   defaultTopic: /device/*/*/**
   defaultTopic: /device/*/*/**
   timeout: 10
   timeout: 10
   keepalive: 60
   keepalive: 60
+  msgSwitch: false
 
 
 wx:
 wx:
   miniapp:
   miniapp:

server-web/src/main/resources/application-test.yml

@@ -116,6 +116,7 @@ mqtt:
   defaultTopic: /device/*/*/**
   defaultTopic: /device/*/*/**
   timeout: 10
   timeout: 10
   keepalive: 60
   keepalive: 60
+    msgSwitch: true
 
 
 wx:
 wx:
   miniapp:
   miniapp: