代码拉取完成,页面将自动刷新
同步操作将从 Ta404团队/开发框架培训 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
注册中心提供zookeeper,redis(还在完善中),数据库(还在完善中)三种实现方式, 将分布式信息,如节点信息,缓存信息进行统一管理,提供注册,获取,删除,监听变化的接口
ta404:
registry-center: #分布式注册中心配置
enable: true #是否启用注册中心
default: zookeeper #配置启用以下那种注册中心
zookeeper:
url: 192.168.17.18:2181 # 配置zk地址
redis:
url: 192.168.29.219:6379 # 配置redis地址
/**
* 初始化分布式服务
* @param url 分布式服务地址(如zk地址,redis地址,数据库地址)
*/
void initClusterClient(String url);
/**
* 注册节点
* @param clusterKey 目标地址
* @param clusterValue 要注册的节点
*/
void setClusterNode(String clusterKey, String clusterValue);
/**
* 注册信息(存储在节点上)
* @param clusterKey 目标节点
* @param clusterValue 存储在节点上的信息
*/
void setClusterInfo(String clusterKey, String clusterValue);
**
* 获取目标节点的信息
* @param clusterKey 目标节点
* @return 返回节点信息
*/
String getClusterInfo(String clusterKey);
/**
* 删除节点
* @param clusterKey 删除的目标节点
*/
void deleteClusterInfo(String clusterKey);
/**
* 获取节点列表
* @param clusterPath 目标地址
* @return
*/
List<String> getClusterNodeList(String clusterPath);
/**
* 节点监听回调
* @param target 目标节点
* @param listener 回调方法
* @return
*/
Object addTargetListener(String target, IClusterEventListener listener);
回调中重写三个方法:
//子节点更新时触发
@Override
public void targetUpdate(String clusterKey) {
setTCPInitialHosts(getInitialHosts());
}
//新增子节点时触发
@Override
public void targetAdd(String clusterKey) {
setTCPInitialHosts(getInitialHosts());
}
//删除子节点时触发
@Override
public void targetRemove(String clusterKey) {
setTCPInitialHosts(getInitialHosts());
}
/**
* 获取分布式计数器
* @param path 目标地址(在该目标地址下获取分布式计数器)
* @return
*/
long getClusterCounter(String path);
/**
* 销毁方法,关闭客户端与注册中心连接
*/
void destory();
<dependency>
<groupId>com.yinhai.ta404</groupId>
<version>5.0.1-RELEASE</version>
<artifactId>ta404-module-registry-zookeeper</artifactId>
</dependency>
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。