RabbitMQ相关操作及监控指标

运维操作

• 添加用户
rabbitmqctl add_user [username] [password]
• 修改用户密码
rabbitmqctl change_password Username Newpassword
• 将用户赋到admin
rabbitmqctl set_user_tags [username] administrator
• 用户赋权
rabbitmqctl set_permissions -p / admin '' '' ''
• 查询用户权限
rabbitmqctl list_permissions
• 查询现存用户
rabbitmqctl list_users
• 查询现存队列及任务量
rabbitmqctl list_queues
• 清理指定队列
rabbitmqctl list_queues |grep [queue_name] | awk {'print $1'} | xargs -n1 rabbitmqctl delete_queue

监控指标

Cluster-wide Metrics

指标 字段
Cluster name cluster_name
Cluster-wide message rates message_stats
Total number of connections object_totals.connections
Total number of channels object_totals.channels
Total number of queues object_totals.queues
Total number of consumers object_totals.consumers
Total number of messages (ready plus unacknowledged) queue_totals.messages
Number of messages ready for delivery queue_totals.messages_ready
Number of unacknowledged messages queue_totals.messages_unacknowledged
Messages published recently message_stats.publish
Message publish rate message_stats.publish_details.rate
Messages delivered to consumers recently message_stats.deliver_get
Message delivery rate message_stats.deliver_get.rate
Other message stats message_stats.* (see this document)

Node Metrics

指标 字段
Total amount of memory used mem_used
Memory usage high watermark mem_limit
Is a memory alarm in effect? mem_alarm
Free disk space low watermark disk_free_limit
Is a disk alarm in effect? disk_free_alarm
File descriptors available fd_total
File descriptors used fd_used
File descriptor open attempts io_file_handle_open_attempt_count
Sockets available sockets_total
Sockets used sockets_used
Message store disk reads message_stats.disk_reads
Message store disk writes message_stats.disk_writes
Inter-node communication links cluster_links
GC runs gc_num
Bytes reclaimed by GC gc_bytes_reclaimed
Erlang process limit proc_total
Erlang processes used proc_used
Runtime run queue run_queue

Individual Queue Metrics

指标 字段
Memory memory
Total number of messages (ready plus unacknowledged) messages
Number of messages ready for delivery messages_ready
Number of unacknowledged messages messages_unacknowledged
Messages published recently message_stats.publish
Message publishing rate message_stats.publish_details.rate
Messages delivered recently message_stats.deliver_get
Message delivery rate message_stats.deliver_get.rate
Other message stats message_stats.* (see this document)

https://www.rabbitmq.com/monitoring.html#rabbitmq-metrics

API结构

  • ./api/queues
    []map[string]interface{}
  • ./api/nodes
    []map[string]interface{}
  • ./api/overview
    map[string]interface{}
  • ./api/healthchecks/node
    {“status”:“ok”}
    {“status”:“failed”,“reason”:“string”}
  • ./api/vhosts
    []map[string]interface{}
  • ./api/exchanges
    []map[string]interface{}
  • ./api/connections
    []map[string]interface{}
版权声明：本文为weixin_43819222原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/weixin_43819222/article/details/106518731