执行器注册机器列表自然排序;

v1.8.2
xuxueli 7 years ago
parent d46522b0d4
commit 80a55655bc

@ -912,7 +912,6 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段
- 8、任务执行结果回调失败后重试待定防止回调死循环 - 8、任务执行结果回调失败后重试待定防止回调死循环
- 9、springboot 和 docker镜像并且推送docker镜像到中央仓库更进一步实现产品开箱即用 - 9、springboot 和 docker镜像并且推送docker镜像到中央仓库更进一步实现产品开箱即用
- 10、安全校验调度中心和执行器约定公共密匙只有密匙一致才允许相互通讯 - 10、安全校验调度中心和执行器约定公共密匙只有密匙一致才允许相互通讯
- 11、交互优化默认左侧菜单折叠新页面默认当前窗口打开
## 七、其他 ## 七、其他

@ -10,6 +10,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -64,8 +65,11 @@ public class JobRegistryMonitorHelper {
// fresh group address // fresh group address
for (XxlJobGroup group: groupList) { for (XxlJobGroup group: groupList) {
List<String> registryList = appAddressMap.get(group.getAppName()); List<String> registryList = appAddressMap.get(group.getAppName());
String addressListStr = StringUtils.join(registryList, ","); String addressListStr = null;
if (CollectionUtils.isNotEmpty(registryList)) {
Collections.sort(registryList);
addressListStr = StringUtils.join(registryList, ",");
}
group.setAddressList(addressListStr); group.setAddressList(addressListStr);
XxlJobDynamicScheduler.xxlJobGroupDao.update(group); XxlJobDynamicScheduler.xxlJobGroupDao.update(group);
} }

Loading…
Cancel
Save