如何保证分布式系统中服务的高可用性：应对 ZooKeeper Leader 节点故障的注册处理策略

「java、python面试题」来自UC网盘app分享，打开手机app，额外获得1T空间
https://drive.uc.cn/s/2aeb6c2dcedd4
AIGC资料包
https://drive.uc.cn/s/6077fc42116d4
https://pan.xunlei.com/s/VN_qC7kwpKFgKLto4KgP4Do_A1?pwd=7kbv#
https://yv4kfv1n3j.feishu.cn/docx/MRyxdaqz8ow5RjxyL1ucrvOYnnH

import redis
from kazoo.client import KazooClient
from kazoo.exceptions import NoNodeError

# 初始化 zk 客户端和临时存储
zk = KazooClient(hosts='zk1:2181,zk2:2181,zk3:2181')
zk.start()
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)

def register_service(service_name, service_data):
    try:
        # 尝试连接 zk 集群
        zk.ensure_path('/services')
        zk.create('/services/' + service_name, value=service_data.encode(), ephemeral=True)
        print(f"Service {service_name} registered successfully.")
    except NoNodeError:
        # zk 节点不存在，将注册请求缓存到临时存储
        redis_client.set(service_name, service_data)
        print(f"Service {service_name} registration cached.")

def handle_leader_failure():
    # 在新的 Leader 节点选举成功后，检查是否有待注册的服务
    for service_name in redis_client.keys():
        service_data = redis_client.get(service_name).decode()
        zk.create('/services/' + service_name, value=service_data.encode(), ephemeral=True)
        print(f"Cached service {service_name} registered after Leader election.")

# 假设在这里调用 register_service() 来注册服务
# ...

# 假设在这里模拟 zk Leader 节点故障
# handle_leader_failure()

zk.stop()