| | |
| | | |
| | | import javax.annotation.PostConstruct; |
| | | import java.util.List; |
| | | import java.util.UUID; |
| | | |
| | | @Slf4j |
| | | @Component |
| | |
| | | @Autowired |
| | | private ArdSyCarRtuService ardSyCarRtuService; |
| | | |
| | | @PostConstruct |
| | | // @PostConstruct |
| | | public void init() { |
| | | // ArdSyCarRtuService carRtuService = SpringUtils.getBean(ArdSyCarRtuService.class); |
| | | // //获取电磁锁地址 |
| | |
| | | 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(); |