文档章节

Curator Service discovery

蘑菇头老大
 蘑菇头老大
发布于 2014/08/01 13:13
字数 580
阅读 119
收藏 0

3 月,跳不动了?>>>

Service Discovery 服务发现,我以前不是很明白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;
                    }
                }
            );
        }
    }

 

 

如果这个思路明白了,其实完全可以不用Curator的,还可以做的更好,比如加入黑名单,路由策略等。

 

有事了,下次再写

© 著作权归作者所有

蘑菇头老大
粉丝 2
博文 20
码字总数 7628
作品 0
杭州
私信 提问
加载中

评论(0)

跟着实例学习ZooKeeper的用法: Curator扩展库

还记得Curator提供哪几个组件吗? 我们不妨回顾一下: Recipes Framework Utilities Client Errors Extensions 前面的例子其实前五个组件都涉及到了, 比如Utilities例子的TestServer, Clien...

longbadx
2015/02/11
2.2K
0
Maven构建ZooKeeper项目

执行mvn命令: mvn archetype:create -DgroupId=com.astute.strong -DartifactId=learn_zookeeper -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false 修改pom,添加......

智深
2012/11/24
7K
5
Apache Curator 2.10.0 和 3.1.0 发布

Apache Curator 今天发布两个新版本,分别是 2.10.0 和 3.1.0 。 其中 2.10.0 改进内容: Bug [CURATOR-208] - InterProcessSemaphoreV2 swallows InterruptedException [CURATOR-209] - Ba......

红薯
2016/02/15
4K
0
Apache Curator 4.3.0 发布,ZooKeeper 简化服务

Apache Curator 4.3.0 发布了。Apache Curator 是用于 Apache ZooKeeper 的 Java / JVM 客户端库,是一个分布式协调服务。 Apache Curator 内置高级 API 框架和实用程序,可使 Apache ZooKe...

xplanet
03/03
1.5K
1
使用Curator实现的zookeeper分布式锁出现的Unimplemented for {root.path}

问题描述 Curator使用 ZooKeeper 作为分布式锁,启动时发生该异常。 Curator 客户端版本:curator-recipes-2.10.0 ZooKeeper 服务器版本:3.4.13 异常日志 以及 问题分析 UnimplementedExcep...

loubobooo
2019/02/27
173
0

没有更多内容

加载失败,请刷新页面

加载更多

如何使div的浏览器窗口高度为100% - How to make a div 100% height of the browser window

问题: I have a layout with two columns - a left div and a right div . 我有两列的布局-左div和右div 。 The right div has a grey background-color , and I need it to expand vertic......

技术盛宴
今天
20
0
SSM框架整合

mybatis逆向工程 mybatis-generator生成pojo、mapper接口及映射文件 mapper放到e3-manager-dao层中 导入sql到数据库中; 导入逆向工程工具,配置xml文件 运行main方法 重复运行main不会覆盖!...

七宝1
今天
30
0
OSChina 周日乱弹 —— 和网友的第一次开房经历

Osc乱弹歌单(2020)请戳(这里) 【今日歌曲】 @薛定谔的兄弟 :分享洛神有语创建的歌单「我喜欢的音乐」: 《Ljósið》- Ólafur Arnalds 手机党少年们想听歌,请使劲儿戳(这里) @xiaos...

小小编辑
今天
50
0
程序员职业生涯指引

程序员应该尽早规划自己的职业生涯 为什么写 众所周知 IT 这一行到了一定的年龄、大部分人都或多或少有危机感,特别是今年全国乃至全球发生的疫情、导致整体经济受到很大的影响、这次的疫情影...

科比可比克
今天
11
0
JVM调优实战分析

一、查看服务器项目JVM参数以及参数分析 1、jps 命令 : 列出系统中所有的 Java 应用程序以及PID 如下图所示,26647就是我部署在服务器的一个小项目的 PID 2、jmap命令:查看堆的使用情况 如...

IT-Mamba
今天
46
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部