rabbitmq

RabbitMQ 服务启动与配置

补充说明

rabbitmq 是 AMQP 消息代理，负责队列、交换机、绑定和路由。服务端用 rabbitmq-server 启动，管理操作常用 rabbitmqctl 和管理插件。

常用示例

rabbitmq-server
rabbitmq-server -detached
rabbitmq-plugins enable rabbitmq_management
rabbitmqctl status
rabbitmqctl cluster_status
rabbitmqctl list_queues name messages consumers
rabbitmqctl add_user app 'S3cret'
rabbitmqctl set_permissions -p /app app '.*' '.*' '.*'
# 4.0 起经典镜像队列(ha-mode)已移除,高可用队列改用 quorum 类型
# 队列声明时设置 {"x-queue-type":"quorum"},已有 classic 队列需重建后才能转换
rabbitmq-diagnostics check_running

常见配置

listeners.tcp.default = 5672
management.tcp.port = 15672
loopback_users.guest = false
vm_memory_high_watermark.relative = 0.6
disk_free_limit.absolute = 2GB

易错点与排错

• guest 用户默认只能本地登录；远程管理要创建专用用户。
• vhost、用户权限和队列权限是三层；漏掉 -p 会操作错 vhost。
• 经典镜像队列在 RabbitMQ 4.0 已移除，ha-mode 策略不再生效；高可用应使用 quorum 队列。
• 队列是否持久化、消息是否持久化、发布是否 confirm 是三件独立的事。
• 消费者不 ack 会导致消息堆积和连接阻塞；检查 prefetch 和 ack 逻辑。
• 内存/磁盘告警会阻塞生产者；先看 status 和告警原因。
• 集群分区可能导致双主和消息重复；网络和分区处理策略要提前设计。
• Erlang cookie 不一致会导致节点无法加入集群。
• 管理插件端口 15672 不要直接暴露公网；加认证和访问控制。

相关命令

• rabbitmqctl — 管理命令
• rabbitmq-plugins — 插件
• rabbitmq-diagnostics — 诊断

读完自测

合上页面，先回答，再展开对照。

1. 队列和消息都声明为持久化，是否就一定不丢消息？
2. 生产者突然被阻塞，先查什么？
3. 节点无法加入集群，常见的集群配置问题是什么？