From 396b5f9bb25812b82e74538d15ae7c24510c4ed2 Mon Sep 17 00:00:00 2001
From: ck-chenkang <bettermanchenkang@163.com>
Date: Wed, 1 Jul 2026 14:41:39 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9Amqtt=E5=A2=9E=E5=8A=A0=E5=90=AF?=
 =?UTF-8?q?=E5=8A=A8=E9=A1=BA=E5=BA=8F=E9=99=90=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../module/iot/framework/mqtt/config/DefaultMqttStarter.java    | 2 ++
 .../iot/framework/mqtt/consumer/impl/MqttserviceImpl.java       | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/mqtt/config/DefaultMqttStarter.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/mqtt/config/DefaultMqttStarter.java
index 3e5c980bc..360e3c106 100644
--- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/mqtt/config/DefaultMqttStarter.java
+++ b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/mqtt/config/DefaultMqttStarter.java
@@ -8,6 +8,7 @@ import org.eclipse.paho.client.mqttv3.MqttException;
 import org.springframework.boot.context.event.ApplicationReadyEvent;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.ApplicationListener;
+import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
@@ -26,6 +27,7 @@ public class DefaultMqttStarter implements ApplicationListener<ApplicationReadyE
 
     @SneakyThrows
     @Override
+    @Order(1) //client先启动后，再订阅
     public void onApplicationEvent(ApplicationReadyEvent applicationReadyEvent) {
         // catch异常，不然连不上emqx项目就跑不起来
         try {
diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/mqtt/consumer/impl/MqttserviceImpl.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/mqtt/consumer/impl/MqttserviceImpl.java
index b172159e0..70e99c9b5 100644
--- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/mqtt/consumer/impl/MqttserviceImpl.java
+++ b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/framework/mqtt/consumer/impl/MqttserviceImpl.java
@@ -18,6 +18,7 @@ import org.springframework.boot.context.event.ApplicationReadyEvent;
 import org.springframework.context.ApplicationListener;
 import org.springframework.context.annotation.DependsOn;
 import org.springframework.context.annotation.Lazy;
+import org.springframework.core.annotation.Order;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.stereotype.Service;
 
@@ -46,6 +47,7 @@ public class MqttserviceImpl implements IMqttservice, ApplicationListener<Applic
 
 
     @Override
+    @Order(2)
     public void onApplicationEvent(ApplicationReadyEvent applicationReadyEvent) {
         new Thread(() -> {
             subscribeMysqlTopic();