ApsaraMQ Copilot for RocketMQ：消息数据集成链路的健康管家

作者：文婷

引言

如何正确使用消息队列保证业务集成链路的稳定性，是消息队列用户首要关心的问题。ApsaraMQ Copilot for RocketMQ 从集成业务稳定性、成本、性能等方面帮助用户更高效地使用产品。

背景

消息队列产品通过异步消息的传递，来协调和解耦各个业务组件的交互，所以消息集成链路有以下复杂性：

1）在消息队列架构中，生产者与消费者是一对多的异步通信链路。

2）为了确保业务的完整性和实时性，消息必须能够可靠且及时地被投递给下游业务消费者应用。

3）消费者消费消息的业务逻辑可能包含了复杂的业务逻辑和服务依赖，任何一个环节的问题都可能引起消息处理不及时，因此需要采取相应措施来保障服务的连续性和可靠性。

为了帮助用户更高效地使用 RocketMQ，阿里云消息队列 ApsaraMQ 提供了一套名为 RocketMQ Copilot 的辅助工具集。它将专家的实践经验产品化，使得即便是缺乏经验的用户也能迅速掌握 RocketMQ 客户端的正确用法，利用云消息队列 RocketMQ 版的可观测性工具进行监控、并高效地排查和解决问题，恢复业务运行。

产品优势

ApsaraMQ Copilot for RocketMQ 提供了全链路健康度智能巡检与诊断的先进功能，成为构建高效消息集成链路的重要工具。这一平台专为维持和提升消息链路的健康状态而设计，通过以下几个关键操作来全面升级其监控和诊断能力：

1）全面监控 - Copilot 系统专注于评估整个消息链路的健康度，全面监测包括生产者和消费者在内的关键环节。它侦测配置异常、审查流量的正常性、确保消息的及时消费，并鉴别消费过程中的异常行为。

2）量化分析与配置可定制性 - 用户能够借助该平台执行量化分析，通过一系列精细化的指标和风险评级系统，有效识别并优先解决紧急的异常状况。同时，它也能够追踪到或许会被忽略的历史潜在问题，从而实现全方位的异常管理与防范。

3）简化诊断流程 - 通过提供一键式根因分析功能，ApsaraMQ Copilot 使用户仅需输入最基本的资源信息即可开始全面的诊断过程。该系统能够自动生成详细的诊断报告和针对性的处理建议，有效地引导用户完成问题修复。

产品功能

ApsaraMQ Copilot for RocketMQ 主要包括自助诊断工具和实例治理两部分功能，自助诊断工具负责单次诊断消息收发异常问题；实例治理负责巡检消息数据链路的使用异常。这项增强的健康巡检与诊断功能，使得 ApsaraMQ Copilot 为 RocketMQ 变成了一个真正的消息集成链路健康监管专家，赋予用户更强的监控能力，确保其消息集成的业务运行在最佳状态。

自助诊断工具

自助诊断工具旨在简化用户在处理消息收发异常时的诊断过程。用户只需要提交一些基本信息，如实例 ID、Topic（主题）和 Consumer Group（消费者组）、消息 ID，以及特定的问题场景，即可迅速开始对潜在问题的原因进行自动化分析。这一工具着重于提升用户体验，使得即使是没有深厚技术背景的用户也能高效地识别和解决问题。

以下是 RocketMQ 自助诊断工具的主要功能和场景介绍：

• 消费堆积延迟： 分析消息堆积延迟的原因，可能是消息量突增消费者应用容量不足、某消费者台机器异常、顺序消费有异常数据卡住无法处理、消费者处理消息耗时增长等原因。
• 消息收不到： 面对消费者无法收到消息的情况，诊断工具能够检查配置错误、网络问题或者其他相关的原因。
• 消息消费重复： 在消息被不止一次消费时，工具将分析并指出可能导致此问题的系统配置失误、消费超时或异常等原因。

自助诊断工具的核心优势在于其快速反馈和简洁的操作流程。它对于定位问题提供一个清晰的起点，使得用户不必深入底层系统细节即可开始故障排查工作。

一旦完成诊断过程，该工具会自动提供一份详尽的分析报告，其中包含了可能的问题原因和建议的解决步骤。这样的智能化分析显著提高了问题解决的效率和准确度。

实例治理

实例治理负责巡检消息数据链路的使用异常，帮助用户从稳定性、性能、安全、成本方面各个方面更专业地使用云消息队列 RocketMQ 产品。

以下是 RocketMQ 实例治理的主要巡检项和场景介绍：

稳定性方面

• 消息堆积延迟监控告警：分析消息堆积延迟的原因，可能是消息量突增消费者应用容量不足、某消费者台机器异常、顺序消费有异常数据卡住无法处理、消费者处理消息耗时增长等原因。
• 消息收不到：面对消费者无法收到消息的情况，诊断工具能够检查配置错误、网络问题或者其他相关的原因。
• 消息消费重复：在消息被不止一次消费时，工具将分析并指出可能导致此问题的系统配置失误、消费超时或异常等原因。

成本方面

• 闲置 Topic：巡检 Topic 的最近一次生产和消费消息时间，按照用户配置的闲置时间阈值发送提醒事件。
• 闲置 Group：巡检 Group 的最近一次消费消息时间，按照用户配置的闲置时间阈值发送提醒事件。

安全方面（二期上线）

• 跨地域接入点：巡检用户是否有正确使用接入点，避免安全和稳定性风险。
• 公网访问安全：巡检用户是否有正确配置公网访问 IP 白名单，避免公网访问的安全风险。

快速入门

自助诊断工具和实例治理没有使用门槛，用户可登录云消息队列 RocketMQ 版控制台直接使用。

1. 自助问题排查，输入实例、Topic、Group 等基础信息一键提交诊断。

2. 实例治理会根据巡检给实例评分，并把巡检事件按照风险分等级，让用户快速修复。

阿里云消息队列 ApsaraMQ 始终围绕“高弹性低成本、更稳定更安全、智能化免运维”三大核心方向进行演进和拓展。在智能化免运维方面，通过 ApsaraMQ Copilot，为企业提供消息数据集成链路的健康管家，让消息服务走进智能化免运维的新时代。

欢迎点击此处进入官网了解更多，也欢迎填写表单进行咨询：https://survey.aliyun.com/apps/zhiliao/bzT3AfPaq