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"}

上面的代碼片段創建了一個設定HostName為"localhost"的ConnectionFactory對象，這個對象被用來配置與 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")

有關在 C# 中使用 IronPDF 進行更多 PDF 相關功能，請訪問此 IronPDF 代碼範例頁面。