mq配置提交

slope-modules/slope-detection/src/main/resources/bootstrap-dev.yml

@@ -22,31 +22,33 @@ spring:
           - dataId: slope-common.yml
             group: slope-manage-service
             refresh: true
-## MQTT##
-#mqtt:
-#  send:
-#    #完成超时时间
-#    completionTimeout: 3000
-#    #通过mqtt发送消息验证所需用户名
-#    username: test
-#    #通过mqtt发送消息验证所需密码
-#    password: test
-#    #连接的mqtt地址
-#    url: tcp://10.10.10.225
-#    #客户端id
-#    clientId: mqttx_12411c5c1ec1
-#    #推送主题  后面跟着#是监控下面所有的话题
-#    topic: slope#
-#    #topic: my-test
-#    # 会话心跳时间
-#    keepAliveInterval: 20
-#    # 设置连接超时时间
-#    connectionTimeout: 3000
-#    timeout: 10
-#    keepalive: 20
-#  # 要消费的topic配置
-#  receive:
-#    topic: slopePush/slopePull/test/out,test,slope,sharjeck/ai/test/out
+#mqtt
+mqtt:
+  send:
+    #完成超时时间
+    completionTimeout: 3000
+    #通过mqtt发送消息验证所需用户名
+    username: admin
+    port: 1883
+    #通过mqtt发送消息验证所需密码
+    password: public..
+    #连接的mqtt地址
+    url: tcp://10.10.10.108
+    #客户端id
+    clientId: mqttx_45thc5c1ec
+    #推送主题  后面跟着#是监控下面所有的话题
+    topic: system/iot/device_data_slope/#
+    #topic: my-test
+    # 会话心跳时间
+    keepAliveInterval: 20
+    # 设置连接超时时间
+    connectionTimeout: 3000
+    timeout: 10
+    keepalive: 20
+  # 要消费的topic配置
+  receive:
+    topic: slopePush/slopePull/test/out,test,slope,sharjeck/ai/test/out,system/iot/original_data_slope,system/iot/device_data_slope
+  isConsume: true
 OkHttpClit:
   url: http://10.10.10.220:9501
 sms:

slope-modules/slope-detection/src/main/resources/bootstrap-lfdc.yml

@@ -52,7 +52,7 @@ mqtt:
     #连接的mqtt地址
     url: tcp://10.10.10.108
     #客户端id
-    clientId: mqttx_4546c5c1ec1
+    clientId: mqttx_45986c5c1ec1
     #推送主题  后面跟着#是监控下面所有的话题
     topic: system/iot/device_data_slope/#
     #topic: my-test