作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中eagle.jfaster.org.ZookeeperRegistryCenter.<init>()
方法的一些代码示例,展示了ZookeeperRegistryCenter.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperRegistryCenter.<init>()
方法的具体详情如下:
包路径:eagle.jfaster.org.ZookeeperRegistryCenter
类名称:ZookeeperRegistryCenter
方法名:<init>
暂无
代码示例来源:origin: fang-yan-peng/eagle
@Override
protected RegistryCenter createRegistry(MergeConfig registryConfig) {
RegistryCenter registryCenter = new ZookeeperRegistryCenter(registryConfig);
registryCenter.init();
return registryCenter;
}
代码示例来源:origin: fang-yan-peng/eagle
/**
* 创建注册中心.
*
* @param connectString 注册中心连接字符串
* @param namespace 注册中心命名空间
* @param digest 注册中心凭证
* @return 注册中心对象
*/
public static CoordinatorRegistryCenter createCoordinatorRegistryCenter(final String connectString, final String namespace, final Optional<String> digest) {
Hasher hasher = Hashing.md5().newHasher().putString(connectString, Charsets.UTF_8).putString(namespace, Charsets.UTF_8);
if (digest.isPresent()) {
hasher.putString(digest.get(), Charsets.UTF_8);
}
HashCode hashCode = hasher.hash();
CoordinatorRegistryCenter result = REG_CENTER_REGISTRY.get(hashCode);
if (null != result) {
return result;
}
MergeConfig zkConfig = new MergeConfig();
zkConfig.addExt(ConfigEnum.address.getName(), connectString);
zkConfig.addExt(ConfigEnum.namespace.getName(), namespace);
if (digest.isPresent()) {
zkConfig.addExt(ConfigEnum.digest.getName(), digest.get());
}
result = new ZookeeperRegistryCenter(zkConfig);
result.init();
REG_CENTER_REGISTRY.put(hashCode, result);
return result;
}
}
本文整理了Java中eagle.jfaster.org.ZookeeperRegistryCenter.()方法的一些代码示例,展示了ZookeeperRegistryCenter.()的具体用法。这
本文整理了Java中com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter.()方法的一些代码示例,展示了ZookeeperReg
我是一名优秀的程序员,十分优秀!