@Override
@Transactional(value = "transactionManager", isolation = Isolation.READ_COMMITTED, readOnly = false)
public List<Server> onlineByDeploy(Integer appId, String appInsId, int pid, Date date) throws Exception {
//用appId和appInsId查找server列表, 不用pid,为了减少时间,避开注册中心的berkeley异步注册时间
List<Server> servers = serverDao.getServersByApp(appId, appInsId, null);
if (servers != null && !servers.isEmpty()) {
List<Integer> serverIds = new ArrayList<Integer>();
List<Integer> ifaceIds = new ArrayList<Integer>();
List<IfaceServer> ifaceServerList = new ArrayList<IfaceServer>();
for (Server server : servers) {
ifaceIds.add(server.getInterfaceId());
serverIds.add(server.getId());
ifaceServerList.add(getIfaceServer(server));
}
logger.info("deploy.online.serverIds: {}", serverIds);
serverDao.updateServerToOnline(serverIds);
interfaceDataVersionDao.update(ifaceIds, date);
logger.info("online ifaceAlias list:" + aliasVersionService.updateByServerList(ifaceServerList, date));
List<IfaceServer> relaAliasServerList = aliasVersionService.getRelaIfaceServerList(ifaceServerList);
logger.info("自动部署调用: 上线服务端成功, appId:{}, appInsId:{}, serverIds: {}", appId, appInsId, serverIds.toString());
mergeServers(servers, relaAliasServerList);
return servers;
}
return null;
}
JsfDeployManagerImpl.java 文件源码
java
阅读 23
收藏 0
点赞 0
评论 0
项目:jsf-core
作者:
评论列表
文章目录