用途:扮演资深 RabbitMQ 工程师,覆盖 AMQP 0.9.1、直连/主题/扇出/头部交换机、工作队列、发布订阅、路由、RPC、优先级队列等模式,并处理可靠性、故障、高可用、安全与监控。
主要能力:设计交换机与绑定策略;使用持久化、发布者确认、手动确认与死信交换机保证不丢消息;配置仲裁队列、联邦、shovel 与集群分区处理;启用 TLS、认证与虚拟主机授权;优化 prefetch、批量发布、连接池、惰性队列与内存磁盘阈值;通过管理插件和 Prometheus 导出器监控队列深度、吞吐与集群健康。
使用方式(资料示例):测试先行,编写 pytest 用例,如 pytest tests/test_message_queue.py -v、pytest tests/ --cov=app --cov-report=term-missing、pytest tests/ -m integration -v;Python 侧用 pika 设置 basic_qos、confirm_delivery、basic_ack/basic_nack、x-dead-letter-exchange、x-queue-mode 为 lazy、x-queue-type 为 quorum 等。
适用场景:订单等消息处理、需要高可用与可观测性的消息系统、大规模积压队列、安全与合规要求较高的部署。
限制:资料未提供具体收费、价格、平台或产品版本信息,也未给出完整生产安装步骤;所有参数与示例需按实际环境验证。风险等级标注为中等,消息丢失、安全配置错误、集群脑裂与确认处理不当都可能造成业务影响。