zookeeper做集群的方法是什么

这篇文章主要讲解了“zookeeper做集群的方法是什么”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“zookeeper做集群的方法是什么”吧！

场景：提供一个分布式Restful 服务让客户端去调用，支持动态加减机器。

分析：

server端并不复杂，启动webserver后，暴露http://url:8088/rs/xx 出去即可，那么会有如下几个：

server1:http://192.168.50.11:8088/rs/xx

server2:http://192.168.50.12:8088/rs/xx

client端 ：假设没有zk的时候，你可能会这么做。服务启动的时候把这些暴露的url地址放到一个static变量里面。然后轮询去调用。 这样就可以实现一个简单的软负载了。(PS:还有个方法：在前面加个nginx 做负载)

但是遇见这种情况了，某台机器挂了，你怎么办？ 或者在线上的时候加一台服务器，那么你需要修改client代码，加上url地址。重新部署。

很显然，这种做法太不好了，要停服务。那么看看有了注册中心后如何干。

改良：

1. server端不变，启动的时候把所有服务全部注册到zookeeper上面，比如User的，在/user下面创建临时节点。

2.添加一个session事件，当挂了后，重新注册，看看curator的源码：

if(newState==ConnectionState.RECONNECTED)
{
try
{
log.debug("Re-registeringduetoreconnection");
reRegisterServices();
}
catch(Exceptione)
{
log.error("Couldnotre-registerinstancesafterreconnection",e);
}
}

再看看 client 的思路，麻烦一点

1. 启动的时候就监听 /user chindren 事件，这个事件要用StartMode.BUILD_INITIAL_CACHE

意思是，第一次就取值。 然后放到cache里面。 我们看看curator的源码ServiceCacheImpl：

@Override
publicvoidstart()throwsException
{
Preconditions.checkState(state.compareAndSet(State.LATENT,State.STARTED),"Cannotbestartedmorethanonce");

cache.start(true);
for(ChildDatachildData:cache.getCurrentData())
{
addInstance(childData,true);
}
discovery.cacheOpened(this);
}

2. 如果中途添加/删除机器，那么在cache 里面 add/remove即可，看看curator的源码：

publicvoidchildEvent(CuratorFrameworkclient,PathChildrenCacheEventevent)throwsException
{
booleannotifyListeners=false;
switch(event.getType())
{
caseCHILD_ADDED:
caseCHILD_UPDATED:
{
addInstance(event.getData(),false);
notifyListeners=true;
break;
}

caseCHILD_REMOVED:
{
instances.remove(instanceIdFromData(event.getData()));
notifyListeners=true;
break;
}
}

if(notifyListeners)
{
listenerContainer.forEach
(
newFunction<ServiceCacheListener,Void>()
{
@Override
publicVoidapply(ServiceCacheListenerlistener)
{
listener.cacheChanged();
returnnull;
}
}
);
}
}

感谢各位的阅读，以上就是“zookeeper做集群的方法是什么”的内容了，经过本文的学习后，相信大家对zookeeper做集群的方法是什么这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是博信，小编将为大家推送更多相关知识点的文章，欢迎关注！