微信 购物网站开发社群运营的经典案例

#作者：任少近

Pulsar高可用测试

1. 测试目的

本次测试旨在验证 Apache Pulsar 在某个 Broker 节点宕机（down）的情况下，是否仍能正常提供服务，确保集群具备高可用能力。通过模拟节点故障，观察并验证 Pulsar 集群在异常情况下的自动恢复和持续服务能力。

2.当前集群环境说明

当前 Pulsar 集群中部署了多个 Broker 节点，组成一个完整的分布式消息队列系统。具体节点信息如下：
Broker 节点数：3个（node1、node2、node3）
ZooKeeper 集群：3节点
BookKeeper 集群：3节点
使用的 Pulsar 版本：2.x.x（根据实际情况填写）

当前的pulsar节点数

3. 模拟故障场景

为了验证高可用性，我们选择将其中一个 Broker 节点 node1 停止服务，模拟节点宕机的异常场景。
操作步骤如下：
停掉bookie-0

4.功能验证

使用 Pulsar 自带的 pulsar-admin 工具对命名空间和主题进行增删查改等基本操作，以验证集群是否仍然可正常运行。
进行增删查改，验证高可用。

创建命名空间：执行如下命令创建一个新的命名空间 public/test2：
./pulsar-admin namespaces create public/test2

创建主题：在该命名空间下创建一个名为 topic2 的主题：

查询主题,执行命令确认主题是否成功创建：

删除主题,验证删除功能是否正常：

重复以上操作
反复执行上述操作，确保在节点宕机期间，所有管理接口均能正常使用，无明显异常或超时。

5.结论

通过一系列对命名空间和主题的管理操作，我们验证了在 bookie-0节点宕机的情况下，Pulsar 集群仍能够正常响应请求，完成主题的创建、查询与删除等操作，表明 Pulsar 具备良好的高可用机制，依然保持服务的连续性和稳定性。