RabbitMQ实战之界面管理和监控

我们想主动了解消息堆积和消费的情况&＃xff0c;以及服务器节点的压力&＃xff0c;RabbitMQ提供了几种方式便捷、直观的了解&＃xff0c;包括Web管理插件、REST API、rabbitmqadmin脚本。

通过介绍&＃xff0c;你会了解到&＃xff1a;

• web管理插件
• REST API
• rabbitmqadmin脚本
• Nagios和监控RabbitMQ

web管理插件

RabbitMQ的插件是由Erlang语言写的&＃xff0c;并且和服务器一同运行在同一个Erlang VM中&＃xff0c;通过下面的命令启用web管理插件&＃xff1a;

sudo ./rabbitmq-plugins enable rabbitmq_management


启动之后&＃xff0c;访问15672端口&＃xff0c;可看到Web管理页面主页面&＃xff1a;

添加用户

默认会提供一个默认用户guest&＃xff0c;密码也是guest&＃xff0c;线上环境需要创建一个新用户&＃xff0c;并把guest用户删除。

首先切换到Admin标签页&＃xff0c;可以查看或添加用户&＃xff0c;添加用户时&＃xff0c;可指定Tags&＃xff0c;相当于角色&＃xff0c;会拥有对应的权限&＃xff1a;

点击用户列表的用户名&＃xff0c;可分配权限、编辑或删除用户&＃xff0c;分配权限时&＃xff0c;可细化到某个virtual下的某个topic&＃xff0c;并按读、写、配置类别进行分开&＃xff1a;

管理队列、交换器、绑定

切换到“Exchanges”标签&＃xff0c;可查看和管理交换器&＃xff0c;单击交换器名称&＃xff0c;可查看到更多详细信息&＃xff0c;比如交换器绑定&＃xff0c;还可以添加新的绑定&＃xff1a;

切换到“Queues”标签&＃xff0c;可以查看队列信息&＃xff0c;点击队列名称&＃xff0c;可查看队列所有状态的消息数量和大小等统计信息&＃xff1a;

还可以查看消费者和绑定&＃xff0c;发布、获取消息&＃xff1a;

REST API

有时需要初始化一些列队列和交换器&＃xff0c;每次部署一套新环境后&＃xff0c;都需要一步一步创建会有点麻烦&＃xff0c;通过REST API可方便的实现自动化脚本。

当启用web管理插件后&＃xff0c;不仅获得了WEB UI&＃xff0c;也拥一个REST化的WEB管理API&＃xff0c;任何语言或脚本只要有HTTP库&＃xff0c;都能调用。

接口会返回json串&＃xff0c;比如获取所有队列&＃xff1a;

curl -i -u admin:admin http://localhost:15672/api/queues


会返回一个json数组&＃xff0c;每个元素是一个队列&＃xff0c;包含队列的各种属性&＃xff1a;

rabbitmqadmin脚本

另外&＃xff0c;还提供了rabbitmqadmin脚本的方式查看元数据信息和一些统计数据&＃xff0c;它会包装REST API&＃xff0c;使用干净的接口与其交互&＃xff0c;而且输出内容也是格式化过的&＃xff0c;方便我们查看。

比如查看所有队列&＃xff0c;可以这样写&＃xff1a;

./rabbitmqadmin list queues


会返回如下结果&＃xff1a;

监控

监控RabbitMQ并不只是确保端口5672是开启的并能接收TCP连接而已&＃xff0c;还要能够模拟AMQP客户端来确保连接之后获取信道&＃xff0c;如果能使用REST API找出是否所有构成RabbitMQ部件都正常运行&＃xff0c;并且之间能正常通信&＃xff0c;就更好了。

书中介绍使用Nagios监控框架进行监控&＃xff0c;我之前没有使用&＃xff0c;这里搜集了一些资料&＃xff0c;会做下简单介绍。

Nagios

Nagios是一款开源的监控工具&＃xff0c;能有效监控Windows、Linux和Unix的主机状态&＃xff0c;交换机路由器等网络设置&＃xff0c;打印机等。在系统或服务状态异常时发出邮件或短信报警第一时间通知网站运维人员&＃xff0c;在状态恢复后发出正常的邮件或短信通知。

它本身不包括这部分功能&＃xff0c;所有的监控、检测功能都是通过各种插件完成的&＃xff0c;启动Nagios后&＃xff0c;它会周期性的自动调用插件去检测服务器状态&＃xff0c;同时Nagios会维持一个队列&＃xff0c;所有插件返回来的状态信息都进入队列&＃xff0c;Nagios每次都从队首开始读取信息&＃xff0c;并进行处理后&＃xff0c;把状态结果通过web显示出来。

Nagios可以识别4种状态返回信息&＃xff1a;

• 0(OK)表示状态正常/绿色&＃xff1b;
• 1(WARNING)表示出现警告/黄色&＃xff1b;
• 2(CRITICAL)表示出现非常严重的错误/红色&＃xff1b;
• 3(UNKNOWN)表示未知错误/深黄色&＃xff1b;

Nagios根据插件返回来的值&＃xff0c;来判断监控对象的状态&＃xff0c;并通过web显示出来&＃xff0c;以供管理员及时发现故障。

它是如何管理远端服务器对象的&＃xff0c;使用NRPE插件&＃xff0c;主要过程如下&＃xff1a;

• Nagios 执行安装在它里面的check_nrpe插件&＃xff0c;并告诉check_nrpe去检测哪些服务&＃xff1b;
• 通过SSL&＃xff0c;check_nrpe连接远端机子上的NRPE daemon&＃xff1b;
• NRPE 运行本地的各种插件去检测本地的服务和状态&＃xff1b;
• NRPE把检测的结果传给主机端的check_nrpe&＃xff0c;check_nrpe再把结果送到Nagios状态队列中&＃xff1b;
• Nagios 依次读取队列中的信息&＃xff0c;再把结果显示出来&＃xff1b;

监控RabbitMQ

书中提到监控RabbitMQ的各个方面&＃xff0c;比如&＃xff1a;监控Rabbit内部状态、确认RabbitMQ可用并且能够响应、观察队列状态检测消费者异常、检测消息通信结构中不合需求的配置更改等。

基本思路都是通过编写Nagios需要的检测脚本&＃xff0c;使用AMQP客户端或REST API的方式&＃xff0c;获取关心的监控信息&＃xff0c;根据情况返回不同的状态码。

具体的脚本脚本就不一一介绍了&＃xff0c;这里举个例子&＃xff0c;监控队列的持久化配置是否正确&＃xff0c;通过api/queues//获取队列信息&＃xff0c;判断它的durable属性是否为true&＃xff0c;脚本如下&＃xff1a;

import sys, json, httplib, urllib, base64, socket# 1.定义状态码
EXIT_OK &＃61; 0
EXIT_WARNING &＃61; 1
EXIT_CRITICAL &＃61; 2
EXIT_UNKNOWN &＃61; 3# 2.解析参数
server, port &＃61; sys.argv[1].split(":")
vhost &＃61; sys.argv[2]
username &＃61; sys.argv[3]
password &＃61; sys.argv[4]
queue_name &＃61; sys.argv[5]
auto_delete &＃61; json.loads(sys.argv[6].lower())
durable &＃61; json.loads(sys.argv[7].lower())# 3.连接服务器
conn &＃61; httplib.HTTPConnection(server, port)# 4.构建api路径
path &＃61; "/api/queues/%s/%s" % (urllib.quote(vhost, safe&＃61;""),urllib.quote(queue_name))
method &＃61; "GET"# 5.执行http请求
credentials &＃61; base64.b64encode("%s:%s" % (username, password))
try:conn.request(method, path, "",{"Content-Type" : "application/json","Authorization" : "Basic " &＃43; credentials})# 6.连接异常&＃xff0c;退出
except socket.error:print "UNKNOWN: Could not connect to %s:%s" % (server, port)exit(EXIT_UNKNOWN)response &＃61; conn.getresponse()# 7.状态码为404&＃xff0c;说明队列不存在&＃xff0c;退出
if response.status &＃61;&＃61; 404:print "CRITICAL: Queue %s does not exist." % queue_nameexit(EXIT_CRITICAL)# 8.durable属性是否正确
if response["durable"] !&＃61; durable:print "WARN: Queue &＃39;%s&＃39; - durable flag is NOT %s." % \(queue_name, durable)exit(EXIT_WARNING)# 9.返回正常
print "OK: Queue %s configured correctly." % queue_name
exit(EXIT_OK)