RabbitMQ 教程 - "Hello World!"

简介

信息

先决条件

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

哪里寻求帮助

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

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

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

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

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

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

这就是我们表示队列的方式
消费的含义与接收类似。消费者 是一个主要等待接收消息的程序。

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

"Hello World"

(使用 BunnySwift)

在本教程的这一部分，我们将用 Swift 编写两个小程序：一个发送单条消息的生产者，以及一个接收并打印消息的消费者。我们将略过 BunnySwift API 的一些细节，重点关注这个非常简单的操作以快速上手。这就是消息传递领域的“Hello World”。

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

BunnySwift 客户端库

RabbitMQ 支持多种协议。本教程使用 AMQP 0-9-1，这是一种开放的通用消息传递协议。RabbitMQ 在多种不同语言中都有对应的客户端。在本教程中，我们将使用 BunnySwift，这是一个利用 Swift 并发特性（async/await）的现代 Swift 客户端。

设置

首先，请确保您已经安装并运行了 RabbitMQ。

BunnySwift 要求 Swift 6.0 或更高版本。为您的项目创建一个新目录，并使用 Swift Package Manager 进行初始化

mkdir rabbitmq-swift-tutorial
cd rabbitmq-swift-tutorial
swift package init --type executable --name Send

编辑 Package.swift 以添加 BunnySwift 依赖

// swift-tools-version: 6.0
import PackageDescription

let package = Package(
    name: "RabbitMQTutorials",
    platforms: [.macOS(.v14)],
    dependencies: [
        .package(url: "https://github.com/michaelklishin/bunny-swift", from: "0.13.0")
    ],
    targets: [
        .executableTarget(
            name: "Send",
            dependencies: [.product(name: "BunnySwift", package: "bunny-swift")]
        ),
        .executableTarget(
            name: "Receive",
            dependencies: [.product(name: "BunnySwift", package: "bunny-swift")]
        )
    ]
)

创建源代码目录

mkdir -p Sources/Send Sources/Receive

现在我们已经设置好了使用 BunnySwift 依赖的 Swift Package Manager。

发送

我们将把消息发布者（发送方）命名为 Send，将消息接收者（接收方）命名为 Receive。发布者将连接到 RabbitMQ，发送一条消息，然后退出。

在 Sources/Send/main.swift 中，我们需要首先导入该库

import BunnySwift
import Foundation

然后，我们可以创建一个到服务器的连接

@main
struct Send {
    static func main() async throws {
        let connection = try await Connection.open()

连接（Connection）抽象了套接字连接，并为我们处理协议版本协商、身份验证等工作。在这里，我们使用所有默认设置连接到本地机器上的 RabbitMQ 节点。

如果我们想连接到不同机器上的节点或配置其他连接参数，我们将使用

let connection = try await Connection.open(
    host: "some-host.example.com",
    port: 5672,
    username: "guest",
    password: "guest"
)

或者指定一个 URI

let connection = try await Connection.open(uri: "amqp://user:password@host:5672/vhost")

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

        let channel = try await connection.openChannel()

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

        let queue = try await channel.queue("hello", type: .quorum, durable: true)

        try await channel.basicPublish(
            body: Data("Hello World!".utf8),
            routingKey: queue.name
        )
        print(" [x] Sent 'Hello World!'")

声明队列是幂等的——只有在队列不存在时才会创建。消息内容是字节数组，因此您可以对其进行任意编码。

最后，我们关闭连接。

        try await connection.close()
    }
}

这是完整的 Send.swift 文件.

发送不起作用！

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

接收

我们的发布者就到这里了。我们的消费者会监听来自 RabbitMQ 的消息，所以与只发布一条消息的发布者不同，我们将保持消费者的运行状态，监听并打印消息。

Sources/Receive/main.swift 中的代码具有与 Send 相同的导入

import BunnySwift

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

@main
struct Receive {
    static func main() async throws {
        let connection = try await Connection.open()
        let channel = try await connection.openChannel()
        let queue = try await channel.queue("hello", type: .quorum, durable: true)

请注意，我们也在这里声明了队列。因为我们可能在发布者之前启动消费者，所以要确保在尝试从队列消费消息之前该队列已经存在。

我们将通知服务器从队列中向我们投递消息。BunnySwift 返回一个消费者，我们可以使用 Swift 的并发特性对其进行迭代。我们调用 basicConsume 并遍历消息

        print(" [*] Waiting for messages. To exit press CTRL+C")

        let consumer = try await channel.basicConsume(
            queue: queue.name,
            acknowledgementMode: .automatic
        )
        for try await message in consumer {
            print(" [x] Received '\(message.bodyString ?? "")'")
        }
    }
}

消费者将继续运行，等待消息。使用 Ctrl-C 停止它。

这是完整的 Receive.swift 文件.

总而言之

构建这两个程序

swift build

在一个终端中，运行消费者

swift run Receive
# => [*] Waiting for messages. To exit press CTRL+C

然后，在另一个终端中，运行发布者

swift run Send
# => [x] Sent 'Hello World!'

消费者将打印出它通过 RabbitMQ 从发布者那里收到的消息。

# => [x] Received 'Hello World!'

消费者将保持运行，等待消息，所以请尝试在另一个终端中再次运行发布者。

恭喜！您已经能够通过 RabbitMQ 发送和接收消息了。

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

现在是时候进入第 2 部分并构建一个简单的 工作队列（work queue） 了。

简介​

先决条件​

哪里寻求帮助​

"Hello World"​

(使用 BunnySwift)​

BunnySwift 客户端库​

设置​

发送​

发送不起作用！​

接收​

总而言之​

简介

先决条件

哪里寻求帮助

"Hello World"

(使用 BunnySwift)

BunnySwift 客户端库

设置

发送

发送不起作用！

接收

总而言之