添加前端页面

common-lib/src/main/java/com/mortals/xhx/common/model/MessageHeader.java

@@ -28,6 +28,7 @@ public class MessageHeader {
      * 消息类型
      */
     public static final String MESSAGETYPE = "messageType";
+    public static final String DEVICECODE = "deviceCode";
     /**
      * topic
      */

device-manager/src/main/java/com/mortals/xhx/busiz/web/DeviceApiController.java

@@ -448,6 +448,7 @@ public class DeviceApiController {
                 TopicPartitionInfo info = TopicPartitionInfo.builder().exchangeName(exchangeName).topic(Constant.UPLOAD_TOPIC + deviceEntity.getDeviceCode()).build();
                 TbQueueMsgHeaders header = new DefaultTbQueueMsgHeaders();
                 header.put(MessageHeader.MESSAGETYPE, Constant.MESSAGETYPE_HEARTBEAT);
+                header.put(MessageHeader.DEVICECODE, deviceEntity.getDeviceCode());
                 for (int i = 0; i < 10; i++) {
                     deviceService.sendDeviceMessage(deviceEntity, info, header, JSON.toJSONString(req), null);
                     // Thread.sleep(50);