mass同步接口测试

@@ -4,7 +4,9 @@ import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+@EnableScheduling
 @SpringBootApplication(exclude = {
         DataSourceAutoConfiguration.class,
         DataSourceTransactionManagerAutoConfiguration.class

@@ -2,20 +2,32 @@ package com.mass.config;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.TaskScheduler;
 import org.springframework.scheduling.annotation.EnableScheduling;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+import org.springframework.scheduling.annotation.SchedulingConfigurer;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+import org.springframework.scheduling.config.ScheduledTaskRegistrar;
+
+import java.util.concurrent.ThreadPoolExecutor;
+
 
 @Configuration
-@EnableScheduling
-public class TaskExecutorConfig {
+public class TaskExecutorConfig implements SchedulingConfigurer {
     @Bean
-    public ThreadPoolTaskExecutor taskExecutor() {
-        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(10);
-        executor.setMaxPoolSize(50);
-        executor.setQueueCapacity(1000);
-        executor.setKeepAliveSeconds(60);
-        executor.setThreadNamePrefix("task-executor-");
+    public TaskScheduler taskScheduler() {
+        ThreadPoolTaskScheduler executor = new ThreadPoolTaskScheduler();
+        executor.setPoolSize(10);
+        executor.setThreadNamePrefix("task-thread");
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
+        executor.initialize();
         return executor;
     }
+
+
+    @Override
+    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
+        scheduledTaskRegistrar.setTaskScheduler(taskScheduler());
+    }
+
+
 }

@@ -3,7 +3,6 @@ package com.mass.controller;
 import com.mass.service.UserSyncService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.repository.query.Param;
-import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;

@@ -49,7 +49,7 @@ public class UserSyncService {
 
     @Scheduled(cron = "*/5 * * * * ?")
     public void snyc() {
-        log.info("====test");
+        log.info( Thread.currentThread().getName()+"====test");
     }
 
 

@@ -16,6 +16,7 @@ logging:
 
 mass:
   domain: http://53.1.230.5:8159
+  syscode: da3fb2fd714e4178a7ab93d88aadb430
   userListUrl: /UUDB/user/list
   userUpdateListUrl: /UUDB/user/updateList
   orgListUrl: /UUDB/org/list