[TOC]

Dubbo注册中心

ZooKeeper

Redis

原理

数据存储

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

• 主Key为服务名和类型

  形如：/dubbo/com.xxx.xxxProvider/providers

• Map中的Key为URL地址

  形如：dubbo://x.x.x.x:10000/com.xxx.xxxProvider?dispatcher=all&dubbo=2.5.8&xxx…

• Map中的Value为过期时间，用于判断脏数据，脏数据由监控中心删除

通知

使用 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 事件

• 服务消费方启动时：

  1、从 Channel:/dubbo/com.foo.BarService/providers 订阅 register 和 unregister 事件

  2、并向 Key:/dubbo/com.foo.BarService/providers 下，添加当前消费者的地址

• 服务消费方：

  收到 register 和 unregister 事件后，从 Key:/dubbo/com.foo.BarService/providers 下获取提供者地址列表

• 服务监控中心：

  1、启动时，从 Channel:/dubbo/* 订阅 register 和 unregister，以及 subscribe和unsubsribe事件

  2、收到 register 和 unregister 事件后，从 Key:/dubbo/com.foo.BarService/providers下获取提供者地址列表

  3、收到 subscribe 和 unsubsribe 事件后，从 Key:/dubbo/com.foo.BarService/consumers 下获取消费者地址列表

配置

RedisRegistry中主要实现了如下接口：

• doRegister(URL url); //向注册中心注册服务
• doUnregister(URL url); //取消服务注册
• doSubscribe(URL url, NotifyListener listener); // 向注册中心监听服务
• doUnsubscribe(URL url, NotifyListener listener); // 取消监听注册中心服务

源码

什么？告诉你原理还不行？来吧一起来看看源码：