Redis
Redis 注册中心的基本使用和工作原理。
前置条件
- 了解 Dubbo 基本开发步骤
- 安装并启动 Redis 服务
使用说明
添加依赖
从 Dubbo3 开始,redis 注册中心适配已经不再内嵌在 Dubbo 中,使用前需要单独引入独立的模块。
<dependency>
<groupId>org.apache.dubbo.extensions</groupId>
<artifactId>dubbo-registry-redis</artifactId>
<version>3.3.0</version>
</dependency>
基本配置
<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 [^1] 实现的注册中心。
Redis 过期数据通过心跳的方式检测脏数据,服务器时间必须同步,并且对服务器有一定压力,否则过期检测会不准确
使用 Redis 的 Key/Map 结构存储数据结构:
- 主 Key 为服务名和类型
- Map 中的 Key 为 URL 地址
- Map 中的 Value 为过期时间,用于判断脏数据,脏数据由监控中心删除 [^3]
使用 Redis 的 Publish/Subscribe 事件通知数据变更:
- 通过事件的值区分事件类型:
register
,unregister
,subscribe
,unsubscribe
- 普通消费者直接订阅指定服务提供者的 Key,只会收到指定服务的
register
,unregister
事件 - 监控中心通过
psubscribe
功能订阅/dubbo/*
,会收到所有服务的所有变更事件
调用过程:
- 服务提供方启动时,向
Key:/dubbo/com.foo.BarService/providers
下,添加当前提供者的地址 - 并向
Channel:/dubbo/com.foo.BarService/providers
发送register
事件 - 服务消费方启动时,从
Channel:/dubbo/com.foo.BarService/providers
订阅register
和unregister
事件 - 并向
Key:/dubbo/com.foo.BarService/consumers
下,添加当前消费者的地址 - 服务消费方收到
register
和unregister
事件后,从Key:/dubbo/com.foo.BarService/providers
下获取提供者地址列表 - 服务监控中心启动时,从
Channel:/dubbo/*
订阅register
和unregister
,以及subscribe
和unsubsribe
事件 - 服务监控中心收到
register
和unregister
事件后,从Key:/dubbo/com.foo.BarService/providers
下获取提供者地址列表 - 服务监控中心收到
subscribe
和unsubsribe
事件后,从Key:/dubbo/com.foo.BarService/consumers
下获取消费者地址列表
最后修改 September 13, 2024: Refactor website structure (#2860) (1a4b998f54b)