- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.gopush.common.constants.ZkGroupEnum
类的一些代码示例,展示了ZkGroupEnum
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkGroupEnum
类的具体详情如下:
包路径:com.gopush.common.constants.ZkGroupEnum
类名称:ZkGroupEnum
暂无
代码示例来源:origin: lee123lee123/GoPush
private void initDataCenterPool() {
monitorDataCenterPool.clear();
Map<String, String> datas = zkUtils.readTargetChildsData(ZkGroupEnum.DATA_CENTER.getValue());
if (datas != null) {
datas.forEach((k, v) -> monitorDataCenterPool.put(k, JSON.parseObject(v, DataCenterInfo.class)));
}
}
代码示例来源:origin: lee123lee123/GoPush
private void initNodeServerPool() {
monitorNodeServerPool.clear();
Map<String, String> datas = zkUtils.readTargetChildsData(ZkGroupEnum.NODE_SERVER.getValue());
if (datas != null) {
datas.forEach((k, v) -> monitorNodeServerPool.put(k, JSON.parseObject(v, NodeServerInfo.class)));
}
}
代码示例来源:origin: lee123lee123/GoPush
/**
* 注册node-server服务
*/
private void registerNodeServer() {
if (!zkUtils.checkExists(ZkGroupEnum.NODE_SERVER.getValue())) {
boolean flag;
do {
flag = zkUtils.createNode(ZkGroupEnum.NODE_SERVER.getValue(), null, CreateMode.PERSISTENT);
} while (!flag);
}
registerNodeInfo();
}
代码示例来源:origin: lee123lee123/GoPush
/**
* 注册datacenter服务
*/
private void registerDataCenter() {
if (!zkUtils.checkExists(ZkGroupEnum.DATA_CENTER.getValue())) {
boolean flag;
do {
flag = zkUtils.createNode(ZkGroupEnum.DATA_CENTER.getValue(), null, CreateMode.PERSISTENT);
} while (!flag);
}
registerDataCenterInfo();
}
代码示例来源:origin: lee123lee123/GoPush
public void postNewData(DataCenterInfo data) {
zkUtils.setNodeData(
ZKPaths.makePath(ZkGroupEnum.DATA_CENTER.getValue(), goPushDataCenterConfig.getName()),
JSON.toJSONString(data));
}
代码示例来源:origin: lee123lee123/GoPush
/**
* 提交最新的数据
*
* @param data
*/
public void postNewData(NodeServerInfo data) {
zkUtils.setNodeData(
ZKPaths.makePath(ZkGroupEnum.NODE_SERVER.getValue(), goPushNodeServerConfig.getName()),
JSON.toJSONString(data));
}
代码示例来源:origin: lee123lee123/GoPush
/**
* 初始化node-server列表
*/
private void initNodeServerDiscovery() {
nodeServerPool.clear();
Map<String, String> datas = zkUtils.readTargetChildsData(ZkGroupEnum.NODE_SERVER.getValue());
if (datas != null) {
datas.forEach((k, v) -> nodeServerPool.put(k, JSON.parseObject(v, NodeServerInfo.class)));
}
nodeServerPool().forEach((k, v) -> nodeManager.put(k, v.getIntranetIp(), v.getNodePort(), v.getInternetIp(), v.getDevicePort()));
}
代码示例来源:origin: lee123lee123/GoPush
private void registerNodeInfo() {
zkUtils.createNode(
ZKPaths.makePath(ZkGroupEnum.NODE_SERVER.getValue(), goPushNodeServerConfig.getName()),
JSON.toJSONString(watchdog.watch()),
CreateMode.EPHEMERAL);
}
代码示例来源:origin: lee123lee123/GoPush
private void registerDataCenterInfo() {
zkUtils.createNode(
ZKPaths.makePath(ZkGroupEnum.DATA_CENTER.getValue(), goPushDataCenterConfig.getName()),
JSON.toJSONString(watchdog.watch()),
CreateMode.EPHEMERAL);
}
代码示例来源:origin: lee123lee123/GoPush
private void listenNodeServer() {
zkUtils.listenerPathChildrenCache(ZkGroupEnum.NODE_SERVER.getValue(), ((zkclient, event) -> {
switch (event.getType()) {
case CHILD_ADDED:
addEvent(event);
break;
case CHILD_REMOVED:
removeEvent(event);
break;
case CHILD_UPDATED:
updateEvent(event);
break;
default:
break;
}
}));
}
代码示例来源:origin: lee123lee123/GoPush
/**
* 设置监听发生更新,更新缓存数据,发生新增,删除,更新
*/
private void listenDataCenter() {
zkUtils.listenerPathChildrenCache(ZkGroupEnum.DATA_CENTER.getValue(), ((client, event) -> {
switch (event.getType()) {
case CHILD_ADDED:
addEvent(event);
break;
case CHILD_REMOVED:
removeEvent(event);
break;
case CHILD_UPDATED:
updateEvent(event);
break;
default:
break;
}
}));
}
代码示例来源:origin: lee123lee123/GoPush
/**
* 设置监听发生更新,更新缓存数据,发生新增,删除,更新
*/
private void listenNodeServerDiscovery() {
zkUtils.listenerPathChildrenCache(ZkGroupEnum.NODE_SERVER.getValue(), ((client, event) -> {
switch (event.getType()) {
case CHILD_ADDED:
addEvent(event);
break;
case CHILD_REMOVED:
removeEvent(event);
break;
case CHILD_UPDATED:
updateEvent(event);
break;
default:
break;
}
}));
}
本文整理了Java中com.gopush.common.constants.ZkGroupEnum类的一些代码示例,展示了ZkGroupEnum类的具体用法。这些代码示例主要来源于Github/Sta
本文整理了Java中com.gopush.common.utils.zk.ZkUtils类的一些代码示例,展示了ZkUtils类的具体用法。这些代码示例主要来源于Github/Stackoverflo
本文整理了Java中com.gopush.common.constants.ZkGroupEnum.getValue()方法的一些代码示例,展示了ZkGroupEnum.getValue()的具体用法
本文整理了Java中com.gopush.common.utils.zk.ZkUtils.init()方法的一些代码示例,展示了ZkUtils.init()的具体用法。这些代码示例主要来源于Githu
本文整理了Java中com.gopush.common.utils.zk.ZkUtils.setNodeData()方法的一些代码示例,展示了ZkUtils.setNodeData()的具体用法。这些
本文整理了Java中com.gopush.common.utils.zk.ZkUtils.checkExists()方法的一些代码示例,展示了ZkUtils.checkExists()的具体用法。这些
本文整理了Java中com.gopush.common.utils.zk.ZkUtils.listenerPathChildrenCache()方法的一些代码示例,展示了ZkUtils.listene
本文整理了Java中com.gopush.common.utils.zk.ZkUtils.readTargetChildsData()方法的一些代码示例,展示了ZkUtils.readTargetCh
本文整理了Java中com.gopush.common.utils.zk.ZkUtils.()方法的一些代码示例,展示了ZkUtils.()的具体用法。这些代码示例主要来源于Github/Stacko
本文整理了Java中com.gopush.common.utils.zk.ZkUtils.destory()方法的一些代码示例,展示了ZkUtils.destory()的具体用法。这些代码示例主要来源
我是一名优秀的程序员,十分优秀!