ard-work/src/main/java/com/ruoyi/utils/qymqtt/AutoMqtt.java
@@ -33,7 +33,7 @@ // MqttCustomerClient mqttCustomerClient = new MqttCustomerClient(); // mqttCustomerClient.connect(carId+"mqtt"+ UUID.randomUUID()); // mqttCustomerClient.subscribe(subscribe); EmqClient emqClient = new EmqClient(carId+"mqttSubscribe"); EmqClient emqClient = new EmqClient(carId+"mqttSubscribe"+UUID.randomUUID()); emqClient.connect(); emqClient.subscribe(subscribe, QosEnum.QoS2); log.info("订阅主题:"+subscribe);