Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

RabbitMQ 教程

以下教程展示如何在 Amazon MQ 上配置和使用 RabbitMQ。要了解有关使用各种编程语言（如 Node.js、Python、.NET 等）支持的客户端库的更多信息，请参阅《RabbitMQ Getting Started Guide》中的 RabbitMQ Tutorials。

步骤 2：将基于 JVM 的应用程序连接到代理

创建 RabbitMQ 代理后，您可以将应用程序连接到该代理。以下示例演示如何使用 RabbitMQ Java 客户端库创建与您的代理的连接，创建队列并发送消息。您可以使用各种语言支持的 RabbitMQ 客户端库连接到 RabbitMQ 代理。有关支持的 RabbitMQ 客户端库的更多信息，请参阅 RabbitMQ 客户端库和开发工具。

先决条件

启用 VPC 属性

要确保您的代理可以在您的 VPC 中访问，您必须启用 enableDnsHostnames 和 enableDnsSupport VPC 属性。有关更多信息，请参阅《Amazon VPC 用户指南》中的 VPC 中的 DNS Support。

启用入站连接

添加 Java 依赖项

如果您使用 Apache Maven 进行自动构建，请将以下依赖项添加到您的 pom.xml 文件中。有关 Apache Maven 中的项目对象模型文件的更多信息，请参阅 POM 简介。

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

如果您正在使用 Gradle 进行自动构建，请声明以下依赖项。

dependencies {
    compile 'com.rabbitmq:amqp-client:5.9.0'
}

导入 Connection 和 Channel 类

RabbitMQ Java 客户端使用 com.rabbitmq.client 作为其顶级软件包，Connection 和 Channel API 类分别表示 AMQP 0-9-1 连接和通道。使用前导入 Connection 和 Channel 类，如以下示例所示。

import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;

创建 ConnectionFactory 并连接到您的代理

使用以下示例创建具有给定参数的 ConnectionFactory 类实例。使用 setHost 方法配置您之前记下的代理终端节点。对于 AMQPS 线级连接，请使用端口 5671。

ConnectionFactory factory = new ConnectionFactory();

factory.setUsername(username);
factory.setPassword(password);

//Replace the URL with your information
factory.setHost("b-c8352341-ec91-4a78-ad9c-a43f23d325bb.mq.us-west-2.amazonaws.com");
factory.setPort(5671);

// Allows client to establish a connection over TLS
factory.useSslProtocol();

// Create a connection
Connection conn = factory.newConnection();

// Create a channel
Channel channel = conn.createChannel();

向交换器发布消息

您可以使用 Channel.basicPublish 将消息发布到交换器。以下示例使用 AMQP Builder 类来构建具有内容类型 plain/text 的消息属性对象。

byte[] messageBodyBytes = "Hello, world!".getBytes();
channel.basicPublish(exchangeName, routingKey,
             new AMQP.BasicProperties.Builder()
               .contentType("text/plain")
               .userId("userId")
               .build(),
               messageBodyBytes);

订阅队列并接收消息

您可以通过使用 Consumer 接口订阅队列来接收消息。订阅后，消息将在到达时自动传递。

实现 Consumer 的最简单方法是使用子类 DefaultConsumer。DefaultConsumer 对象可以作为 basicConsume 调用的一部分传递以设置订阅，如以下示例所示。

boolean autoAck = false;
channel.basicConsume(queueName, autoAck, "myConsumerTag",
     new DefaultConsumer(channel) {
         @Override
         public void handleDelivery(String consumerTag,
                                    Envelope envelope,
                                    AMQP.BasicProperties properties,
                                    byte[] body)
             throws IOException
         {
             String routingKey = envelope.getRoutingKey();
             String contentType = properties.getContentType();
             long deliveryTag = envelope.getDeliveryTag();
             // (process the message components here ...)
             channel.basicAck(deliveryTag, false);
         }
     });

关闭连接并断开与代理的连接

要断开与您的 RabbitMQ 代理的连接，请关闭通道和连接，如下所示。

channel.close();
conn.close();

步骤 3：（可选）Connect 到 Amazon Lambda 函数

Amazon Lambda 可以连接并使用来自您的 Amazon MQ 代理的消息。当您将代理连接到 Lambda 时，可以创建事件源映射，从队列中读取消息并同步调用函数。您创建的事件源映射分批从您的代理中读取消息，并以 JSON 对象的形式将它们转换为 Lambda 负载。

有关将 Amazon MQ 连接到 Lambda、Lambda 为 Amazon MQ 事件源提供支持的选项和事件源映射错误的更多信息，请参阅《Amazon Lambda 开发人员指南》中的将 Lambda 与 Amazon MQ 结合使用。