| | |
|---|
| | | */ |
|---|
| | | public static final Map<String, MqttClient> MQTT_CLIENT_MAP = new ConcurrentHashMap<>(); |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 创建MQTT客户端 |
|---|
| | | */ |
|---|
| | | @PostConstruct |
|---|
| | | public void createMqttClient() { |
|---|
| | | System.out.println("createMqttClient"); |
|---|
| | | List<MqttClientVO> mqttClientList = mqttConfig.getClientList(); |
|---|
| | | |
|---|
| | | for (MqttClientVO mqttClient : mqttClientList) { |
|---|
| | | //创建客户端，客户端ID：demo，回调类跟客户端ID一致 |
|---|
| | | System.out.println(mqttClient.getClientId()); |
|---|
| | | mqttClientManager.createMqttClient(mqttClient.getClientId(), mqttClient.getSubscribeTopic(), mqttClient.getUserName(), mqttClient.getPassword()); |
|---|
| | | System.out.println(mqttClient.getClientId()+"创建完成"); |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
