Galaxis 中文站

阿里云ES监控RabbitMQ

发布日期:2025-01-03 17:26    点击次数:56
RabbitMQ是一个开源的消息代理服务器,能够为您的应用提供一个通用的消息发送和接收平台,并且保证消息在传输过程中的安全性。本文介绍如何通过Filebeat,将RabbitMQ的日志采集到阿里云Elasticsearch(简称ES)中,并对日志进行可视化分析与监控。步骤一:配置RabbitMQ步骤二:安装RabbitMQ示例应用步骤三:创建并配置阿里云Filebeat步骤四:配置阿里云Logstash管道步骤五:通过Kibana查看日志数据步骤六:通过Kibana过滤日志数据步骤七:配置Metricbeat采集RabbitMQ指标准备工作创建阿里云ES和Logstash实例,两者版本相同,并且在同一专有网络VPC(Virtual Private Cloud)下。开启阿里云ES实例的自动创建索引功能。创建阿里云ECS实例,要求与阿里云ES实例和Logstash实例处于同一VPC下。在目标ECS实例上安装云助手和Docker服务。在目标ECS实例上安装RabbitMQ。 步骤一:配置RabbitMQ配置RabbitMQ的日志记录级别和文件名,步骤如下:连接安装了RabbitMQ的ECS服务器。执行以下命令,打开RabbitMQ的配置文件。修改RabbitMQ的配置文件。修改配置文件后,需要启动RabbitMQ才能生效。启动RabbitMQ服务。步骤二:安装RabbitMQ示例应用在ECS中,执行以下命令克隆示例。进入该应用所在根目录。执行以下命令打包并运行应用。进入log目录下查看RabbitMQ日志。步骤三:创建并配置阿里云Filebeat配置Filebeat采集器,将RabbitMQ的日志信息发送到阿里云Logstash的8100端口。登录阿里云Elasticsearch控制台。在左侧导航栏,单击Beats数据采集中心。在创建采集器区域,选择Filebeat > ECS日志。配置采集器。安装并启动采集器。查看采集器安装情况。步骤四:配置阿里云Logstash管道配置阿里云Logstash管道,使用基本的Grok模式从原始消息中分离出时间戳、日志级别和消息,然后发送到阿里云ES实例的指定索引中。进入阿里云Elasticsearch控制台的Logstash页面。进入目标实例。在顶部菜单栏处,选择地域。在Logstash实例中单击目标实例ID。在左侧导航栏,单击管道管理。单击创建管道。在创建管道任务页面,输入管道ID并配置管道。单击下一步,配置管道参数。单击保存或者保存并部署。步骤五:通过Kibana查看日志数据登录目标阿里云ES的Kibana控制台。在左侧导航栏,单击Dev Tools。在Console中执行以下命令,查看Logstash处理后的RabbitMQ日志数据。步骤六:通过Kibana过滤日志数据登录目标阿里云ES实例的Kibana控制台。创建一个索引模式。在左侧导航栏,单击Management。在Kibana区域,单击Index Patterns。单击Create index pattern。输入Index pattern(本文使用rabbitmqlog-*),单击Next step。选择Time Filter field name(本文选择@timestamp),单击Create index pattern。在左侧导航栏,单击Discover。从页面左侧的下拉列表中,选择您已创建的索引模式(rabbitmqlog-*)。在页面右上角,选择一段时间,查看对应时间段内的RabbitMQ日志数据。单击Add a filter,设置过滤条件,查看符合条件的日志数据。步骤七:配置Metricbeat采集RabbitMQ指标您也可以通过Metricbeat采集RabbitMQ日志数据,并通过Kibana可视化监控RabbitMQ的各项指标。登录目标阿里云ES的Kibana控制台。在页面左上角,单击Kibana。在Add Data to Kibana区域,单击Add metric data。在Metrics页签,单击RabbitMQ metrics。单击RPM,按照页面提示在ECS中安装并配置Metricbeat。启动RabbitMQ模块及Metricbeat服务。在RPM页签中,单击Check data。单击RabbitMQ metrics dashboard,查看Dashboard监控大盘。

栏目分类
热点资讯