usage.txt 412 B

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