重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
这篇文章主要讲解了“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-registering due to reconnection"); reRegisterServices(); } catch ( Exception e ) { log.error("Could not re-register instances after reconnection", e); } }
再看看 client 的思路,麻烦一点
1. 启动的时候就监听 /user chindren 事件,这个事件要用StartMode.BUILD_INITIAL_CACHE
意思是,第一次就取值。 然后放到cache里面。 我们看看curator的源码ServiceCacheImpl:
@Override public void start() throws Exception { Preconditions.checkState(state.compareAndSet(State.LATENT, State.STARTED), "Cannot be started more than once"); cache.start(true); for ( ChildData childData : cache.getCurrentData() ) { addInstance(childData, true); } discovery.cacheOpened(this); }
2. 如果中途添加/删除机器,那么在cache 里面 add/remove即可,看看curator的源码:
public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception { boolean notifyListeners = false; switch ( event.getType() ) { case CHILD_ADDED: case CHILD_UPDATED: { addInstance(event.getData(), false); notifyListeners = true; break; } case CHILD_REMOVED: { instances.remove(instanceIdFromData(event.getData())); notifyListeners = true; break; } } if ( notifyListeners ) { listenerContainer.forEach ( new Function() { @Override public Void apply(ServiceCacheListener listener) { listener.cacheChanged(); return null; } } ); } }
感谢各位的阅读,以上就是“zookeeper做集群的方法是什么”的内容了,经过本文的学习后,相信大家对zookeeper做集群的方法是什么这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!