liusuyi
2023-11-23 fc79fc2d93ee39183af133d80515649c5fbd7eae
ard-work/src/main/java/com/ruoyi/utils/qymqtt/AutoMqtt.java
@@ -8,6 +8,7 @@
import javax.annotation.PostConstruct;
import java.util.List;
import java.util.UUID;
@Slf4j
@Component
@@ -16,7 +17,7 @@
    @Autowired
    private ArdSyCarRtuService ardSyCarRtuService;
    @PostConstruct
//    @PostConstruct
    public void init() {
//        ArdSyCarRtuService carRtuService = SpringUtils.getBean(ArdSyCarRtuService.class);
//        //获取电磁锁地址
@@ -28,7 +29,7 @@
            String subscribe = rtu.getTopicSubscribe();
            try {
                MqttCustomerClient mqttCustomerClient = new MqttCustomerClient();
                mqttCustomerClient.connect(carId+"mqtt");
                mqttCustomerClient.connect(carId+"mqtt"+ UUID.randomUUID());
                mqttCustomerClient.subscribe(subscribe);
            }catch (Exception e) {
                e.printStackTrace();