# 集群状态
rabbitmqctl status
rabbitmqctl cluster_status

# 健康检查
rabbitmq-diagnostics check_running
rabbitmq-diagnostics check_local_alarms
rabbitmq-diagnostics check_port_connectivity
rabbitmq-diagnostics check_if_node_is_quorum_critical

# 列出资源
rabbitmqctl list_queues name messages consumers memory
rabbitmqctl list_connections name state channels
rabbitmqctl list_channels consumer_count messages_unacknowledged

# 日志
rabbitmq-diagnostics log_tail --since 1h
tail -f /var/log/rabbitmq/[email protected]

# 1. 检查服务是否运行
systemctl status rabbitmq-server
rabbitmqctl status

# 2. 检查端口监听
ss -tlnp | grep 5672
netstat -tlnp | grep 5672

# 3. 检查防火墙
iptables -L -n | grep 5672
firewall-cmd --list-ports

# 4. 检查配置
cat /etc/rabbitmq/rabbitmq.conf | grep listeners

# 检查用户是否存在
rabbitmqctl list_users

# 检查用户权限
rabbitmqctl list_permissions

# 重置密码
rabbitmqctl change_password username newpassword

# guest 用户远程访问被拒绝
# 解决: 创建新用户或修改 loopback_users.guest = false（不推荐）
rabbitmqctl add_user admin admin123
rabbitmqctl set_user_tags admin administrator
rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"

# 查看连接数
rabbitmqctl list_connections name peer_host state channels | wc -l

# 查看每个 IP 的连接数
rabbitmqctl list_connections peer_host | sort | uniq -c | sort -rn

# 关闭特定主机的连接
rabbitmqctl close_connection "connection_id" "reason"

# 查看内存使用
rabbitmqctl status | grep mem_used

# 查看内存告警
rabbitmqctl status | grep alarms

# 查看阻塞的连接
rabbitmqctl list_connections name state | grep blocked

# 查看队列内存使用
rabbitmqctl list_queues name memory messages | sort -k3 -rn | head -20

# 1. 增加内存阈值（临时）
rabbitmqctl set_vm_memory_high_watermark 0.7

# 2. 永久配置
# /etc/rabbitmq/rabbitmq.conf
vm_memory_high_watermark.relative = 0.6
vm_memory_high_watermark_paging_ratio = 0.75

# 3. 清理大队列
rabbitmqctl purge_queue queue_name

# 4. 扩容内存
# 增加服务器内存或使用更多节点分担负载

# 查看磁盘使用
df -h
rabbitmqctl status | grep disk_free

# 查看告警状态
rabbitmqctl status | grep alarms

# 查看队列占用
rabbitmqctl list_queues name messages durable | sort -k2 -rn | head -20

# 1. 调整磁盘阈值（临时）
rabbitmqctl set_disk_free_limit 1GB

# 2. 永久配置
disk_free_limit.absolute = 2GB

# 3. 清理数据
# 清空指定队列
rabbitmqctl purge_queue queue_name

# 删除不用的队列
rabbitmqctl delete_queue queue_name

# 4. 扩容磁盘
# 增加磁盘空间或迁移数据目录

# 检查网络分区
rabbitmqctl cluster_status | grep partitions

# 检查节点间连通性
rabbitmq-diagnostics check_port_connectivity

# 查看日志中的网络相关错误
grep -i "network\|partition\|net_ticktime" /var/log/rabbitmq/*.log

# 方案 1: 自动恢复（pause_minority 配置下）
# 等待网络恢复后节点自动加入

# 方案 2: 手动恢复
# 1. 选择数据最新的节点作为主节点
# 2. 在其他节点上执行：
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@primary_node
rabbitmqctl start_app

# 方案 3: 强制重置（最后手段）
rabbitmqctl force_reset

# 配置分区处理策略
cluster_partition_handling = pause_minority

# 调整网络检测超时（默认 60s）
net_ticktime = 120

# 使用仲裁队列（不受网络分区影响数据一致性）

# 查看未确认消息
rabbitmqctl list_queues name messages messages_unacknowledged consumers

# 查看消费者的预取设置
rabbitmqctl list_channels prefetch_count consumer_count messages_unacknowledged

# 查看消费者处理速率（通过管理 API）
curl -u admin:admin123 http://localhost:15672/api/queues/%2F/queue_name | \
  jq '{messages, messages_ready, messages_unacknowledged, consumer_details}'

# 设置合理的预取值
channel.basic_qos(prefetch_count=10)  # 根据处理速度调整

# 消费者处理超时
import signal

def timeout_handler(signum, frame):
    raise TimeoutError("Message processing timeout")

def callback(ch, method, properties, body):
    signal.signal(signal.SIGALRM, timeout_handler)
    signal.alarm(30)  # 30 秒超时
    try:
        process_message(body)
        ch.basic_ack(delivery_tag=method.delivery_tag)
    except TimeoutError:
        ch.basic_nack(delivery_tag=method.delivery_tag, requeue=True)
    finally:
        signal.alarm(0)

# 检查队列是否持久化
rabbitmqctl list_queues name durable

# 检查消息数量
rabbitmqctl list_queues name messages

# 重启 RabbitMQ 后检查消息是否丢失
systemctl restart rabbitmq-server
rabbitmqctl list_queues name messages

# 查看堆积队列
rabbitmqctl list_queues name messages messages_ready messages_unacknowledged consumers | \
  awk '$2 > 1000'

# 查看消费者数量
rabbitmqctl list_queues name consumers | awk '$2 == 0'

# 查看队列的进出速率（通过管理 API）
curl -u admin:admin123 http://localhost:15672/api/queues/%2F/queue_name | \
  jq '{messages, message_stats: {publish_details: {rate}, deliver_details: {rate}}}'

# 检查队列状态
rabbitmqctl list_queues name state

# 仲裁队列状态
rabbitmq-queues quorum_status "queue_name"

# 检查 Leader 是否存在
rabbitmq-queues members "queue_name"

# 查看队列参数
rabbitmqctl list_queues name arguments

# 删除并重建队列（谨慎）
rabbitmqctl delete_queue queue_name
# 然后通过代码重新声明

# 查看 Erlang 进程数
rabbitmqctl status | grep proc_used

# 查看文件描述符
rabbitmqctl status | grep fd_used

# 查看网络统计
rabbitmqctl list_connections name recv_oct send_oct

# 查看慢队列（消息多但消费者少）
rabbitmqctl list_queues name messages consumers | \
  awk '$2 > 1000 && $3 < 2'

# 启用 Top 插件查看进程资源使用
rabbitmq-plugins enable rabbitmq_top
# 管理界面 -> Admin -> Top