rtu封

aijinhui

2023-11-09 e2cc46293d84e49cf896b2ffd3494101712ac29e

 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));
    }
}