图灵学院:dubbo启动之注册中心Registry

Registry dubbo

今天来分享下dubbo注册中心的大致结构

服务注册

对于服务提供方,它需要发布服务,而且由于应用系统的复杂性,服务的数量、类型也不断膨胀;对于服务消费方,它最关心如何获取到它所需要的服务,而面对复杂的应用系统,需要管理大量的服务调用。而且,对于服务提供方和服务消费方来说,他们还有可能兼具这两种角色,即既需要提供服务,有需要消费服务。通过将服务统一管理起来,可以有效地优化内部应用对服务发布/使用的流程和管理。服务注册中心可以通过特定协议来完成服务对外的统一

Registry: 服务注册与发现的注册中心。

RegistryFactory是注册中心的入口,调用注册中心方法的类是RegistryProtocol(下期会介绍)

先看下类图关系

类图可以看出

1:Dubbo提供的注册中心有如下几种类型可供选择:

1:Multicast注册中心

2:Zookeeper注册中心

3:Redis注册中心

4:Dubbo注册中心

2:获取注册中心

通过调用RegistryFactory的Registry getRegistry(URL url)方法获取注册中心的信息

Registry类图如下

服务首先暴露在服务端,然后调用Registry的register方法在注册中心(它是一个服务协调中心,dubbo以外的独立服务端,dubbo提供了客户端实现)注册服务,然后用户通过配置文件中配置的service的url去subscribe(订阅服务),Registry接收到订阅消息后会往url对应的的List中塞入当前NotifyListener,反之从这个list中移除listener就是取消订阅。registry会调用据consumer的订阅情况调用notify方法推送服务列表给Consumer。

注:

1:RegistryFactor在选择注册中心是通过SPI,默认是(dubbo)下图

2:RegistryFactor中 getRegistry(URL url) 里URL的数据来源是 的配置

详解下zookeeper注册中心

我们现在注册中心 配置如下:

通过spi调用的类和方法是

ZookeeperRegistryFactory

他里面有个createRegistry方法 new ZookeeperRegistry(url, zookeeperTransporter);

我们先看下zookeeperTransporter,他是一个接口,CuratorZookeeperTransporter和 ZkclientZookeeperTransporter

通过spi可以看到他是调用zkclient,主要实现zk的连接。

默认采用zkClient, dubbo源码集成两种zookeeper客户端,除了zkClient还有一个是curator

zkclient=com.alibaba.dubbo.remoting.zookeeper.zkclient.ZkclientZookeeperTransporter curator=com.alibaba.dubbo.remoting.zookeeper.curator.CuratorZookeeperTransporter

1:ZookeeperRegistry构造函数,客户端创建了对zookeeper的连接,并且添加了自动回复连接的监听器。

public ZookeeperRegistry(URL url, ZookeeperTransporter zookeeperTransporter) { super(url); if (url.isAnyHost()) { throw new IllegalStateException("registry address == null"); } String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT); if (! group.startsWith(Constants.PATH_SEPARATOR)) { group = Constants.PATH_SEPARATOR + group; } this.root = group; zkClient = zookeeperTransporter.connect(url);//这个是连接zk zkClient.addStateListener(new StateListener() { //监听器 public void stateChanged(int state) { if (state == RECONNECTED) { try { recover(); } catch (Exception e) { logger.error(e.getMessage(), e); } } } }); }

2.服务器端创建url的节点,默认为临时节点,客户端与服务端断开自动删除(这个是zk的特性参考CreateMode枚举)

创建的节点可以是临时和持久两种

public void create(String path, boolean ephemeral) { int i = path.lastIndexOf('/'); if (i > 0) { create(path.substring(0, i), false); } if (ephemeral) { createEphemeral(path); } else { createPersistent(path); } }

3:向服务器端发送注册请求

protected void doRegister(URL url) { try { zkClient.create(toUrlPath(url), url.getParameter(Constants.DYNAMIC_KEY, true)); } catch (Throwable e) { throw new RpcException("Failed to register " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e); } }

4:向服务器端发送取消注册请求

protected void doUnregister(URL url) { try { zkClient.delete(toUrlPath(url)); } catch (Throwable e) { throw new RpcException("Failed to unregister " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e); } }

注册BUG问题:

之前我用带有账号和密码的redis注册中心发现是连接不上的,通过源码分析里面并没有注入账号和密码我们看代码

类名是:RedisRegistry

在newJedisPool的时候没注入password和username

  • 发表于:
  • 原文链接:https://kuaibao.qq.com/s/20180518A0SYE000?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。

扫码关注云+社区

领取腾讯云代金券