云上的RabbitMQ&AMQP来监听为什么会时有时无？

云上的 RabbitMQ 解决方案

阿里云提供的 云消息队列 RabbitMQ 版 是一种基于开源 RabbitMQ 的高级消息队列服务，专为解决企业级消息传递需求而设计。以下从多个方面为您详细介绍其功能、优势及使用方法。

一、产品核心优势

1. 兼容开源

   • 完全支持 AMQP 0-9-1 协议标准。
   • 兼容所有开源 RabbitMQ 客户端（包括多种语言）以及 Queue、Exchange、Vhost 等组件。

2. 解决开源痛点

   • 提供海量消息堆积能力，避免因内存问题导致的宕机。
   • 集群采用分布式无主架构，彻底根除脑裂问题，支持高可扩展性和弹性扩缩容，单队列吞吐量无上限。

3. Serverless 模式

   • 打破固定资源付费模式，按量计费，节省成本。
   • 弹性伸缩范围广，业务无感知。

4. 功能增强

   • 支持全球消息路由，提供稳定可靠的 Shovel 转发能力，实现跨实例、跨地域的消息转发。
   • 新增死信队列功能：当消息消费超过最大重试次数后，自动进入死信队列。
   • 灵活的消息重试机制，确保不会因个别问题阻塞新消息的消费。

二、产品功能详解

1. 全模型支持

   • 完全兼容开源 RabbitMQ 的各个组件和概念，包括 Queue、Exchange 和 Vhost。

2. Queue 模式

   • 支持多分区存储消息，同一消费者支持集群消费模式。

3. Exchange 类型

   • Fanout 类型：将消息路由到所有绑定的 Queue。
   • Direct 类型：根据 binding key 和 routing key 的完全匹配进行路由。
   • Topic 类型：支持模糊匹配，将消息路由到符合规则的 Queue。

4. Vhost 虚拟主机

   • 提供虚拟主机能力，满足生产与测试环境隔离、多业务拆分等需求。

5. 运维配套

   • 提供完善的监控告警能力，支持 Prometheus 指标，涵盖实例、Vhost、Exchange、Queue 等维度。
   • 提供资源报表功能，支持设备查询、分组在线设备管理、消息收发统计等。
   • 支持 Open API（RESTful），便于自助资源管理和运维。

三、迁移上云指南

1. 迁移前评估

在迁移至云消息队列 RabbitMQ 版之前，需进行以下技术评估： - 功能差异：云消息队列 RabbitMQ 版与开源 RabbitMQ 在功能、性能、Exchange 和 Queue 等方面存在差异，请确认是否符合您的需求。 - 限制评估：云消息队列 RabbitMQ 版对集群、接口调用和字符长度进行了限制，请确保这些限制能满足您的业务需求。

2. 网络打通

• 使用私网连接接入点，支持云企业网（CEN）上云组网。

3. 数据迁移

以 VirtualHost 为最小迁移单位，使用 Shovel 插件完成数据迁移： 1. 梳理 VirtualHost 下的所有生产者和消费者。 2. 修改 URL、用户名和密码配置，使其访问云消息队列 RabbitMQ 版服务。 3. 开启 Shovel 插件，创建临时同步任务，将堆积的消息转发至云上实例。 4. 观察队列堆积情况，确认数据迁移完成后删除临时任务。

四、操作步骤与配置

1. 创建客户端连接

（1）安装依赖库

在 Java 工程中添加以下依赖：

<dependency>
 <groupId>com.rabbitmq</groupId>
 <artifactId>amqp-client</artifactId>
 <version>5.5.0</version>
</dependency>

（2）生成用户名和密码

通过 AccessKey ID 和 AccessKey Secret 生成静态用户名和密码： 1. 登录云消息队列 RabbitMQ 版控制台，选择目标实例。 2. 在左侧导航栏选择 静态用户名密码，点击 创建用户名密码。 3. 输入 AccessKey ID 和 AccessKey Secret，生成用户名和密码。

（3）创建连接工厂

使用 ConnectionFactory 启动客户端与服务端的连接：

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;

public class RabbitMQClient {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("your-rabbitmq-host");
        factory.setUsername("your-username");
        factory.setPassword("your-password");
        Connection connection = factory.newConnection();
        System.out.println("Connected to RabbitMQ!");
    }
}

五、监控与运维

1. 查看 Dashboard

前提条件： - 已创建云消息队列 RabbitMQ 版实例。 - 实例下已创建 Vhost、Queue 和 Exchange。 - 已开通 ARMS Prometheus 监控服务。

操作步骤： 1. 登录控制台，选择目标实例。 2. 在左侧导航栏点击 Dashboard。 3. 根据需要指定 Vhost、Exchange、Queue 或时间范围查看指标。

2. 获取 Metrics 指标数据

所有指标数据存储在阿里云 Prometheus 服务中，可通过以下步骤获取： 1. 登录 ARMS 控制台，搜索并接入 RabbitMQ 服务。 2. 获取 HTTP API 地址，通过 API 将指标数据接入自建 Grafana。

六、注意事项

• 续费提醒：预付费系列实例需及时续费，建议开启自动续费以避免停服。
• 弹性 TPS 功能：仅预付费系列实例支持开启弹性 TPS 功能，欠费状态下无法开启。
• 迁移风险：迁移过程中需确保数据一致性，建议在低峰期操作。

以上内容详细介绍了云消息队列 RabbitMQ 版的功能、优势、迁移步骤及操作方法，帮助您快速上手并充分利用该服务。