使用Spring Cloud Zookeeper替代Spring Cloud Config Server实现Actuator上下文刷新

完全可以用Zookeeper实现这个需求，核心是把Git的配置同步到Zookeeper，再让Spring Boot应用监听Zookeeper配置变化并触发上下文刷新，以下是落地的实践方案：

一、Git配置同步到Zookeeper的实现 #

需要一个配置同步服务打通Git和Zookeeper，有两种触发方式：

• 定时拉取：用Python/Java写个轻量服务，定时（比如1分钟）拉取Git仓库的目标YAML配置文件，解析后将配置写入Zookeeper指定节点（比如/config/{service-id}/prod）。如果是复杂YAML结构，可以转成扁平键值对存储，或者直接存整个YAML字符串（取决于后续Spring Boot的读取方式）。
• Git Webhook触发：在Git仓库配置Webhook，当配置文件有提交变更时，触发同步服务拉取最新配置并更新Zookeeper节点，这种方式更实时。

同步服务核心逻辑示例（伪代码）：

# 拉取Git仓库最新代码
git pull origin main
# 读取YAML配置文件
with open('application-prod.yaml', 'r') as f:
    config_content = f.read()
# 连接Zookeeper并更新节点内容
zk = KazooClient(hosts='zk-cluster:2181')
zk.start()
zk.set('/config/my-service/prod', config_content.encode('utf-8'))
zk.stop()

二、Spring Boot应用集成Zookeeper配置监听与刷新 #

1. 依赖引入 #

在pom.xml中加入相关依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zookeeper-config</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

2. 基础配置 #

在bootstrap.yaml中配置Zookeeper地址和配置节点路径：

spring:
  cloud:
    zookeeper:
      connect-string: zk-cluster:2181
      config:
        root: config
        default-context: my-service
        profile-separator: '-'
management:
  endpoints:
    web:
      exposure:
        include: refresh

3. 配置监听与自动刷新 #

• 在需要动态刷新的Bean上添加@RefreshScope注解：

@RestController
@RefreshScope
public class ConfigController {
    @Value("${app.config.key}")
    private String configValue;

    @GetMapping("/config")
    public String getConfig() {
        return configValue;
    }
}

• 自定义Zookeeper节点监听器：Spring Cloud Zookeeper Config默认会监听配置节点变化，若需自定义逻辑，可手动注册Watcher，当节点内容变更时触发上下文刷新：

@Component
public class ZkConfigWatcher implements ApplicationListener<ContextRefreshedEvent> {
    @Autowired
    private ContextRefresher contextRefresher;
    @Autowired
    private CuratorFramework curatorFramework;

    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {
        try {
            curatorFramework.getData().usingWatcher((Watcher) watchedEvent -> {
                // 节点内容变更时触发刷新
                contextRefresher.refresh();
            }).forPath("/config/my-service/prod");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

三、Kubernetes环境下的刷新触发优化 #

在K8s集群中，每个Pod的/actuator/refresh是内部端点，可通过以下方式批量触发：

• 同步服务调用K8s API：同步服务完成Zookeeper配置更新后，调用K8s API获取目标服务的所有Pod IP，逐个发送POST请求到http://{pod-ip}:{port}/actuator/refresh。注意给同步服务配置K8s的ServiceAccount权限，允许获取Pod列表。
• 使用K8s Job触发：将刷新逻辑封装成Job，同步服务更新Zookeeper后创建Job，Job内部通过服务名访问所有Pod的端点（可借助K8s的DNS轮询，或用kubectl exec在Pod内调用本地端点）。

四、实践注意事项 #

• 权限控制：给Zookeeper配置节点设置ACL，避免未授权修改；给/actuator/refresh端点添加Basic Auth或JWT认证，防止恶意调用。
• 版本回溯：同步服务可将Git的Commit ID写入Zookeeper元数据节点（比如/config/my-service/prod/commit-id），方便后续回滚配置。
• 容错处理：同步服务加入重试机制，处理Git拉取失败、Zookeeper连接异常的情况；Spring Boot应用处理Zookeeper断开重连场景，避免配置监听失效。
• 灰度刷新：大规模服务场景下，可先刷新部分Pod验证配置正确性，再批量刷新所有实例。

内容的提问来源于stack exchange，提问作者user18363564