# 启动消费者: python consumer_quorum.py # 启动生产者 发送 2000 条消息 python producer_quorum.py 2000 # 在管理界面查看: # Queue Type 一栏显示 quorum # 即使某个节点挂掉,消息依旧不丢,队列自动重新选主,继续可用。 # 在队列声明里加 arguments={'x-queue-type':'quorum'},就得到高可用 + 强一致的 仲裁队列,无需额外镜像配置。