添加测试mqtt消费者

device-api-service/src/main/java/com/xy/consumer/TestUpConsumer.java

@@ -0,0 +1,28 @@
+package com.xy.consumer;
+
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.xy.producer.MqttProducer;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * 测试消费者
+ */
+@Slf4j
+@Service
+@AllArgsConstructor
+public class TestUpConsumer implements MqttConsumer {
+
+    private MqttProducer mqttProducer;
+
+    @Override
+    public boolean message(String topic, String payload) {
+        log.info("测试数据：{}", payload);
+        JSONObject jsonObject = JSONUtil.parseObj(payload);
+        String deviceId = jsonObject.getStr("deviceId");
+        mqttProducer.sendToMqtt(payload, String.format("%s_test_down", deviceId));
+        return true;
+    }
+}

device-start/src/main/resources/bootstrap-uat.yml

@@ -4,6 +4,7 @@ spring:
       - {topic: "device-log", handler: com.xy.consumer.LogConsumer}
       - {topic: "device-disconnected", handler: com.xy.consumer.DisconnectedConsumer}
       - {topic: "device-connected", handler: com.xy.consumer.ConnectedConsumer}
+      - {topic: "test-up", handler: com.xy.consumer.TestUpConsumer}
 
 #微服务相关配置
 cloud:

device-start/src/main/resources/bootstrap.yml

@@ -18,3 +18,7 @@ cloud:
       name: device
   service:
     name: dev-device
+  feign:
+    head:
+      carr-heads:
+        - satoken