Dubbo注册中心

Multicast 注册中心

Multicast 注册中心不须要启动任何中心节点，只要广播地址同样，就能够互相发现。

1. 提供方启动时广播本身的地址
2. 消费方启动时广播订阅请求
3. 提供方收到订阅请求时，单播本身的地址给订阅者，若是设置了 unicast=false，则广播给订阅者
4. 消费方收到提供方地址时，链接该地址进行 RPC 调用。

组播受网络结构限制，只适合小规模应用或开发阶段使用。组播地址段: 224.0.0.0 - 239.255.255.255

配置

<dubbo:registry address="multicast://224.5.6.7:1234" />

或

<dubbo:registry protocol="multicast" address="224.5.6.7:1234" />

为了减小广播量，Dubbo 缺省使用单播发送提供者地址信息给消费者，若是一个机器上同时启了多个消费者进程，消费者需声明 unicast=false，不然只会有一个消费者能收到消息：

<dubbo:registry address="multicast://224.5.6.7:1234?unicast=false" />

或

<dubbo:registry protocol="multicast" address="224.5.6.7:1234">
    <dubbo:parameter key="unicast" value="false" />
</dubbo:registry>

zookeeper 注册中心

Zookeeper 是 Apacahe Hadoop 的子项目，是一个树型的目录服务，支持变动推送，适合做为 Dubbo 服务的注册中心，工业强度较高，可用于生产环境，并推荐使用 1。

流程说明：

• 服务提供者启动时: 向 /dubbo/com.foo.BarService/providers 目录下写入本身的 URL 地址
• 服务消费者启动时: 订阅 /dubbo/com.foo.BarService/providers 目录下的提供者 URL 地址。并向 /dubbo/com.foo.BarService/consumers 目录下写入本身的 URL 地址
• 监控中心启动时: 订阅 /dubbo/com.foo.BarService 目录下的全部提供者和消费者 URL 地址。

支持如下功能：

• 当提供者出现断电等异常停机时，注册中心能自动删除提供者信息
• 当注册中心重启时，能自动恢复注册数据，以及订阅请求
• 当会话过时时，能自动恢复注册数据，以及订阅请求
• 当设置 <dubbo:registry check="false" /> 时，记录失败注册和订阅请求，后台定时重试
• 可经过 <dubbo:registry username="admin" password="1234" /> 设置 zookeeper 登陆信息
• 可经过 <dubbo:registry group="dubbo" /> 设置 zookeeper 的根节点，不设置将使用无根树
• 支持 * 号通配符 <dubbo:reference group="*" version="*" />，可订阅服务的全部分组和全部版本的提供者

使用

在 provider 和 consumer 中增长 zookeeper 客户端 jar 包依赖：

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.3.3</version>
</dependency>

Dubbo 支持 zkclient 和 curator 两种 Zookeeper 客户端实现：

使用 zkclient 客户端

从 2.2.0 版本开始缺省为 zkclient 实现，以提高 zookeeper 客户端的健状性。zkclient 是 Datameer 开源的一个 Zookeeper 客户端实现。

缺省配置：

<dubbo:registry ... client="zkclient" />

或：

dubbo.registry.client=zkclient

或：

zookeeper://10.20.153.10:2181?client=zkclient

需依赖或直接下载：

<dependency>
    <groupId>com.github.sgroschupf</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.1</version>
</dependency>

使用 curator 客户端

从 2.3.0 版本开始支持可选 curator 实现。Curator 是 Netflix 开源的一个 Zookeeper 客户端实现。

若是须要改成 curator 实现，请配置：

<dubbo:registry ... client="curator" />

或：

dubbo.registry.client=curator

或：

zookeeper://10.20.153.10:2181?client=curator

需依赖或直接下载：

<dependency>
    <groupId>com.netflix.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>1.1.10</version>
</dependency>

Zookeeper 单机配置:

<dubbo:registry address="zookeeper://10.20.153.10:2181" />

或：

<dubbo:registry protocol="zookeeper" address="10.20.153.10:2181" />

Zookeeper 集群配置：

<dubbo:registry address="zookeeper://10.20.153.10:2181?backup=10.20.153.11:2181,10.20.153.12:2181" />

或：

<dubbo:registry protocol="zookeeper" address="10.20.153.10:2181,10.20.153.11:2181,10.20.153.12:2181" />

同一 Zookeeper，分红多组注册中心:

<dubbo:registry id="chinaRegistry" protocol="zookeeper" address="10.20.153.10:2181" group="china" />
<dubbo:registry id="intlRegistry" protocol="zookeeper" address="10.20.153.10:2181" group="intl" />

zookeeper 安装

安装方式参见: Zookeeper安装手册，只需搭一个原生的 Zookeeper 服务器，并将 Quick Start 中 Provider 和 Consumer 里的 conf/dubbo.properties 中的 dubbo.registry.addrss 的值改成 zookeeper://127.0.0.1:2181 便可使用。

可靠性声明
阿里内部并无采用 Zookeeper 作为注册中心，而是使用本身实现的基于数据库的注册中心，即：Zookeeper 注册中心并无在阿里内部长时间运行的可靠性保障，此 Zookeeper 桥接实现只为开源版本提供，其可靠性依赖于 Zookeeper 自己的可靠性。

兼容性声明
因 2.0.8 最初设计的 zookeeper 存储结构不能扩充不一样类型的数据，2.0.9 版本作了调整，因此不兼容，需所有改用 2.0.9 版本才行，之后的版本会保持兼容 2.0.9。2.2.0 版本改成基于 zkclient 实现，需增长 zkclient 的依赖包，2.3.0 版本增长了基于 curator 的实现，做为可选实现策略。

Redis 注册中心

基于 Redis(是一个高效的 KV 存储服务器)实现的注册中心(从 2.1.0 版本开始支持) 。

使用 Redis 的 Key/Map 结构存储数据结构：

• 主 Key 为服务名和类型
• Map 中的 Key 为 URL 地址
• Map 中的 Value 为过时时间，用于判断脏数据，脏数据由监控中心删除 (Redis 过时数据经过心跳的方式检测脏数据，服务器时间必须同步，而且对服务器有必定压力，不然过时检测会不许确)

使用 Redis 的 Publish/Subscribe 事件通知数据变动：

• 经过事件的值区分事件类型：register, unregister, subscribe, unsubscribe
• 普通消费者直接订阅指定服务提供者的 Key，只会收到指定服务的 register, unregister 事件
• 监控中心经过 psubscribe 功能订阅 /dubbo/*，会收到全部服务的全部变动事件

调用过程：

1. 服务提供方启动时，向 Key:/dubbo/com.foo.BarService/providers 下，添加当前提供者的地址
2. 并向 Channel:/dubbo/com.foo.BarService/providers 发送 register 事件
3. 服务消费方启动时，从 Channel:/dubbo/com.foo.BarService/providers 订阅 register 和 unregister 事件
4. 并向 Key:/dubbo/com.foo.BarService/providers 下，添加当前消费者的地址
5. 服务消费方收到 register 和 unregister 事件后，从 Key:/dubbo/com.foo.BarService/providers 下获取提供者地址列表
6. 服务监控中心启动时，从 Channel:/dubbo/* 订阅 register 和 unregister，以及 subscribe 和unsubsribe事件
7. 服务监控中心收到 register 和 unregister 事件后，从 Key:/dubbo/com.foo.BarService/providers 下获取提供者地址列表
8. 服务监控中心收到 subscribe 和 unsubsribe 事件后，从 Key:/dubbo/com.foo.BarService/consumers 下获取消费者地址列表

配置

<dubbo:registry address="redis://10.20.153.10:6379" />

或

<dubbo:registry address="redis://10.20.153.10:6379?backup=10.20.153.11:6379,10.20.153.12:6379" />

或

<dubbo:registry protocol="redis" address="10.20.153.10:6379" />

或

<dubbo:registry protocol="redis" address="10.20.153.10:6379,10.20.153.11:6379,10.20.153.12:6379" />

选项

• 可经过 <dubbo:registry group="dubbo" /> 设置 redis 中 key 的前缀，缺省为 dubbo。
• 可经过 <dubbo:registry cluster="replicate" /> 设置 redis 集群策略，缺省为 failover：
• failover: 只写入和读取任意一台，失败时重试另外一台，须要服务器端自行配置数据同步
• replicate: 在客户端同时写入全部服务器，只读取单台，服务器端不须要同步，注册中心集群增大，性能压力也会更大

可靠性声明

阿里内部并无采用 Redis 作为注册中心，而是使用本身实现的基于数据库的注册中心，即：Redis 注册中心并无在阿里内部长时间运行的可靠性保障，此 Redis 桥接实现只为开源版本提供，其可靠性依赖于 Redis 自己的可靠性。

Simple 注册中心

 Simple 注册中心自己就是一个普通的 Dubbo 服务，能够减小第三方依赖，使总体通信方式一致。

配置

将 Simple 注册中心暴露成 Dubbo 服务：

 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsdhttp://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 当前应用信息配置 -->
    <dubbo:application name="simple-registry" />
    <!-- 暴露服务协议配置 -->
    <dubbo:protocol port="9090" />
    <!-- 暴露服务配置 -->
    <dubbo:service interface="com.alibaba.dubbo.registry.RegistryService" ref="registryService" registry="N/A" ondisconnect="disconnect" callbacks="1000">
        <dubbo:method name="subscribe"><dubbo:argument index="1" callback="true" /></dubbo:method>
        <dubbo:method name="unsubscribe"><dubbo:argument index="1" callback="false" /></dubbo:method>
    </dubbo:service>
    <!-- 简单注册中心实现，可自行扩展实现集群和状态同步 -->
    <bean id="registryService" class="com.alibaba.dubbo.registry.simple.SimpleRegistryService" />
</beans>

引用 Simple Registry 服务：

<dubbo:registry address="127.0.0.1:9090" />

或者：

<dubbo:service interface="com.alibaba.dubbo.registry.RegistryService" group="simple" version="1.0.0" ... >

或者：

<dubbo:registry address="127.0.0.1:9090" group="simple" version="1.0.0" />

适用性说明

此 SimpleRegistryService 只是简单实现，不支持集群，可做为自定义注册中心的参考，但不适合直接用于生产环境。

参考：

http://dubbo.io/books/dubbo-user-book/references/registry/introduction.html