ScheduledFuture cancel

apq-pc-client/src/main/java/com/priusis/client/service/core/MqttServiceImpl.java

@@ -126,6 +126,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
     private ExecutorService mqttReceiverExecutor;
     private ExecutorService callbackExecutor = Executors.newCachedThreadPool();
     private ScheduledExecutorService realDataMonitorScheduler;
+    private static ScheduledFuture<?> realDataMonitorSchedulerFuture;
 
     @Autowired
     private NioEventLoopGroup nioEventLoopGroup;
@@ -424,9 +425,12 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
                 realDataMonitor = true;
                 log.info("数据上报频率请求接受!!! params: {}", mqttRpcDataMessage.getParams());
 
-                realDataMonitorScheduler(mqttRpcDataMessage);
+                try {
+                    realDataMonitorScheduler(mqttRpcDataMessage);
+                } finally {
+                    realDataMonitor = false;
+                }
 
-                realDataMonitor = false;
             }
             if ("facility_scan".equals(mqttRpcDataMessage.getMethod())) {
                 log.info("收到平台扫描软件请求");
@@ -469,7 +473,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
             public void run() {
                 try {
                     if (i >= durationSeconds) {
-                        realDataMonitorScheduler.shutdown();
+                        realDataMonitorSchedulerFuture.cancel(false);
                     }
 
                     String cpuLoad = "cpuLoad";
@@ -529,7 +533,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
 
             }
         };
-        realDataMonitorScheduler.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS);
+        realDataMonitorSchedulerFuture = realDataMonitorScheduler.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS);
     }
 
     private void onGatewayAttributesGet(String message) {