From b35c9e203826ad223a4edb17e30a62772765f331 Mon Sep 17 00:00:00 2001 From: zhangyue <82248909@qq.com> Date: Mon, 17 Aug 2026 11:53:52 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0mqt=E7=9A=84=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E5=8F=91=E9=80=81=E5=BB=B6=E8=BF=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/appmana/service/impl/IotCommonP3ServiceImpl.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java index 0ff88f4..9fd9ffd 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java @@ -749,6 +749,8 @@ public class IotCommonP3ServiceImpl { QueryCmd queryCmd = LhIotUtil.ConstructCmd(batch); String cmdStr = JSONObject.toJSONString(queryCmd); mqttService.sendMessage(deploy.getDeviceIotUrl(), cmdStr); + //增加延迟,发送太快会导致客户端忽略 + Thread.sleep(2000); log.error("===========当前批次指令========={}============", batch); }