添加项目启动默认实现接口

hazard-admin/src/main/java/com/ozs/web/controller/mqtt/MqttController.java

@@ -8,6 +8,8 @@ import com.ozs.service.utils.SubscribeClient;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.paho.client.mqttv3.MqttException;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
@@ -18,16 +20,8 @@ import org.springframework.web.bind.annotation.RestController;
 @RestController
 @RequestMapping("/service/mqtt")
 @Slf4j
-public class MqttController {
-
-    @ApiOperation(value = "设备心跳")
-    @GetMapping("/deviceHeartbeat")
-    @Log(title = "MQTT", businessType = BusinessType.SELECT)
-    public AjaxResult selectCameraAll() {
-        new SubscribeClient("heart", "heart").start();
-        return AjaxResult.success();
-    }
-
+public class MqttController implements ApplicationRunner {
+    
 
     @ApiOperation(value = "置信度修改")
     @GetMapping("/confidenceCoefficient")
@@ -37,4 +31,9 @@ public class MqttController {
         new SubscribeClient("config", "config").start();
         return AjaxResult.success();
     }
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        new SubscribeClient("heart", "heart").start();
+    }
 }