xzzn/sipaiis_datacollector
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mqtt初始化链接调试

Browse Source
This commit is contained in:
Timer
2026-02-24 00:13:36 +08:00
parent 4e39491e5c
commit e35f300cff
3 changed files with 24 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/sipai/service/mqtt/impl/MqttConfigServiceImpl.java
View File

@ -12,6 +12,7 @@ import com.sipai.entity.mqtt.MqttConfigTopic;
import com.sipai.service.mqtt.MqttConfigService;
import com.sipai.service.mqtt.MqttConfigTopicService;
import com.sipai.tools.CommUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.binary.Base64;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
@ -37,6 +38,7 @@ import java.util.List;
* @Date: 2021/03/24/16:45
* @Description:
*/
@Slf4j
@Service
public class MqttConfigServiceImpl implements MqttConfigService {
private final MqttProperties mqttProperties;
@ -152,6 +154,7 @@ public class MqttConfigServiceImpl implements MqttConfigService {
mqttClient1.setCallback(new PushCallback(mqttClient1, connOpts, topic, qos));
//订阅
mqttClient1.subscribe(topic, qos);
System.out.println("已连接成功");
} else {
System.out.println("重新连接");
//连接
@ -160,12 +163,15 @@ public class MqttConfigServiceImpl implements MqttConfigService {
mqttClient1.setCallback(new PushCallback(mqttClient1, connOpts, topic, qos));
//订阅
mqttClient1.subscribe(topic, qos);
System.out.println("重新连接成功");
}
} catch (MqttException me) {
log.error("MqttException:",me);
me.printStackTrace();
}
}
System.out.println(clientId);
return clientId;
}