mq测试

aijinhui

2023-10-12 ed0fb1e88b2851234052b503c2390750044645dd

mq测试

 ard-work/src/main/java/com/ruoyi/statistical/controller/StatisticalController.java

@@ -78,7 +78,7 @@
            //移动终端
            return Results.succeed(statisticalService.apponekeyYear(esParam));
        }else if("1008".equals(type)){
            //移动终端
            //雷达停机
            return Results.succeed(statisticalService.pumpYear(esParam));
        }else if("1010".equals(type)){
            //电子围栏

 ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java

@@ -80,7 +80,7 @@
            }
            if (topic.equals("radarWellData"))
            {
                System.out.println(new String(message.getPayload(), StandardCharsets.UTF_8));
                System.err.println(new String(message.getPayload(), StandardCharsets.UTF_8));
                IStorageMinioEventService storageMinioEventService = SpringUtils.getBean(IStorageMinioEventService.class);
                storageMinioEventService.parseStorageMinioEvent(new String(message.getPayload(), StandardCharsets.UTF_8));
            }

 ruoyi-admin/src/main/resources/application-prod.yml

@@ -94,7 +94,7 @@
  clientId: server229
  username: admin
  password: xzx12345
  topic: minioEvent,apponekey,camera,external
  topic: minioEvent,apponekey,camera,external,radarWellData
  timeout: 100
  keepalive: 60
  enabled: true