Azure.Messaging.ServiceBus範例C#（工作原理）

理解 Azure Service Bus

Azure Service Bus 是一個完全託管的企業集成消息代理，能夠促進應用程式和服務之間的可靠通信，無論它們運行於雲端、內部部署還是混合環境。

它提供靈活的消息功能，包括排隊和發布/訂閱機制，以實現分散系統組件之間無縫的通信。 此外，它允許批量消息，這使得多個消息不會超過總大小限制。

Azure Service Bus 提供以下好處：

1. 應用程式解耦：Service Bus 允許您將應用程式和服務彼此分離。 這種解耦增強了可靠性和可擴展性。
2. 負載均衡：它在競爭的工作者之間分配工作，確保資源的高效利用。
3. 消息傳輸：數據通過消息在應用程式和服務之間傳輸。 這些消息的消息體可以包含各種類型的數據，例如 JSON 、XML 或純文本。
4. 消息場景：常見的場景包括業務數據傳輸（如銷售訂單）、負載平衡，以及通過主題和訂閱使發布者和訂閱者之間的關係生效。
5. 交易：Service Bus 支持原子交易，允許在單個交易範圍內進行多個操作。 一個交易可以有多個並發調用，而消息批次會有單個調用。
6. 消息會話：它促進工作流程的高規模協調和有序消息傳輸。

關鍵功能和能力

1. 隊列和主題：Azure Service Bus 提供隊列和主題作為通信通道。 隊列支持點對點通信，確保每條消息僅由一個接收者處理，這使得它非常適合工作負載分配和負載均衡場景。 另一方面，主題支持發布/訂閱消息模式，允許多個訂閱者獨立接收相關消息，並促進可擴展的事件驅動架構。

2. 可靠的消息傳遞：使用 Azure Service Bus，消息傳遞本質上是可靠的。 它確保消息持久性，可以配置消息和錯誤處理程序，支持容錯和至少一次的傳遞語義，從而最大限度地降低數據丟失或重複的風險。 此外，它支持交易，允許在多個消息之間進行原子操作，從而確保數據完整性。

3. 死信和重試策略：為了有效地處理錯誤消息，Azure Service Bus 提供了死信功能，允許問題消息自動移動到單獨的隊列進行分析和故障排除。 此外，它提供靈活的重試策略，使開發人員能夠配置自動重試和指數退避策略，提高應用程式在面對瞬時失敗時的彈性。

4. 分區和擴展：Azure Service Bus 支持消息實體的分區，將工作負載分佈在多個節點上，確保水平擴展和高吞吐量。 這種能力對於處理大量消息和適應波動的工作量至關重要，同時不影響性能或可靠性。

5. 與 Azure 生態系統的集成：Azure Service Bus 與其他 Azure 服務（如 Azure Functions、Logic Apps、Event Grid 和 Azure Kubernetes Service (AKS)）無縫集成，為開發人員提供了簡便的端到端解決方案。 無論是響應輸入消息觸發無服務器功能，還是使用 Logic Apps 編排複雜的工作流程，Azure Service Bus 作為構建可靠的事件驅動架構的核心軸心。

IronPDF 简介

IronPDF 是一個強大的 C# PDF 庫，允許您在 .NET 專案中生成、編輯和提取 PDF 文件的內容。 以下是一些關鍵功能：

1. HTML 到 PDF 轉換：

   • 將 HTML 、CSS 和 JavaScript 內容轉換為 PDF 格式。

   • 使用 Chrome 渲染引擎生成像素完美的 PDF。

   • 從 URL 、HTML 文件或 HTML 字串生成 PDF。

2. 圖像和內容轉換：

   • 將圖像轉換為 PDF，反之亦然。

   • 從現有的 PDF 中提取文本和圖像。

   • 支持多種圖像格式。

3. 編輯和操縱：

   • 設置 PDF 的屬性、安全和許可權。

   • 添加數位簽名。

   • 編輯元數據和修訂歷史。

4. 跨平台支持：

   • 支持 .NET Core（8、7、6、5 和 3.1+）、.NET Standard（2.0+）和 .NET Framework（4.6.2+）。

   • 與 Windows、Linux 和 macOS 相容。

   • 在 NuGet 上可用以便於安裝。

使用 IronPDF 和 Azure.Messaging.ServiceBus 生成 PDF 文件

首先，使用 Visual Studio 創建控制台應用程式，如下所示。

提供專案名稱

提供 .NET 版本

安裝 IronPDF 包。

在 Azure 門戶中創建 Service Bus 隊列

要在您的 Service Bus 命名空間中設置一個隊列，請按照以下步驟操作：

1. 導航到隊列：前往 Azure 門戶中的 Service Bus 命名空間頁面。 從左側導航菜單中選擇"隊列"。
2. 創建新隊列：在隊列頁面上，點擊工具欄上的"+ 隊列"按鈕。

3. 配置隊列：在提供的字段中輸入隊列的名稱。 其他設置保持默認值。 創建 Azure Service Bus 隊列時需要配置的選項：

   1. 名稱：這是隊列的唯一標識符。 選擇一個描述性且易於記住的名稱。

   2. 最大隊列大小：這定義了隊列的最大存儲容量。 您可以將其設置為 1 GB、2 GB、5 GB、10 GB、20 GB、40 GB、80 GB 或 100 GB。 對於您的情況，它設置為 1 GB。

   3. 最大交付次數：這指定一條消息可以被交付的最大次數，然後才將其發送到死信隊列或丟棄。 這樣有助於處理消息處理的失敗。

   4. 消息生存時間（TTL）：這決定消息在到期前在隊列中保留的時間。 您可以以天、時、分和秒來設置此項。 一旦達到 TTL ，死信消息要麼被丟棄，要麼如果啟用了死信功能，將其移動到死信隊列。

   5. 鎖定持續時間：這是接收者處理消息時鎖定消息的時間。 在此期間，其他接收者不能處理同一條消息。 您可以以天、時、分和秒來設置此持續時間。

   6. 啟用消息過期死信：啟用時，過期的消息（即超過其 TTL）被移動到死信隊列而不是丟棄。 這可以對過期的消息進行進一步檢查和處理。

   7. 啟用分區：此選項啟用隊列在多個消息代理之間的分區，這有助於提高可擴展性和吞吐量。 分區對於處理大量消息非常有用。

這些設置幫助您控制 Azure Service Bus 隊列的行為和性能，確保其滿足您的應用程式要求。

4. 完成創建：點擊"創建"按鈕以最終完成隊列的創建。 這些步驟確保您成功地使用 Azure 門戶在您的 Service Bus 命名空間內創建了一個隊列。

安裝 Azure.Messaging.ServiceBus ，一個 Service Bus 客戶端庫，以使用連接字符串連接到 Azure 隊列。

添加以下代碼來發送消息和使用 Azure.Messaging.ServiceBus 接收消息。

using Azure.Messaging.ServiceBus;
namespace CodeSample
{
    public static class AzureServiceBusDemo
    {
        public static async Task Execute()
        {
            string connectionString = "Endpoint=sb://iron-articles.servicebus.windows.net/;SharedAccessKeyName=all;SharedAccessKey=uqQIzpuc2HxbnAb9keqTINvzfTcFbkkU0+ASbJZ/tow=;EntityPath=ironpdf";
            string queName = "ironpdf";
            Console.WriteLine("Demo IronPDF with Azure.Messaging.ServiceBus");
            Installation.EnableWebSecurity = true;

            // Instantiate Renderer
            var renderer = new ChromePdfRenderer();
            var content = "<h1>Demo IronPDF with Azure.Messaging.ServiceBus</h1>";
            content += "<h2>Send Message to Azure.Messaging.ServiceBus Queue: ironpdf</h2>";

            await using var client = new ServiceBusClient(connectionString);
            var msgText = "IronPDF is Awesome Package";
            content += $"<p>Message: {msgText}</p>";

            var tx = client.CreateSender(queName);
            await tx.SendMessageAsync(new ServiceBusMessage(msgText)); // Send message to the queue
            Console.WriteLine($"Sent Below message at: {DateTime.Now}");
            content += $"<p>Sent Below message at: {DateTime.Now}</p>";

            Console.ReadLine(); // wait for user input to read the message;

            var rx = client.CreateReceiver(queName);
            var msg = await rx.ReceiveMessageAsync(); // receive messages
            content += "<h2>Receive Message from Azure.Messaging.ServiceBus Queue: ironpdf</h2>";
            content += $"<p>Recieved Below message at: {DateTime.Now}</p>";
            Console.WriteLine($"Recieved Below message at: {DateTime.Now}");

            content += $"<p>MessageID={msg.MessageId}</p>";
            Console.WriteLine($"MessageID={msg.MessageId}");

            content += $"<p>Message Received: {msg.Body}</p>";
            Console.WriteLine($"Message Received: {msg.Body}");

            var pdf = renderer.RenderHtmlAsPdf(content);
            // Export to a file or Stream
            pdf.SaveAs("AwesomeAzureServiceBusQueueAndIronPdf.pdf");
        }
    }
}

using Azure.Messaging.ServiceBus;
namespace CodeSample
{
    public static class AzureServiceBusDemo
    {
        public static async Task Execute()
        {
            string connectionString = "Endpoint=sb://iron-articles.servicebus.windows.net/;SharedAccessKeyName=all;SharedAccessKey=uqQIzpuc2HxbnAb9keqTINvzfTcFbkkU0+ASbJZ/tow=;EntityPath=ironpdf";
            string queName = "ironpdf";
            Console.WriteLine("Demo IronPDF with Azure.Messaging.ServiceBus");
            Installation.EnableWebSecurity = true;

            // Instantiate Renderer
            var renderer = new ChromePdfRenderer();
            var content = "<h1>Demo IronPDF with Azure.Messaging.ServiceBus</h1>";
            content += "<h2>Send Message to Azure.Messaging.ServiceBus Queue: ironpdf</h2>";

            await using var client = new ServiceBusClient(connectionString);
            var msgText = "IronPDF is Awesome Package";
            content += $"<p>Message: {msgText}</p>";

            var tx = client.CreateSender(queName);
            await tx.SendMessageAsync(new ServiceBusMessage(msgText)); // Send message to the queue
            Console.WriteLine($"Sent Below message at: {DateTime.Now}");
            content += $"<p>Sent Below message at: {DateTime.Now}</p>";

            Console.ReadLine(); // wait for user input to read the message;

            var rx = client.CreateReceiver(queName);
            var msg = await rx.ReceiveMessageAsync(); // receive messages
            content += "<h2>Receive Message from Azure.Messaging.ServiceBus Queue: ironpdf</h2>";
            content += $"<p>Recieved Below message at: {DateTime.Now}</p>";
            Console.WriteLine($"Recieved Below message at: {DateTime.Now}");

            content += $"<p>MessageID={msg.MessageId}</p>";
            Console.WriteLine($"MessageID={msg.MessageId}");

            content += $"<p>Message Received: {msg.Body}</p>";
            Console.WriteLine($"Message Received: {msg.Body}");

            var pdf = renderer.RenderHtmlAsPdf(content);
            // Export to a file or Stream
            pdf.SaveAs("AwesomeAzureServiceBusQueueAndIronPdf.pdf");
        }
    }
}

Imports Azure.Messaging.ServiceBus
Namespace CodeSample
	Public Module AzureServiceBusDemo
		Public Async Function Execute() As Task
			Dim connectionString As String = "Endpoint=sb://iron-articles.servicebus.windows.net/;SharedAccessKeyName=all;SharedAccessKey=uqQIzpuc2HxbnAb9keqTINvzfTcFbkkU0+ASbJZ/tow=;EntityPath=ironpdf"
			Dim queName As String = "ironpdf"
			Console.WriteLine("Demo IronPDF with Azure.Messaging.ServiceBus")
			Installation.EnableWebSecurity = True

			' Instantiate Renderer
			Dim renderer = New ChromePdfRenderer()
			Dim content = "<h1>Demo IronPDF with Azure.Messaging.ServiceBus</h1>"
			content &= "<h2>Send Message to Azure.Messaging.ServiceBus Queue: ironpdf</h2>"

			Await var client = New ServiceBusClient(connectionString)
			Dim msgText = "IronPDF is Awesome Package"
			content &= $"<p>Message: {msgText}</p>"

			Dim tx = client.CreateSender(queName)
			Await tx.SendMessageAsync(New ServiceBusMessage(msgText)) ' Send message to the queue
			Console.WriteLine($"Sent Below message at: {DateTime.Now}")
			content &= $"<p>Sent Below message at: {DateTime.Now}</p>"

			Console.ReadLine() ' wait for user input to read the message;

			Dim rx = client.CreateReceiver(queName)
			Dim msg = Await rx.ReceiveMessageAsync() ' receive messages
			content &= "<h2>Receive Message from Azure.Messaging.ServiceBus Queue: ironpdf</h2>"
			content &= $"<p>Recieved Below message at: {DateTime.Now}</p>"
			Console.WriteLine($"Recieved Below message at: {DateTime.Now}")

			content &= $"<p>MessageID={msg.MessageId}</p>"
			Console.WriteLine($"MessageID={msg.MessageId}")

			content &= $"<p>Message Received: {msg.Body}</p>"
			Console.WriteLine($"Message Received: {msg.Body}")

			Dim pdf = renderer.RenderHtmlAsPdf(content)
			' Export to a file or Stream
			pdf.SaveAs("AwesomeAzureServiceBusQueueAndIronPdf.pdf")
		End Function
	End Module
End Namespace

IronPDF 許可證

IronPDF 套件需要許可證才能運行並生成 PDF。 在訪問套件之前，請在應用程式的開始處添加以下代碼。

IronPdf.License.LicenseKey = "IRONPDF-MYLICENSE-KEY";

IronPdf.License.LicenseKey = "IRONPDF-MYLICENSE-KEY";

IRON VB CONVERTER ERROR developers@ironsoftware.com

試用許可證可在 IronPDF 試用許可證頁面 上獲得。

結論

在由數位轉型和快速技術進步特徵化的時代，Azure Service Bus 作為企業在全球現代化旅程中的關鍵組件。通過提供可靠、可擴展和靈活的消息功能，它使開發人員能夠設計適應不斷變化的業務要求的彈性且靈活的解決方案。

無論是促進無縫整合、啟用事件驅動架構還是確保非同步通信，Azure Service Bus 在推動創新和加速數位化計劃方面發揮著變革性的作用。

隨著組織不斷採用雲原生範式和分散架構，Azure Service Bus 是微軟致力於在向雲轉型之旅中為開發人員和企業提供支持的證明。 IronPDF 簡化了 .NET 應用程式中的 PDF 生成，提供了直接從代碼創建專業級文件的靈活性和功能。