解决循环依赖问题

src/main/java/com/hxjt/dataupload/mqtt/MqttCallback.java

@@ -6,6 +6,7 @@ import org.eclipse.paho.client.mqttv3.MqttMessage;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
 @Component
@@ -13,6 +14,7 @@ public class MqttCallback implements org.eclipse.paho.client.mqttv3.MqttCallback
     private static final Logger logger = LoggerFactory.getLogger(com.hxjt.dataupload.mqtt.MqttClient.class);
 
     @Autowired
+    @Lazy
     private MqttConfig mqttConfig;
 
     private static org.eclipse.paho.client.mqttv3.MqttClient client;

src/main/java/com/hxjt/dataupload/mqtt/MqttClient.java

@@ -11,9 +11,12 @@ import org.springframework.stereotype.Component;
 @Component
 public class MqttClient {
     private static final Logger logger = LoggerFactory.getLogger(com.hxjt.dataupload.mqtt.MqttClient.class);
-
-    @Autowired
+    
     private MqttCallback pushCallback;
+    @Autowired
+    public void setPushCallback(MqttCallback pushCallback) {
+        this.pushCallback = pushCallback;
+    }
 
     private static org.eclipse.paho.client.mqttv3.MqttClient client;
 

src/main/java/com/hxjt/dataupload/mqtt/MqttConfig.java

@@ -4,14 +4,17 @@ package com.hxjt.dataupload.mqtt;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.DependsOn;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 import org.springframework.util.StringUtils;
 
 @Component
 @ConfigurationProperties("spring.mqtt")
-
+@DependsOn("mqttCallback")
 public class MqttConfig {
     @Autowired
+    @Lazy
     private com.hxjt.dataupload.mqtt.MqttClient mqttClient;
 
     private String username;