|
|
@@ -6,6 +6,7 @@ import cn.hutool.core.date.DateUtil;
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
import cn.hutool.system.SystemUtil;
|
|
|
import com.fdkankan.fusion.config.CacheUtil;
|
|
|
+import com.fdkankan.redis.util.RedisUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.boot.ApplicationArguments;
|
|
|
@@ -24,7 +25,8 @@ public class AppListener implements ApplicationRunner {
|
|
|
|
|
|
@Resource
|
|
|
private WebApplicationContext applicationContext;
|
|
|
-
|
|
|
+ @Autowired
|
|
|
+ private RedisUtil redisUtil;
|
|
|
@Override
|
|
|
public void run(ApplicationArguments args) {
|
|
|
if (CacheUtil.settingEntity.getPid()<= 0) {
|
|
|
@@ -42,7 +44,13 @@ public class AppListener implements ApplicationRunner {
|
|
|
shutdownApplication();
|
|
|
break;
|
|
|
}
|
|
|
- Thread.sleep(5000);
|
|
|
+ if (redisUtil.hasKey("QUIT_JOB_FUSION")) {
|
|
|
+ System.out.println("收到推出通知,准备退出 SpringBoot 服务...");
|
|
|
+ redisUtil.del("QUIT_JOB_FUSION");
|
|
|
+ shutdownApplication();
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ Thread.sleep(2000);
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|