zookeeper做集群的方法是什么

62次阅读
没有评论

共计 2008 个字符,预计需要花费 6 分钟才能阅读完成。

这篇文章主要讲解了“zookeeper 做集群的方法是什么”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着丸趣 TV 小编的思路慢慢深入,一起来研究和学习“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 ServiceCacheListener, Void ()
 {
 @Override
 public Void apply(ServiceCacheListener listener)
 { listener.cacheChanged();
 return null;
 }
 }
 );
 }
 }

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

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-08-04发表,共计2008字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)