RabbitMQ 教程 - "Hello World!"
简介
先决条件
本教程假设 RabbitMQ 已 安装 并在 localhost 上的 标准端口 (5672) 上运行。如果您使用不同的主机、端口或凭据，则需要调整连接设置。
哪里寻求帮助
如果您在学习本教程时遇到困难，可以通过 GitHub Discussions 或 RabbitMQ 社区 Discord 联系我们。
RabbitMQ 是一个消息代理：它接收并转发消息。你可以把它想象成一个邮局：当你把想要寄出的邮件放进邮箱时，你可以确信邮递员最终会将邮件送到你的收件人手中。在这个比喻中，RabbitMQ 就是邮箱、邮局和邮递员。
RabbitMQ 和邮局的主要区别在于，它不处理纸张，而是接收、存储和转发数据的二进制数据块——消息。
RabbitMQ 和消息传递通常会使用一些行话。
-
发布（Producing）不过就是发送。发送消息的程序就是生产者（producer）。
-
队列 是 RabbitMQ 中邮箱的名称。虽然消息在 RabbitMQ 和你的应用程序之间流动，但它们只能存储在队列 中。队列 的大小仅受主机内存和磁盘空间的限制，它本质上是一个大的消息缓冲区。
许多生产者 可以发送消息到同一个队列，许多消费者 可以尝试从同一个队列 接收数据。
这就是我们表示队列的方式
-
消费 的含义与接收类似。消费者 是一个主要等待接收消息的程序。
请注意，生产者、消费者和代理不一定需要驻留在同一台主机上；事实上，在大多数应用程序中它们都不会。一个应用程序也可以同时是生产者和消费者。
"Hello World"
（使用 .NET/C# 客户端）
在本教程的这一部分，我们将用 C# 编写两个程序：一个生产者发送一条消息，一个消费者接收消息并将其打印出来。我们将略过 .NET 客户端 API 的一些细节，只关注这个非常简单的入门示例。这是消息传递领域的“Hello World”。
在下面的图表中，“P”是我们的生产者，“C”是我们的消费者。中间的框是一个队列——RabbitMQ 代表消费者存储的消息缓冲区。
.NET 客户端库
RabbitMQ 支持多种协议。本教程使用 AMQP 0-9-1，这是一种开放的、通用的消息传递协议。RabbitMQ 在多种不同语言中提供了许多客户端。我们将使用 RabbitMQ 提供的 .NET 客户端。
该客户端支持.NET Core 以及 .NET Framework 4.6.2+。本教程将使用 RabbitMQ .NET 客户端 7.0 和 .NET Core，因此请确保您已安装它并在您的 PATH 中。
您也可以使用 .NET Framework 完成本教程，但设置步骤将有所不同。
RabbitMQ .NET 客户端 7 版本通过 nuget 分发。
本教程假定您在 Windows 上使用 PowerShell。在 MacOS 和 Linux 上，几乎任何 shell 都可以工作。
设置
首先，让我们验证一下您的 PATH 中是否具有 .NET Core 工具链。
dotnet --help
应该会显示帮助信息。
现在，让我们生成两个项目，一个用于发布者，一个用于消费者。
dotnet new console --name Send
mv Send/Program.cs Send/Send.cs
dotnet new console --name Receive
mv Receive/Program.cs Receive/Receive.cs
这将创建两个名为 Send 和 Receive 的新目录。
然后添加客户端依赖项。
cd Send
dotnet add package RabbitMQ.Client
cd ../Receive
dotnet add package RabbitMQ.Client
现在我们已经设置好了 .NET 项目，可以编写一些代码了。
发送
我们将消息发布者（发送者）称为 Send.cs，将消息消费者（接收者）称为 Receive.cs。发布者将连接到 RabbitMQ，发送一条消息，然后退出。
在Send.cs 中，我们需要使用一些命名空间。
loading...
然后，我们可以创建一个到服务器的连接
loading...
连接封装了套接字连接，并为我们处理了协议版本协商、身份验证等。这里我们连接到本地机器上的 RabbitMQ 节点——因此是localhost。如果我们要连接到另一台机器上的节点，只需在此处指定其主机名或 IP 地址即可。
接下来，我们创建一个通道，其中包含了大部分用于完成任务的 API。
为了发送，我们必须声明一个要发送到的队列；然后我们可以将消息发布到该队列。
loading...
声明队列是幂等的——只有在队列不存在时才会创建。消息内容是字节数组，因此您可以对其进行任意编码。
当上面的代码运行完毕后，通道和连接将被释放。这就是我们的发布者所做的。
发送不起作用！
如果这是您第一次使用 RabbitMQ，但没有看到“Sent”消息，您可能会感到困惑，不知道哪里出了问题。也许代理启动时磁盘空间不足（默认需要至少 50 MB 可用空间），因此拒绝接收消息。检查代理的日志文件，看看是否有资源警报已记录，并在必要时降低可用磁盘空间阈值。配置指南将展示如何设置
disk_free_limit。
接收
至于消费者，它会监听来自 RabbitMQ 的消息。因此，与发布一条消息的发布者不同，我们将让消费者持续运行，以监听消息并将其打印出来。
代码（在Receive.cs 中）的 using 语句与 Send 几乎相同。
loading...
设置与发布者相同：我们打开一个连接和一个通道，并声明我们将要从中消费消息的队列。请注意，这与 Send 发布消息到的队列相匹配。
loading...
请注意，我们也在这里声明了队列。因为我们可能在发布者之前启动消费者，所以我们希望在尝试从队列中消费消息之前确保队列存在。
我们即将告诉服务器向我们传递来自队列的消息。由于它将异步推送消息给我们，因此我们提供一个回调。这就是 AsyncEventingBasicConsumer.Received 事件处理程序的作用。
loading...
整合
打开两个终端。
您可以按任意顺序运行客户端，因为两者都会声明队列。我们将先运行消费者，以便您可以看到它正在等待然后接收消息。
cd Receive
dotnet run
然后运行发布者
cd Send
dotnet run
消费者将打印出它通过 RabbitMQ 从发布者那里收到的消息。消费者将继续运行，等待消息，所以尝试多次重启发布者。
是时候继续学习第 2 部分，构建一个简单的工作队列了。