RabbitMQ C#（开发人员如何使用）

关键概念

1. 生产者：负责将消息发送到 RabbitMQ 交换的组件。
2. 交换：一种路由机制，决定消息应如何分发到队列。 常见类型包括直接、扇出、主题和头部。
3. 队列：一个缓冲区，用于存储生产者发送的消息，直到它们被消费者消费。
4. 消费者：负责从 RabbitMQ 队列接收和处理消息的组件。
5. 绑定：定义交换与队列之间的关系，指定消息应如何路由。

RabbitMQ .NET 客户端安装

通过 NuGet 包管理器控制台安装 RabbitMQ 客户端库：

Install-Package RabbitMQ.Client

或者，您可以使用 NuGet 包管理器为解决方案浏览并安装 RabbitMQ.Client：

设置连接工厂

// Creates a ConnectionFactory object to configure the connection settings
var factory = new ConnectionFactory { HostName = "localhost" };

// Creates a ConnectionFactory object to configure the connection settings
var factory = new ConnectionFactory { HostName = "localhost" };

' Creates a ConnectionFactory object to configure the connection settings
Dim factory = New ConnectionFactory With {.HostName = "localhost"}

上面的代码片段创建了一个 ConnectionFactory 对象，HostName 设置为"localhost"。此对象用于配置与 RabbitMQ 服务器的连接。

创建连接和通道

// Establishes a connection to the RabbitMQ server
using var connection = factory.CreateConnection();

// Creates a channel, which is the means of communication with RabbitMQ
using var channel = connection.CreateModel();

// Establishes a connection to the RabbitMQ server
using var connection = factory.CreateConnection();

// Creates a channel, which is the means of communication with RabbitMQ
using var channel = connection.CreateModel();

' Establishes a connection to the RabbitMQ server
Dim connection = factory.CreateConnection()

' Creates a channel, which is the means of communication with RabbitMQ
Dim channel = connection.CreateModel()

使用 ConnectionFactory 的 CreateConnection 方法建立到 RabbitMQ 服务器的连接。 然后，使用连接的 CreateModel 方法创建一个通道。 通道用于应用程序与 RabbitMQ 服务器之间的通信。

声明队列

队列在处理大型消息缓冲区和在分布式系统中提供缓冲机制方面发挥着至关重要的作用。 以下是 QueueDeclare 方法：

// Declares a queue within the channel
channel.QueueDeclare(queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null);

// Declares a queue within the channel
channel.QueueDeclare(queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null);

' Declares a queue within the channel
channel.QueueDeclare(queue:= "hello", durable:= False, exclusive:= False, autoDelete:= False, arguments:= Nothing)

代码声明了一个名为"hello"的队列，并具有特定属性：

• durable: false - 队列将在代理重启时不存活。
• exclusive: false - 队列可以被其他连接使用。
• autoDelete: false - 当最后一个消费者取消订阅时，队列不会被删除。
• arguments: 额外的队列参数（在此情况下设置为 null）。

准备消息数据

// Prepares the message to be sent
var message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);

// Prepares the message to be sent
var message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);

' Prepares the message to be sent
Dim message = "Hello World!"
Dim body = Encoding.UTF8.GetBytes(message)

准备了一条简单消息"Hello World!"，其二进制表示（UTF-8 编码）存储在 body 变量中。

发布消息

// Publishes the message to the specified exchange and routing key
channel.BasicPublish(exchange: string.Empty, routingKey: "hello", basicProperties: null, body: body);

// Publishes the message to the specified exchange and routing key
channel.BasicPublish(exchange: string.Empty, routingKey: "hello", basicProperties: null, body: body);

' Publishes the message to the specified exchange and routing key
channel.BasicPublish(exchange:= String.Empty, routingKey:= "hello", basicProperties:= Nothing, body:= body)

BasicPublish 方法用于将消息发布到指定的交换机（"string.Empty" 表示默认交换机），并使用路由键"hello"。basicProperties 参数设置为 null，body 包含实际消息。

控制台输出

// Outputs to the console that the message has been sent
Console.WriteLine($" [x] Sent {message}");

// Outputs to the console that the message has been sent
Console.WriteLine($" [x] Sent {message}");

' Outputs to the console that the message has been sent
Console.WriteLine($" [x] Sent {message}")

在控制台窗口中打印一条消息，表明消息已发送。

等待用户输入

// Waits for user input to prevent the application from exiting immediately
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();

// Waits for user input to prevent the application from exiting immediately
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();

' Waits for user input to prevent the application from exiting immediately
Console.WriteLine(" Press [enter] to exit.")
Console.ReadLine()

应用程序等待用户按下 Enter 键后退出。 这允许消息被发布，并确保应用程序不会立即终止。

此代码设置与 RabbitMQ 服务器的连接，声明队列，准备消息，将消息发布到指定队列中，然后等待用户输入再退出。 RabbitMQ 服务器也可以以描述的方式接收消息。 在此上下文中，服务器充当消息代理。

1. 解耦微服务

RabbitMQ 促进了微服务之间的松耦合。 每个微服务都可以作为生产者或消费者，通过消息交换实现通信，而无需直接依赖。

2. 后台作业处理

使用 RabbitMQ 实现后台作业处理。 生产者将作业推送到队列，消费者（工作者）异步处理这些作业，以确保资源的高效利用。

3. 事件驱动架构

实现事件驱动的架构，其中组件通过事件进行通信。 事件被产生和消费，使系统具有动态性和响应性。

4. 应用程序扩展

RabbitMQ 通过在多个实例之间分配工作负荷来帮助水平扩展应用程序。 它确保高效利用资源并保持系统的可靠性。

从HTML生成PDF

使用 IronPDF 从 HTML 创建 PDF 是一个简单高效的过程。 以下是基本 HTML 字符串到 PDF 的示例源码：

using IronPdf;

var htmlContent = "<h1>Hello, IronPDF!</h1>";
var renderer = new ChromePdfRenderer();

// Create a PDF from an HTML string using C#
var pdf = renderer.RenderHtmlAsPdf(htmlContent);

// Export to a file or Stream
pdf.SaveAs("output.pdf");

using IronPdf;

var htmlContent = "<h1>Hello, IronPDF!</h1>";
var renderer = new ChromePdfRenderer();

// Create a PDF from an HTML string using C#
var pdf = renderer.RenderHtmlAsPdf(htmlContent);

// Export to a file or Stream
pdf.SaveAs("output.pdf");

Imports IronPdf

Private htmlContent = "<h1>Hello, IronPDF!</h1>"
Private renderer = New ChromePdfRenderer()

' Create a PDF from an HTML string using C#
Private pdf = renderer.RenderHtmlAsPdf(htmlContent)

' Export to a file or Stream
pdf.SaveAs("output.pdf")

有关使用 IronPDF 进行更多 C# PDF 相关功能，请访问此 IronPDF 代码示例 页面。