diff --git a/src/main/java/com/loadcenter/controller/GatewayController.java b/src/main/java/com/loadcenter/controller/GatewayController.java index e858b51..0795f22 100644 --- a/src/main/java/com/loadcenter/controller/GatewayController.java +++ b/src/main/java/com/loadcenter/controller/GatewayController.java @@ -40,4 +40,17 @@ public class GatewayController { public void scheduleECS(){ gatewayLoadService.scheduleECS(); } + + /** + * 刷新负载规则 实现动态负载 + */ + @Scheduled(cron = "0/30 * * * * ?") + public void refresh(){ + gatewayLoadService.refresh(); + } + + @Scheduled(cron = "0/30 * * * * ?") + public void dynamicEcs()throws Exception{ + gatewayLoadService.dynamicEcs(); + } } diff --git a/src/main/java/com/loadcenter/service/GatewayLoadService.java b/src/main/java/com/loadcenter/service/GatewayLoadService.java index 6fd3409..8368c82 100644 --- a/src/main/java/com/loadcenter/service/GatewayLoadService.java +++ b/src/main/java/com/loadcenter/service/GatewayLoadService.java @@ -12,8 +12,18 @@ public interface GatewayLoadService { */ String loadNode(); - + /** + * 查询ECS车辆连接数 + */ void scheduleECS(); + /** + * 刷新负载规则 实现动态负载 + */ void refresh(); + + /** + * 动态ECS + */ + void dynamicEcs() throws Exception; } diff --git a/src/main/java/com/loadcenter/service/impl/GatewayLoadServiceImpl.java b/src/main/java/com/loadcenter/service/impl/GatewayLoadServiceImpl.java index 664e0ab..0848253 100644 --- a/src/main/java/com/loadcenter/service/impl/GatewayLoadServiceImpl.java +++ b/src/main/java/com/loadcenter/service/impl/GatewayLoadServiceImpl.java @@ -76,6 +76,9 @@ public class GatewayLoadServiceImpl implements GatewayLoadService { } + /** + * 查询ECS车辆连接数 + */ @Override public void scheduleECS() { //客户端初始化 @@ -190,6 +193,7 @@ public class GatewayLoadServiceImpl implements GatewayLoadService { /** * 动态ECS */ + @Override public void dynamicEcs() throws Exception { //上线最大数量 Long vehicleMaxOnlineNum = gatewayNodeScoreCache.getNodeMaxOnlineNum();