From ecaaf0cdc2efee584ee821fee3cfcbeeafa869ef Mon Sep 17 00:00:00 2001
From: pengjie <17373303529@163.com>
Date: Thu, 7 Aug 2025 11:33:01 +0800
Subject: [PATCH] =?UTF-8?q?=E9=85=8D=E7=BD=AE=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/zhgd/mqtt/server/MqttConfig.java    | 3 ++-
 src/main/java/com/zhgd/xmgl/util/MqttFaceDevUtil.java | 6 +++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zhgd/mqtt/server/MqttConfig.java b/src/main/java/com/zhgd/mqtt/server/MqttConfig.java
index a29759ec7..bc9c5fed5 100644
--- a/src/main/java/com/zhgd/mqtt/server/MqttConfig.java
+++ b/src/main/java/com/zhgd/mqtt/server/MqttConfig.java
@@ -98,6 +98,7 @@ public class MqttConfig {
         options.setConnectionTimeout(20);
         // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送心跳判断客户端是否在线，但这个方法并没有重连的机制
         options.setKeepAliveInterval(20);
+        options.setMaxInflight(100);
         // 设置“遗嘱”消息的话题，若客户端与服务器之间的连接意外中断，服务器将发布客户端的“遗嘱”消息。
         //options.setWill("willTopic", WILL_DATA, 2, false);
         return options;
@@ -156,7 +157,7 @@ public class MqttConfig {
                         StringUtils.split(consumerDefaultTopic, Cts.COMMA));
         adapter.setCompletionTimeout(5000);
         adapter.setConverter(new DefaultPahoMessageConverter());
-        adapter.setQos(1);
+        adapter.setQos(0);
         // 设置订阅通道
         adapter.setOutputChannel(mqttInboundChannel());
         return adapter;
diff --git a/src/main/java/com/zhgd/xmgl/util/MqttFaceDevUtil.java b/src/main/java/com/zhgd/xmgl/util/MqttFaceDevUtil.java
index de19fa197..2c43959a6 100644
--- a/src/main/java/com/zhgd/xmgl/util/MqttFaceDevUtil.java
+++ b/src/main/java/com/zhgd/xmgl/util/MqttFaceDevUtil.java
@@ -42,7 +42,7 @@ public class MqttFaceDevUtil {
                 String topic = mqttTopic + ds;
                 log.info("发送主题信息：{}，主题为：{}", payload, topic);
                 IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class);
-                mqttSender.sendToMqtt(topic, 2, payload);
+                mqttSender.sendToMqtt(topic, 0, payload);
             }
         } else {
             log.info("未查询到设备sn");
@@ -65,7 +65,7 @@ public class MqttFaceDevUtil {
                 String topic = mqttTopic + ds;
                 log.info("发送主题信息：{}，主题为：{}", payload, topic);
                 IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class);
-                mqttSender.sendToMqtt(topic, 2, payload);
+                mqttSender.sendToMqtt(topic, 0, payload);
             }
         } else {
             log.info("未查询到设备sn");
@@ -92,7 +92,7 @@ public class MqttFaceDevUtil {
                 String topic = mqttTopic + ds;
                 log.info("发送主题信息：{}，主题为：{}", payload, topic);
                 IMqttSender mqttSender = SpringContextUtils.getBean(IMqttSender.class);
-                mqttSender.sendToMqtt(topic, 2, payload);
+                mqttSender.sendToMqtt(topic, 0, payload);
             }
         } else {
             log.error("未查询到设备sn");