增加定时采集间隔时间配置。

src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java

@@ -8,6 +8,7 @@ import java.util.concurrent.TimeUnit;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.core.env.Environment;
 
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
 import com.gzzn.omms.msgexchangeapi.redis.RedisKeyConstant;
@@ -28,8 +29,13 @@ public class SchdWaitRunner implements Runnable {
 	 private ICminmsgService cminmsgService;
 	 private IFlightInfoService flightInfoService;
 	 
+	 private Long intervalSeconds;
+	 
 	 public SchdWaitRunner()
 	 {
+		 Environment env = (Environment)SpringUtil.getBean("environment");
+		 intervalSeconds = Long.valueOf(env.getProperty("msgExchange.intervalSeconds"));
+		 
 		 flightInfoService =  (IFlightInfoService) SpringUtil.getBean("flightInfoService");
 		 redisService = (RedisService) SpringUtil.getBean("redisService");
 		 cminmsgService = (ICminmsgService) SpringUtil.getBean("cminmsgService");
@@ -37,9 +43,9 @@ public class SchdWaitRunner implements Runnable {
 	 
 	@Override
 	public void run() {
-		logger.info("获取日计划航班信息返回结果开始...");
+		logger.info("获取日计划航班信息返回结果开始...,采集间隔{}",intervalSeconds);
 		Boolean isRun = true;
-		Long intervalMs = 3000L;
+		Long intervalMs = 30L;
 		Long tryTimes = 0L;
 		
 		while (isRun) {
@@ -75,7 +81,7 @@ public class SchdWaitRunner implements Runnable {
 	    	
 	    	//启动消息采集线程
 	    	ScheduledExecutorService  scheduledExecutorService = Executors.newScheduledThreadPool(1);
-	    	scheduledExecutorService.scheduleAtFixedRate(new MsgExchangeRunner(), 0, 30 , TimeUnit.SECONDS);
+	    	scheduledExecutorService.scheduleAtFixedRate(new MsgExchangeRunner(), 0, intervalSeconds , TimeUnit.SECONDS);
 	    	
 	    	
 	    	isRun = false; //退出

src/main/resources/application-dev.yml

@@ -51,4 +51,6 @@ kafka:
     concurrency: 10
     group:
       id: test
+msgExchange:
+  intervalSeconds: 30