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

關鍵概念

1. 生產者： 負責將訊息發送到RabbitMQ交換器的組件。
2. 交換器： 一種路由機制，決定訊息應如何分配到佇列。 常見類型包括direct、fanout、topic和headers。
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" };

上述程式碼片段創建了一個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();

通過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);

程式碼宣告了一個名為"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);

準備了一個簡單的訊息"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);

使用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}");

在控制台窗口中打印出一條訊息，表明訊息已被發送。

等待使用者輸入

// 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");

欲知更多使用IronPDF進行與C#有關的PDF功能，請訪問此IronPDF程式碼範例頁面。