admin/wisdomisite-java
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

配置调整

Browse Source
This commit is contained in:
pengjie 2025-08-07 11:33:01 +08:00
parent b05f69ebca
commit ecaaf0cdc2
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/zhgd/mqtt/server/MqttConfig.java
View File

@ -98,6 +98,7 @@ public class MqttConfig {
options.setConnectionTimeout(20); options.setConnectionTimeout(20);
// 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送心跳判断客户端是否在线，但这个方法并没有重连的机制 // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送心跳判断客户端是否在线，但这个方法并没有重连的机制
options.setKeepAliveInterval(20); options.setKeepAliveInterval(20);
options.setMaxInflight(100);
// 设置“遗嘱”消息的话题，若客户端与服务器之间的连接意外中断，服务器将发布客户端的“遗嘱”消息。 // 设置“遗嘱”消息的话题，若客户端与服务器之间的连接意外中断，服务器将发布客户端的“遗嘱”消息。
//options.setWill("willTopic", WILL_DATA, 2, false); //options.setWill("willTopic", WILL_DATA, 2, false);
return options; return options;
@ -156,7 +157,7 @@ public class MqttConfig {
StringUtils.split(consumerDefaultTopic, Cts.COMMA)); StringUtils.split(consumerDefaultTopic, Cts.COMMA));
adapter.setCompletionTimeout(5000); adapter.setCompletionTimeout(5000);
adapter.setConverter(new DefaultPahoMessageConverter()); adapter.setConverter(new DefaultPahoMessageConverter());
adapter.setQos(1); adapter.setQos(0);
// 设置订阅通道 // 设置订阅通道
adapter.setOutputChannel(mqttInboundChannel()); adapter.setOutputChannel(mqttInboundChannel());
return adapter; return adapter;

6
src/main/java/com/zhgd/xmgl/util/MqttFaceDevUtil.java
View File

@ -42,7 +42,7 @@ public class MqttFaceDevUtil {
String topic = mqttTopic + ds; String topic = mqttTopic + ds;
log.info("发送主题信息：{}，主题为：{}", payload, topic); log.info("发送主题信息：{}，主题为：{}", payload, topic);
IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class); IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class);
mqttSender.sendToMqtt(topic, 2, payload); mqttSender.sendToMqtt(topic, 0, payload);
} }
} else { } else {
log.info("未查询到设备sn"); log.info("未查询到设备sn");
@ -65,7 +65,7 @@ public class MqttFaceDevUtil {
String topic = mqttTopic + ds; String topic = mqttTopic + ds;
log.info("发送主题信息：{}，主题为：{}", payload, topic); log.info("发送主题信息：{}，主题为：{}", payload, topic);
IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class); IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class);
mqttSender.sendToMqtt(topic, 2, payload); mqttSender.sendToMqtt(topic, 0, payload);
} }
} else { } else {
log.info("未查询到设备sn"); log.info("未查询到设备sn");
@ -92,7 +92,7 @@ public class MqttFaceDevUtil {
String topic = mqttTopic + ds; String topic = mqttTopic + ds;
log.info("发送主题信息：{}，主题为：{}", payload, topic); log.info("发送主题信息：{}，主题为：{}", payload, topic);
IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class); IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class);
mqttSender.sendToMqtt(topic, 2, payload); mqttSender.sendToMqtt(topic, 0, payload);
} }
} else { } else {
log.error("未查询到设备sn"); log.error("未查询到设备sn");