| | |
| | | |
| | | @Slf4j(topic = "mqttCar") |
| | | @Component |
| | | public class AutoMqtt { |
| | | public class AutoMqtt { |
| | | |
| | | @Autowired |
| | | private ArdSyCarRtuService ardSyCarRtuService; |
| | | |
| | | // @PostConstruct |
| | | @PostConstruct |
| | | public void init() { |
| | | // ArdSyCarRtuService carRtuService = SpringUtils.getBean(ArdSyCarRtuService.class); |
| | | // //获取电磁锁地址 |
| | |
| | | EmqClient emqClient = new EmqClient(carId+"mqttSubscribe"+UUID.randomUUID()); |
| | | emqClient.connect(); |
| | | emqClient.subscribe(subscribe, QosEnum.QoS2); |
| | | log.info("订阅主题:"+subscribe); |
| | | log.debug("订阅主题:"+subscribe); |
| | | }catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | } |