11.7.2 服务发现与注册中心实践

服务发现与注册中心实践#

服务发现的目标是让服务实例运行时动态注册、下线，消费者及时感知变更。ZooKeeper 提供强一致元数据与事件通知机制，适合作为轻量注册中心。以下给出可落地的结构规划、命令、示例、排错与练习。

原理草图与调用链路#

目录结构与节点规划#

/services/{env}/{service}/providers：服务提供者列表
/services/{env}/{service}/consumers：可选，记录消费者信息
节点数据：IP、端口、版本、权重、健康状态、标签

节点类型建议：
- providers 下使用临时顺序节点，会话断开自动移除且避免实例 ID 冲突
- 服务元数据可放在持久节点，便于统一管理与变更

实战：注册中心目录初始化#

适用于首次上线路径结构，命令基于 zkCli.sh。

# 1) 进入 ZooKeeper 客户端
/opt/zookeeper/bin/zkCli.sh -server 127.0.0.1:2181

# 2) 创建目录结构（持久节点）
create /services ""
create /services/prod ""
create /services/prod/order ""
create /services/prod/order/providers ""
create /services/prod/order/consumers ""

# 3) 校验结构
ls /services/prod/order
# 预期输出: [providers, consumers]

实战：服务实例注册（临时顺序节点）#

# 在 zkCli 中执行：创建临时顺序节点并写入实例信息
create -e -s /services/prod/order/providers/instance- \
'{"ip":"10.0.1.21","port":8080,"version":"1.2.3","weight":80,"healthy":true,"zone":"az1"}'

# 预期输出: /services/prod/order/providers/instance-0000000012
# 查询节点数据
get /services/prod/order/providers/instance-0000000012

命令解释：
- -e：创建临时节点，Session 断开后自动删除
- -s：创建顺序节点，自动追加序号
- get：读取节点数据（实例元信息）

实战：服务发现与Watcher订阅#

# 1) 初次拉取并构建本地缓存（示意）
ls /services/prod/order/providers
# 预期输出: [instance-0000000012, instance-0000000013]

# 2) 设置 Watcher 订阅变更（一次性触发）
ls -w /services/prod/order/providers
# 有新增/删除时会收到事件通知，随后需重新注册 Watch

Watcher 策略建议：
- 事件触发后重新拉取全量列表并重建本地缓存
- 定时全量同步（如 30s）防止 Watcher 丢失
- 本地缓存优先用于负载均衡，避免频繁访问 ZK

实战：客户端注册/发现脚本样例（运维自测）#

#!/usr/bin/env bash
# file: /opt/ops/zk_register.sh
# 用途: 模拟实例注册/发现

ZK="127.0.0.1:2181"
BASE="/services/prod/order/providers"
META='{"ip":"10.0.1.99","port":8080,"version":"1.0.0","weight":50,"healthy":true,"zone":"az2"}'

# 注册
/opt/zookeeper/bin/zkCli.sh -server "$ZK" <<EOF
create -e -s ${BASE}/instance- '$META'
ls ${BASE}
EOF

执行与预期：

bash /opt/ops/zk_register.sh
# 预期输出: instance-00000000xx 出现在 providers 列表

健康检查与剔除策略#

会话断开自动剔除实例，无需额外清理
应用层健康状态可写入节点数据，消费者基于字段过滤
对短暂抖动设置本地延迟剔除（如 3 次失败后剔除）

示例：更新健康字段（模拟）

set /services/prod/order/providers/instance-0000000012 \
'{"ip":"10.0.1.21","port":8080,"version":"1.2.3","weight":80,"healthy":false,"zone":"az1"}'

负载均衡与路由策略#

客户端侧负载均衡：轮询、随机、加权
标签路由：按版本、机房、可用区选择实例
灰度发布：通过标签/权重控制流量比例

加权路由示例（伪代码）：

# weight=80 的实例被选中的概率更高
# 伪示意：按照 weight 构建权重桶

安全与权限（ACL）#

示例：只允许提供者写入 providers 节点

# 添加 digest ACL 示例（需在客户端执行）
# 账号: provider 密码: strongpass
addauth digest provider:strongpass
setAcl /services/prod/order/providers \
digest:provider:strongpass:cdrwa

权限说明：
- c 创建、d 删除、r 读取、w 写入、a ACL 管理

高可用与降级#

启用本地缓存 + 定时刷新，ZK 短暂不可用不影响请求
设置合理会话超时（如 10s~30s）与重试退避
兜底：静态服务清单或多注册中心策略

典型问题与处理（含排错命令）#

1) Watcher 丢失
- 现象：服务变更后客户端无更新
- 处理：重新注册 Watch，做定时全量同步
- 验证：

ls -w /services/prod/order/providers
# 观察事件是否触发

2) 节点过多导致通知风暴
- 现象：事件频繁、客户端 CPU 飙高
- 处理：按服务拆分路径，避免全局监听
- 验证：

ls /services/prod
# 确认服务按路径拆分

3) 会话频繁重连
- 现象：临时节点频繁消失/重建
- 排查：网络抖动、心跳超时、ZK 负载
- 命令：

# 查看会话信息与连接状态
echo stat | nc 127.0.0.1 2181
echo cons | nc 127.0.0.1 2181

练习题（含操作步骤）#

1) 练习：创建服务注册目录并模拟 2 个实例注册
- 要求：/services/prod/payment/providers 下出现 2 个临时顺序节点
- 步骤：使用 create -e -s 注册两次

2) 练习：模拟实例下线
- 要求：关闭会话后节点自动删除
- 步骤：在一个 zkCli 会话中创建临时节点，退出会话，观察节点消失

3) 练习：Watcher 触发
- 要求：在消费者会话中对 providers 设置 Watch，另一个会话新增实例触发事件

与其他组件集成建议#

与 Nacos/Consul 共存时明确注册源优先级，避免双写
在微服务框架中封装注册与发现逻辑，统一治理与监控