跳至主内容

RabbitMQ 教程 - "Hello World!"

引言

信息

先决条件​

本教程假设 RabbitMQ 已 安装 并在 localhost 上的 标准端口 (5672) 上运行。如果您使用不同的主机、端口或凭据，则需要调整连接设置。

哪里寻求帮助​

如果您在学习本教程时遇到困难，可以通过 GitHub Discussions 或 RabbitMQ 社区 Discord 联系我们。

RabbitMQ 是一个消息代理：它接收并转发消息。你可以把它想象成一个邮局：当你把想要寄出的邮件放进邮箱时，你可以确信邮递员最终会将邮件送到你的收件人手中。在这个比喻中，RabbitMQ 就是邮箱、邮局和邮递员。

RabbitMQ 和邮局的主要区别在于，它不处理纸张，而是接收、存储和转发数据的二进制数据块——消息。

RabbitMQ 和消息传递通常会使用一些行话。

  • 发布（Producing）不过就是发送。发送消息的程序就是生产者（producer）。

  • 队列 是 RabbitMQ 中邮箱的名称。虽然消息在 RabbitMQ 和你的应用程序之间流动，但它们只能存储在队列 中。队列 的大小仅受主机内存和磁盘空间的限制，它本质上是一个大的消息缓冲区。

    许多生产者 可以发送消息到同一个队列，许多消费者 可以尝试从同一个队列 接收数据。

    这就是我们表示队列的方式

  • 消费 的含义与接收类似。消费者 是一个主要等待接收消息的程序。

请注意，生产者、消费者和代理不一定需要驻留在同一台主机上；事实上，在大多数应用程序中它们都不会。一个应用程序也可以同时是生产者和消费者。

"Hello World"​

(使用 Objective-C 客户端)​

在本教程的这一部分，我们将编写一个简单的 iOS 应用。它将发送一条消息，并使用 NSLog 来接收并记录这条消息。

在下面的图表中，“P”是我们的生产者，“C”是我们的消费者。中间的框是一个队列——RabbitMQ 代表消费者存储的消息缓冲区。

Objective-C 客户端库​

RabbitMQ 支持多种协议。本教程使用 AMQP 0-9-1，这是一种开放的、通用的消息协议。RabbitMQ 有许多用 各种不同语言 编写的客户端。在本教程中，我们将使用 Objective-C 客户端。

创建包含 RabbitMQ 客户端依赖项的 Xcode 项目​

请按照以下说明创建新的 Xcode 项目。

  1. 使用 File -> New -> Project… 创建一个新的 Xcode 项目。
  2. 选择 iOS Application -> Single View Application。
  3. 点击 Next。
  4. 为您的项目命名，例如 "RabbitTutorial1"。
  5. 根据需要填写组织信息。
  6. 选择 Objective-C 作为语言。本教程不需要 Unit Tests。
  7. 点击 Next。
  8. 选择一个项目创建位置，然后点击 Create。

现在，我们必须添加 Objective-C 客户端作为依赖项。这部分需要通过命令行完成。有关详细说明，请访问 客户端的 GitHub 页面。

将客户端添加为依赖项后，使用 Product -> Build 构建项目，以确保其正确链接。

发送​

为了本教程的方便，我们将发送和接收代码放在同一个视图控制器中。发送代码将连接到 RabbitMQ 并发送一条消息。

让我们编辑 ViewController.m 并开始添加代码。

导入框架​

首先，我们将客户端框架作为模块导入。

@import RMQClient;

现在，我们在 viewDidLoad 中调用一些发送和接收方法。

- (void)viewDidLoad {
    [super viewDidLoad];
    [self send];
    [self receive];

发送方法以连接到 RabbitMQ 节点开始。

- (void)send {
    RMQConnection *conn = [[RMQConnection alloc] initWithUri:@"amqp://:5672"
                                                 delegate:[RMQConnectionDelegateLogger new]];
}

连接抽象了套接字连接，并为我们处理了协议版本协商、身份验证等。

我们必须使用 initWithUri:delegate: 便利初始化器指定其名称或 IP 地址。

RMQConnection *conn = [[RMQConnection alloc] initWithUri:@"amqp://:5672"
                                             delegate:[RMQConnectionDelegateLogger new]];

接下来，我们创建一个通道，这是完成大部分操作的 API 所在。

id<RMQChannel> ch = [conn createChannel];

为了发送，我们必须声明一个要发送到的队列；然后我们可以将消息发布到该队列。

RMQQueue *q = [ch queue:@"hello"];
[ch.defaultExchange publish:[@"Hello World!" dataUsingEncoding:NSUTF8StringEncoding] routingKey:q.name];

声明一个队列是幂等的——如果它不存在，则仅创建一次。

最后，我们关闭连接。

[conn close];

这是整个控制器（包括接收部分）。.

发送不起作用！​

如果这是您第一次使用 RabbitMQ，但没有看到“Sent”消息，您可能会感到困惑，不知道哪里出了问题。也许代理启动时磁盘空间不足（默认需要至少 50 MB 可用空间），因此拒绝接收消息。检查代理的日志文件，看看是否有资源警报已记录，并在必要时降低可用磁盘空间阈值。配置指南将展示如何设置 disk_free_limit。

接收​

发送部分就到这里。我们的 receive 方法将启动一个消费者，该消费者将接收来自 RabbitMQ 的消息。因此，与发送单条消息的 send 不同，它将等待一条消息，记录它，然后退出。

设置与 send 相同；我们打开一个连接和一个通道，并声明我们将从中消费的队列。请注意，这与 send 发布消息的队列匹配。

- (void)receive {
    NSLog(@"Attempting to connect to local RabbitMQ broker");
    RMQConnection *conn = [[RMQConnection alloc] initWithDelegate:[RMQConnectionDelegateLogger new]];
    [conn start];

    id<RMQChannel> ch = [conn createChannel];

    RMQQueue *q = [ch queue:@"hello"];

请注意，我们在这里也声明了队列。因为我们可能在发送方之前启动接收方，所以我们希望在尝试从队列中消费消息之前确保队列存在。

我们将指示服务器将队列中的消息传递给我们。由于它会异步地将消息推给我们，因此我们提供了一个回调，当 RabbitMQ 将消息推送到我们的消费者时，该回调将被执行。这正是 RMQQueue subscribe: 的作用。

NSLog(@"Waiting for messages.");
[q subscribe:^(RMQMessage * _Nonnull message) {
    NSLog(@"Received %@", [[NSString alloc] initWithData:message.body encoding:NSUTF8StringEncoding]);
}];

这是完整的控制器（包括发送部分）。.

运行​

现在我们可以运行应用程序了。点击大播放按钮，或者按 cmd-R。

receive 将通过 RabbitMQ 记录它从 send 收到的消息。接收器将继续运行，等待消息（使用停止按钮停止它），因此您可以使用另一个客户端尝试向同一队列发送消息。

如果你想检查队列，可以尝试使用 rabbitmqctl list_queues。

Hello World!

是时候继续进行 第二部分，构建一个简单的工作队列。

© . This site is unofficial and not affiliated with VMware.