Merge remote-tracking branch 'origin/master'

aijinhui

2023-11-09 b5ae703a499b97fd83dd9a7b67a10a7b8157df5f

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

@@ -24,9 +24,11 @@

    @Override
    public void run(String... args) throws Exception {
        String topic = ardSyCarRtuService.allCarTopic();
        String[] topic = ardSyCarRtuService.allCarTopic();
        MqttConsumer mqttConsumer = new MqttConsumer();
        mqttConsumer.subscribe(topic,2);
        log.info("mqtt订阅清淤车辆锁信息："+topic);
        for (int i = 0; i < topic.length; i++) {
            mqttConsumer.subscribe(topic[i],2);
        }
        log.info("mqtt订阅清淤车辆锁信息："+Arrays.toString(topic));
    }
}