【采集调度器-后端TCP API】采集调度器下发任务命令 API

collector-scheduling-management/src/main/java/com/docus/server/AppRunBootstrap.java

@@ -1,12 +1,11 @@
 package com.docus.server;
 
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.scheduling.annotation.EnableAsync;
 
-
+@EnableAsync
-@Slf4j
 @EnableFeignClients(basePackages = ("com.docus.core.excel.feign"))
 @SpringBootApplication(scanBasePackages = {"com.docus"})
 public class AppRunBootstrap {

collector-scheduling-management/src/main/java/com/docus/server/JobConfig.java

@@ -9,26 +9,19 @@ import com.docus.server.dto.scheduling.management.schterminator.CommMsgDTO;
 import io.netty.buffer.Unpooled;
 import io.netty.channel.Channel;
 import io.netty.util.CharsetUtil;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.scheduling.annotation.Async;
-import org.springframework.scheduling.annotation.EnableAsync;
-import org.springframework.scheduling.annotation.EnableScheduling;
-import org.springframework.scheduling.annotation.Scheduled;
 
 import javax.annotation.Resource;
 import java.util.Date;
 import java.util.Map;
 import java.util.Set;
 
-@Configuration
+//@Configuration
-@EnableScheduling
-@EnableAsync
 public class JobConfig {
     @Resource
     private ChannelRepository channelRepository;
 
-    @Async
+    //    @Async("recordMessage")
-    @Scheduled(cron = "0/1 * * * * ?")
+//    @Scheduled(cron = "0/1 * * * * ?")
     public void runTask() throws InterruptedException {
 
         Map<String, Channel> channelMap = channelRepository.getIpToChannelCacheMap();

collector-scheduling-management/src/main/java/com/docus/server/common/SchedulerTask.java

@@ -0,0 +1,25 @@
+package com.docus.server.common;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class SchedulerTask {
+
+    //定时任务
+    // 5 * * * * ? 在每分钟的5秒执行
+    @Scheduled(cron = "0/1 * * * * ?")
+    public void scheduleTask() {
+        try {
+            log.info("定时任务： 开始执行");
+            //todo:执行业务
+            log.info("定时任务： 执行完毕");
+        } catch (Exception e) {
+            log.error("定时任务执行出错", e);
+        }
+    }
+
+}
+