提交 ea95dc4d 编写于 作者: O o2null

如果center没有启动,update,如果启动refresh


(cherry picked from commit 1218fb29947ef0c5086ce015c81ffcf1b749e86b)
上级 ecf7edd0
{
"unitLevelOrderNumberDigits": 10.0,
"pickPersonWithName": true,
"pickIdentityWithName": false,
"pickIdentityWithName": true,
"###unitLevelOrderNumberDigits": "unit中unitLevelOrderNumber扩充位数,\u003c\u003d0不扩充.###",
"###pickPersonWithName": "zhangsan@123@P人员识别过程中过程为先查找 distinguishedName 再查找中间的 unique 如果还是没有查找到是否要通过名称进行查找.###",
"###pickIdentityWithName": "zhangsan@456@I身份识别过程中过程为先查找 distinguishedName 再查找中间的 unique 如果还是没有查找到是否要通过名称进行查找.###"
......
......@@ -29,10 +29,15 @@ public class RegistApplicationsAndVoteCenterTask implements Job {
// 先选举center
Config.resource_node_eventQueue().put(XGsonBuilder.instance().toJsonTree(new VoteCenterEvent()));
}
// 从主center更新本地数据
Config.resource_node_eventQueue().put(XGsonBuilder.instance().toJsonTree(new UpdateApplicationsEvent()));
// 刷新本地application
Config.resource_node_eventQueue().put(XGsonBuilder.instance().toJsonTree(new RefreshApplicationsEvent()));
if (BooleanUtils.isTrue(Servers.centerServerIsStarted())) {
// 刷新本地application
Config.resource_node_eventQueue()
.put(XGsonBuilder.instance().toJsonTree(new RefreshApplicationsEvent()));
} else {
// 从主center更新本地数据
Config.resource_node_eventQueue()
.put(XGsonBuilder.instance().toJsonTree(new UpdateApplicationsEvent()));
}
} catch (Exception e) {
logger.error(e);
Thread.currentThread().interrupt();
......
......@@ -29,6 +29,7 @@ import com.x.base.core.project.gson.XGsonBuilder;
import com.x.base.core.project.jaxrs.WrapString;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
import com.x.base.core.project.tools.ListTools;
import com.x.server.console.server.Servers;
public class RegistApplicationsEvent implements Event {
......@@ -49,6 +50,9 @@ public class RegistApplicationsEvent implements Event {
if (BooleanUtils.isTrue(Servers.applicationServerIsStarted())
&& (null != Config.resource_node_applications())) {
List<Application> list = listApplication(applicationServer);
if (ListTools.isEmpty(list)) {
logger.warn("applications on node:{} is empty.", Config.node());
}
if (BooleanUtils.isTrue(Config.currentNode().getSelfHealthCheckEnable()) && (!this.healthCheck(list))) {
logger.warn("health check result is false.");
list.clear();
......
package com.x.program.center.schedule;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
import com.x.program.center.CenterQueueRefreshBody;
import com.x.program.center.ThisApplication;
public class RefreshApplications extends BaseAction {
private static Logger logger = LoggerFactory.getLogger(RefreshApplications.class);
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
try {
CenterQueueRefreshBody body = new CenterQueueRefreshBody();
ThisApplication.centerQueue.send(body);
} catch (Exception e) {
logger.error(e);
throw new JobExecutionException(e);
}
}
}
\ No newline at end of file
//package com.x.program.center.schedule;
//
//import org.quartz.JobExecutionContext;
//import org.quartz.JobExecutionException;
//
//import com.x.base.core.project.logger.Logger;
//import com.x.base.core.project.logger.LoggerFactory;
//import com.x.program.center.CenterQueueRefreshBody;
//import com.x.program.center.ThisApplication;
//
//public class RefreshApplications extends BaseAction {
//
// private static Logger logger = LoggerFactory.getLogger(RefreshApplications.class);
//
// @Override
// public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
// try {
// CenterQueueRefreshBody body = new CenterQueueRefreshBody();
// ThisApplication.centerQueue.send(body);
// } catch (Exception e) {
// logger.error(e);
// throw new JobExecutionException(e);
// }
// }
//
//}
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册