zookeeper注册中心

发表于 2021-08-30 更新于 2025-08-21 分类于微服务 Waline：阅读次数：本文字数： 3.7k 阅读时长 ≈ 3 分钟

Zookeeper 作为服务注册中心：实现与特性解析

Zookeeper 是一个分布式协调服务，常被用作微服务架构的注册中心。与 Eureka 不同，Zookeeper 本身就是一个独立的服务端，无需额外开发注册中心服务，只需在微服务中集成客户端即可实现服务注册与发现。

Zookeeper 注册中心的核心优势

强一致性：基于 ZAB 协议（类 Paxos 算法），保证服务注册信息在集群中的一致性；
临时节点特性：服务实例以临时节点注册，服务下线或崩溃时自动删除，无需手动清理；
分布式协调能力：支持节点监听（Watch）机制，服务消费者可实时感知服务实例变化；
成熟稳定：广泛应用于分布式系统，如 Kafka、Hadoop 等，可靠性经过验证。

集成 Zookeeper 注册中心的步骤

1. 引入依赖

在 Spring Boot 项目中添加 Zookeeper 服务发现依赖：

<!-- Zookeeper注册中心客户端 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
</dependency>

注意：需确保 Zookeeper 服务已安装并启动（默认端口 2181）。

2. 主程序配置

通过@EnableDiscoveryClient注解开启服务注册与发现功能：

@SpringBootApplication
@EnableDiscoveryClient  // 启用服务注册与发现
public class ZookeeperProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(ZookeeperProviderApplication.class, args);
    }
}

3. 配置 Zookeeper 连接信息

在application.yml中配置 Zookeeper 地址和服务名称：

spring:
  application:
    name: provide-zookeeper  # 服务名称（注册到Zookeeper的标识）
  cloud:
    zookeeper:
      connect-string: localhost:2181  # Zookeeper服务地址（集群用逗号分隔，如host1:2181,host2:2181）
      discovery:
        enabled: true  # 启用Zookeeper服务发现（默认开启）
        register: true  # 启用服务注册（默认开启）

4. 启动服务并验证注册结果

服务启动后，会自动注册到 Zookeeper，可通过 Zookeeper 客户端工具（如zkCli.sh）查看：

# 连接Zookeeper
zkCli.sh -server localhost:2181

# 查看服务注册节点
ls /services  # 列出所有服务
ls /services/provide-zookeeper  # 列出"provide-zookeeper"服务的所有实例
get /services/provide-zookeeper/39a78506-f2cb-4c8f-bbab-768f1f9fc702  # 查看具体实例信息

实例信息示例（JSON 格式）：

{
  "name": "provide-zookeeper",
  "id": "39a78506-f2cb-4c8f-bbab-768f1f9fc702",  // 实例唯一ID
  "address": "192.168.1.124",  // 服务IP地址
  "port": 8004,  // 服务端口
  "payload": {
    "id": "application-1",
    "name": "provide-zookeeper",
    "metadata": {}  // 自定义元数据
  },
  "registrationTimeUTC": 1630313091916,  // 注册时间
  "serviceType": "DYNAMIC",
  "uriSpec": {
    "parts": [{"value":"scheme","variable":true}, {"value":"://","variable":false}, ...]
  }
}

Zookeeper 注册中心的核心特性

1. 节点结构

Zookeeper 中服务注册的节点结构为树形结构，默认根路径为/services：

/services
  /服务名称（如provide-zookeeper）
    /实例ID1（临时节点）
    /实例ID2（临时节点）
    ...

服务名称节点：持久节点，代表一个服务（如provide-zookeeper）；
实例节点：临时节点（ephemeralOwner不为 0），每个实例对应一个节点，服务下线后自动删除。

2. 临时节点与健康检查

Zookeeper 通过临时节点实现服务健康检查：

服务启动时创建临时节点，与 Zookeeper 保持会话（Session）；
服务正常运行时，定期发送心跳维持会话；
服务宕机或网络中断时，会话超时（默认 60 秒），临时节点自动删除；
服务消费者通过监听节点变化，实时感知实例上下线。

3. 服务发现机制

服务消费者获取服务实例的流程：

消费者启动时，向 Zookeeper 查询/services/服务名称下的所有实例节点；
消费者缓存实例列表，并注册Watch 监听（节点变化通知）；
当服务实例变化（上线 / 下线）时，Zookeeper 主动推送事件给消费者；
消费者收到通知后，重新查询实例列表并更新本地缓存。

4. 负载均衡

Spring Cloud 集成 Zookeeper 时，默认通过LoadBalancerClient实现负载均衡，支持轮询、随机等策略。如需自定义，可配置@LoadBalanced注解的 RestTemplate：

@Configuration
public class RestConfig {
    @Bean
    @LoadBalanced  // 启用负载均衡
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

// 使用时通过服务名调用
@Service
public class ConsumerService {
    @Autowired
    private RestTemplate restTemplate;
    
    public String callProvider() {
        // 直接使用服务名代替IP:端口
        return restTemplate.getForObject("http://provide-zookeeper/hello", String.class);
    }
}

Zookeeper 作为注册中心的注意事项

CP 特性的影响：
Zookeeper 是 CP 系统，Leader 节点故障时会进行选举（约 30-120 秒），期间服务注册功能不可用，但已注册的服务可正常发现。
会话超时配置：
需合理设置 Zookeeper 会话超时（spring.cloud.zookeeper.session-timeout），过短可能导致服务误判下线，过长可能延迟发现故障实例。
集群部署：
生产环境需部署 Zookeeper 集群（至少 3 节点），避免单点故障，配置示例：
```
spring:
  cloud:
    zookeeper:
      connect-string: zk-node1:2181,zk-node2:2181,zk-node3:2181
```
节点权限：
如需安全控制，可配置 Zookeeper 节点的 ACL 权限（spring.cloud.zookeeper.discovery.acl），限制服务注册与查询权限。

总结

Zookeeper 作为注册中心，凭借强一致性和临时节点特性，适合对数据一致性要求高的场景。其集成步骤简单，只需引入依赖、配置地址并启用服务发现注解即可。但需注意其 CP 特性可能带来的短暂不可用问题，适合服务变化不频繁、可接受短暂注册中断的分布式系统。

相比 Eureka 的 AP 特性，Zookeeper 更适合需要严格数据同步的场景（如金融支付、分布式事务），是微服务架构中注册中心的重要选择之一