Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

1、优化MQTT初始连接

Browse Source
This commit is contained in:
weidong 2025-06-20 18:58:56 +08:00
parent 57de48e899
commit c7b1438d02
2 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/MQTTClient.java
View File

@ -41,6 +41,10 @@ public class MQTTClient {
client.connect(options); client.connect(options);
} }
public boolean isConnected(){
return client.isConnected();
}
public boolean publish(String topic, String message) { public boolean publish(String topic, String message) {
if(!client.isConnected()){ if(!client.isConnected()){
logger.info("mqtt disconnected"); logger.info("mqtt disconnected");

17
sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXJKForwarder.java
View File

@ -38,7 +38,12 @@ public class GXJKForwarder extends Forwarder {
void registerMe() throws MqttException { void registerMe() throws MqttException {
init(FORWARDER_NAME, "MQTT "+brokerUrl,7,FWD_DEVICE_NAME,10); init(FORWARDER_NAME, "MQTT "+brokerUrl,7,FWD_DEVICE_NAME,10);
mqttClient = new MQTTClient(brokerUrl, username, password,clientid); mqttClient = new MQTTClient(brokerUrl, username, password,clientid);
mqttClient.connect(); try{
mqttClient.connect();
}
catch (Exception e){
}
} }
/** /**
@ -47,7 +52,15 @@ public class GXJKForwarder extends Forwarder {
@Scheduled(cron = "0 0/10 * * * ?") // 每30分钟执行一次 @Scheduled(cron = "0 0/10 * * * ?") // 每30分钟执行一次
private void forwardGnss() { private void forwardGnss() {
logger.debug("gxjk forwardGnss"); logger.debug("gxjk forwardGnss");
forwardCurrentGnss(); if(mqttClient.isConnected()) forwardCurrentGnss();
else{
try{
mqttClient.connect();
}
catch (Exception e){
}
}
} }
@Override @Override