RabbitMQ C#（對於開發者的運行原理）

主要概念

1.生產者：負責將消息傳送至 RabbitMQ 交換中心的元件。 2.交換：一種路由機制，用來決定訊息應如何分配到佇列。 常見的類型包括直接、扇出、主題和標題。 3.Queue： 緩衝區，用來儲存生產者傳送的訊息，直到它們被消費者使用為止。 4.消費者：負責從 RabbitMQ 佇列接收和處理訊息的元件。 5.綁定：定義交換和佇列之間的關係，指定訊息應該如何路由。

RabbitMQ .NET 用戶端安裝。

透過 NuGet Package Manager Console 安裝 RabbitMQ Client 函式庫：

Install-Package RabbitMQ.Client

或者您可以使用 NuGet Package Manager for Solutions 瀏覽並安裝 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 - 佇列無法在 broker 重新啟動時存活。
• 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 創建 使用 IronPDF 從 HTML 創建 PDF 簡單直接。 以下是一個基本 HTML String 轉 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 程式碼範例 頁面。