package com.sandu.ximon.admin.localMQTT.client;
|
|
|
import com.sandu.ximon.admin.localMQTT.config.MqttConfig;
|
import com.sandu.ximon.admin.localMQTT.model.MqttClientVO;
|
import lombok.extern.slf4j.Slf4j;
|
import org.eclipse.paho.client.mqttv3.MqttClient;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.PostConstruct;
|
import javax.annotation.Resource;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
/**
|
* @author van
|
* @version 1.0
|
* msg：MQTT客户端创建
|
* @date 2022/11/9 16:31
|
*/
|
@Component
|
@Slf4j
|
public class MqttClientCreate {
|
@Autowired
|
private MqttConfig mqttConfig;
|
|
@Resource
|
private MqttClientManager mqttClientManager;
|
|
/**
|
* 存储MQTT客户端
|
*/
|
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());
|
}
|
}
|
}
|
