test/earth-frost
1
0
Fork 0
mirror of https://gitee.com/justlive1/earth-frost.git synced 2024-12-02 03:59:20 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

增加shutdown

Browse Source
This commit is contained in:
justlive1 2018-06-19 17:00:53 +08:00
parent e7cc6674dc
commit 714117e925
3 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
frost-executor/src/main/resources/application.properties
View File

@ -14,3 +14,5 @@ server.servlet.contextPath=/executor
logging.level.root=info
logging.file=${spring.application.name}.log
management.endpoint.shutdown.enabled=true

5
frost-support-redis/pom.xml
View File

@ -28,6 +28,11 @@
<artifactId>redisson</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>

9
frost-support-redis/src/main/java/vip/justlive/frost/executor/redis/registry/RedisRegistry.java
View File

@ -9,6 +9,7 @@ import org.redisson.api.RMapCache;
import org.redisson.api.RTopic;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.actuate.context.ShutdownEndpoint;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Component;
import lombok.extern.slf4j.Slf4j;
@ -43,6 +44,9 @@ public class RedisRegistry extends AbstractRegistry {
new ScheduledThreadPoolExecutor(1, new BasicThreadFactory.Builder()
.namingPattern("heartbeat-schedule-pool-%d").daemon(true).build());
@Autowired
ShutdownEndpoint shutdown;
@Override
public void register() {
@ -62,8 +66,7 @@ public class RedisRegistry extends AbstractRegistry {
if (jobProps.getExecutor().getScriptJobEnabled()) {
redissonClient.getExecutorService(JobProperties.JOB_SCRIPT_PREFIX)
.registerWorkers(executorProperties.getParallel());
redissonClient
.getExecutorService(String.join(JobProperties.SEPERATOR,
redissonClient.getExecutorService(String.join(JobProperties.SEPERATOR,
JobProperties.JOB_SCRIPT_PREFIX, jobExecutorBean.getKey()))
.registerWorkers(executorProperties.getParallel());
}
@ -89,6 +92,7 @@ public class RedisRegistry extends AbstractRegistry {
// 注册事件
topic.publish(new HeartBeat(jobExecutorBean.getAddress(), HeartBeat.TYPE.REGISTER.name(),
jobExecutorBean.getName()));
}
@Override
@ -96,6 +100,7 @@ public class RedisRegistry extends AbstractRegistry {
beatFuture.cancel(true);
topic.publish(new HeartBeat(jobExecutorBean.getAddress(), HeartBeat.TYPE.UNREGISTER.name(),
jobExecutorBean.getName()));
shutdown.shutdown();
}
}