Rebus .NET Core 示例（開發人員使用方式）

在.NET開發的複雜世界中，管理服務之間的非同步通訊是建立健全且可擴展應用程式的關鍵方面。 輸入瑞巴斯.NET，一個強大的函式庫，簡化了 .NET 生態系統中的消息傳遞和路由。 讓我們探討 Rebus 如何使開發人員能夠利用服務匯流排和排隊服務調用機制的全部潛力，使用所提供的關鍵字。

開發人員可以通過結合 Rebus .NET，建立能夠在消息傳遞操作中生成 PDF 文檔的複雜分佈式系統。IronPDF 生成 PDF 的功能. 例如，使用 Rebus 構建的系統可能會收到產生 PDF 文件的請求，由 Rebus 處理程序處理，然後使用 IronPDF 生成文件並回覆。

開發人員可以使用 Rebus 和 IronPDF 創建功能豐富、可擴展且可靠的分佈式應用程序，這些應用程序可以輕鬆集成到消息傳遞工作流程中以生成 PDF。 這種整合為開發各種應用程式（例如報告工具和文件管理系統）提供了堅實的基礎。

什麼是 Rebus？

分佈式系統的核心在於有效的消息路由及處理需求。 Rebus 概覽與資源，憑藉其直觀的API和全面的功能，作為分散式應用程式不同組件之間的橋樑。 無論是協調微服務之間的通信，還是管理非同步任務，Rebus 都提供了必要的工具來簡化消息處理和傳遞。

服務總線與消息路由

使用 Rebus，根據預定義標準路由消息變得輕而易舉。 開發者可以利用 Rebus 的路由功能將消息定向到特定的處理程序或佇列，確保每條消息都能高效地到達其預定目的地。 通過使用 Rebus 的擴展方法定義路由規則，開發人員可以根據其應用程式架構的獨特需求自訂消息流。

多功能訊息模式

Rebus .NET 與多種訊息模式相容，如訊息路由、命令/查詢、請求/回應和發佈/訂閱。由於這種多功能性，開發人員可以選擇最適合其特定用例的設計。

非同步訊息傳遞

Rebus.NET 使分散式系統的元件能夠彼此通信，無需等待回應或阻塞彼此。 藉由此非同步通信，系統的響應性和可擴展性得到了提升。

分散式架構

Rebus.NET 旨在開發分散式系統，其中若干個流程或網路被用作組件之間的通信手段。 它提供了處理消息序列化和反序列化、維持消息傳遞可靠性以及管理消息隊列的功能。

可擴展性

Rebus.NET 非常可擴展，使程式設計師能夠根據需要修改和擴展其功能。 它提供與多種中介軟體平台、序列化格式和消息代理的集成點。

錯誤處理和重試技術

Rebus.NET 內建的重試和錯誤處理技術確保即使在短暫中斷或網路問題時，訊息也能一致地被處理。 開發人員可以設定重試策略和錯誤處理技術，以滿足其應用程式的復原需求。

訊息加密和安全性

Rebus.NET 透過提供訊息加密和安全功能，使開發者能夠保護在分散組件、託管環境和混合雲應用程式中傳輸的敏感資料。 它通過輕鬆整合加密庫和協議，為混合雲應用程式保證安全的通信渠道。

非同步訊息處理

處理非同步消息處理是 Rebus 的核心功能。 通過使用 await 緩衝模式，開發人員可以讓應用程式代碼等待消息的到達，並異步執行相應的消息處理程式。 這允許非阻塞的消息處理，確保應用程序在高負載下仍然保持響應和可擴展性。

容錯和失敗消息管理

在分布式系統中，故障是不可避免的。 Rebus 為開發人員提供機制，以優雅地管理和處理失敗的消息。 通過配置錯誤日誌記錄和重試策略，開發人員可以定義 Rebus 如何處理失敗的消息，無論是重試錯誤消息的傳送、將消息移至死信佇列，還是記錄錯誤以進一步記錄和分析。

建立和配置 Rebus

與 .NET Core 整合

Rebus 完全兼容 .NET Core，是現代跨平台應用程式的理想選擇。 無論您是在構建微服務、無伺服器功能、混合雲應用程式還是本地應用程式，Rebus 都在 .NET Core 生態系統中為非同步通信和訊息處理提供堅實的基礎。

配置消息處理器

要處理接收到的訊息，則必須創建消息處理類。 所有消息處理程序類別都應實作IHandleMessages介面，其中MyMessage是處理器類別將處理的消息類型。

public class MyMessageHandler : IHandleMessages<MyMessage>
{
    public async Task Handle(MyMessage message)
    {
        // Process the incoming message here
    }
}

public class MyMessageHandler : IHandleMessages<MyMessage>
{
    public async Task Handle(MyMessage message)
    {
        // Process the incoming message here
    }
}

Public Class MyMessageHandler
	Implements IHandleMessages(Of MyMessage)

	Public Async Function Handle(ByVal message As MyMessage) As Task
		' Process the incoming message here
	End Function
End Class

配置訊息傳輸

為了傳送和接收訊息，Rebus 還必須配置訊息傳輸機制。 Rebus 相容於多種傳輸替代方案，例如用於測試的內存傳輸、Azure Service Bus、RabbitMQ 和 SQL Server。 使用此技術不僅限於特定的佇列技術。 它可以移至任何主機環境。

例如，將 RabbitMQ 作為消息傳輸工具使用：

var services = new ServiceCollection();
//service bus
services.AddRebus(configure => configure
    .Transport(t => t.UseRabbitMq("amqp://guest:guest@localhost", "my-queue"))
    .Routing(r => r.TypeBased().Map<MyMessage>("my-queue")));

var services = new ServiceCollection();
//service bus
services.AddRebus(configure => configure
    .Transport(t => t.UseRabbitMq("amqp://guest:guest@localhost", "my-queue"))
    .Routing(r => r.TypeBased().Map<MyMessage>("my-queue")));

Dim services = New ServiceCollection()
'service bus
services.AddRebus(Function(configure) configure.Transport(Function(t) t.UseRabbitMq("amqp://guest:guest@localhost", "my-queue")).Routing(Function(r) r.TypeBased().Map(Of MyMessage)("my-queue")))

初始化 Rebus

最後，您必須開始消息處理循環過程，並使用配置的服務初始化 Rebus。

var serviceProvider = services.BuildServiceProvider();
var bus = serviceProvider.GetRequiredService<IBus>();
await bus.Start();

var serviceProvider = services.BuildServiceProvider();
var bus = serviceProvider.GetRequiredService<IBus>();
await bus.Start();

Dim serviceProvider = services.BuildServiceProvider()
Dim bus = serviceProvider.GetRequiredService(Of IBus)()
Await bus.Start()

其他設定

重試策略：通過在配置中包括重試選項，您可以設置 Rebus 以在失敗時重試消息處理。

併發控制：透過調整工作執行緒或處理器的數量，Rebus 使您能夠調節訊息處理的併發性。

消息序列化：Rebus 能夠將消息序列化為多種格式，包括 JSON、XML 和 Protobuf。 序列化設定是可配置的，以適應您的應用程式代碼和需求。

入門

什麼是 IronPDF？

一個受歡迎的 .NET 庫，可以讓我們在程式中創建、修改和呈現 PDF 文件，叫做IronPDF. 處理PDF檔可以有多種方式，包括使用 IronPDF 將 HTML 頁面轉換為 PDF 的範例，並在已存在的檔案中插入文字、圖片和形狀。更好的是，您可以創建新的使用IronPDF的HTML來製作PDF文件應用程式代碼、影像或未處理的數據。

IronPDF 的易用性是其主要優勢之一。 由於其用戶友好的 API 和豐富的文檔，開發人員可以快速開始從其 .NET 應用程式中生成 PDF。IronPDF 的效率和速度是幫助開發人員快速創建高品質 PDF 文件的另外兩個特點。

IronPDF 的優勢

一些優點IronPDF 功能

• 從 HTML、圖片和未加工數據創建 PDF。
• 從 PDF 文件中移除文字和圖像。
• 將浮水印、頁首和頁尾添加到 PDF 文件中。
• 密碼和加密用於保護 PDF 文件。
• 以電子方式完成和簽署文件的能力。

安裝庫

您必須先設定 Rebus 以進行消息傳遞，並設定 IronPDF 以生成 PDF，才能在 .NET 應用程式中使用它們。 詳細操作指南：

Install-Package Rebus
Install-Package Rebus.ServiceProvider
Install-Package IronPdf

Install-Package Rebus
Install-Package Rebus.ServiceProvider
Install-Package IronPdf

'INSTANT VB TODO TASK: The following line uses invalid syntax:
'Install-Package Rebus Install-Package Rebus.ServiceProvider Install-Package IronPdf

將您的應用程式配置為處理 Rebus 的消息傳遞。 若要發送和接收訊息，請使用訊息傳輸機制配置 Rebus。(如 RabbitMQ 或 Azure Service Bus). 此服務可以管理失敗的訊息。

下面是一個簡單的例子，其中訊息傳輸的隊列名稱是RabbitMQ 概述:

// create service broker config
var services = new ServiceCollection();
// adding extension method to service
services.AddRebus(configure => configure
    .Transport(t => t.UseRabbitMq("amqp://guest:guest@localhost", "my-queue"))
    .Routing(r => r.TypeBased().Map<MyMessage>("my-queue")));
var serviceProvider = services.BuildServiceProvider();
var bus = serviceProvider.GetRequiredService<IBus>();
await bus.Start();

// create service broker config
var services = new ServiceCollection();
// adding extension method to service
services.AddRebus(configure => configure
    .Transport(t => t.UseRabbitMq("amqp://guest:guest@localhost", "my-queue"))
    .Routing(r => r.TypeBased().Map<MyMessage>("my-queue")));
var serviceProvider = services.BuildServiceProvider();
var bus = serviceProvider.GetRequiredService<IBus>();
await bus.Start();

' create service broker config
Dim services = New ServiceCollection()
' adding extension method to service
services.AddRebus(Function(configure) configure.Transport(Function(t) t.UseRabbitMq("amqp://guest:guest@localhost", "my-queue")).Routing(Function(r) r.TypeBased().Map(Of MyMessage)("my-queue")))
Dim serviceProvider = services.BuildServiceProvider()
Dim bus = serviceProvider.GetRequiredService(Of IBus)()
Await bus.Start()

Rebus 和 IronPDF 現在可以整合以支援和管理使用 IronPDF 創建 PDF作為消息傳遞工作流程的一部分的工作。 對於一個 Rebus 實例，您可以使用 Rebus 設計消息處理器，當接收到某條消息時，生成 PDF。

public class GeneratePdfMessageHandler : IHandleMessages<GeneratePdfMessage>
{
    public async Task Handle(GeneratePdfMessage message)
    {
        var Renderer = new IronPdf.ChromePdfRenderer();
        var PDF = Renderer.RenderHtmlAsPdf(message.HtmlContent);
        PDF.SaveAs(message.OutputPath);
    }
}

public class GeneratePdfMessageHandler : IHandleMessages<GeneratePdfMessage>
{
    public async Task Handle(GeneratePdfMessage message)
    {
        var Renderer = new IronPdf.ChromePdfRenderer();
        var PDF = Renderer.RenderHtmlAsPdf(message.HtmlContent);
        PDF.SaveAs(message.OutputPath);
    }
}

Public Class GeneratePdfMessageHandler
	Implements IHandleMessages(Of GeneratePdfMessage)

	Public Async Function Handle(ByVal message As GeneratePdfMessage) As Task
		Dim Renderer = New IronPdf.ChromePdfRenderer()
		Dim PDF = Renderer.RenderHtmlAsPdf(message.HtmlContent)
		PDF.SaveAs(message.OutputPath)
	End Function
End Class

最後，您可以通過向 Rebus 發送訊息來啟動 PDF 創建任務。 例如：

var message = new GeneratePdfMessage
{
    HtmlContent = "<h1>Hello, IronPDF!</h1>",
    OutputPath = "Sample.pdf"
};
await bus.Send(message);

var message = new GeneratePdfMessage
{
    HtmlContent = "<h1>Hello, IronPDF!</h1>",
    OutputPath = "Sample.pdf"
};
await bus.Send(message);

Dim message = New GeneratePdfMessage With {
	.HtmlContent = "<h1>Hello, IronPDF!</h1>",
	.OutputPath = "Sample.pdf"
}
Await bus.Send(message)

輸出

以下是上述源代碼的輸出結果。

結論

最後，隨著的結合，開發人員現在擁有了一個強大的工具箱，用於在 .NET 應用程式中創建具有整合文件生成的分散式系統。瑞巴斯和IronPDF 功能和特性.

開發人員可以利用 Rebus 堅固且可擴展的消息架構，設計多樣化的消息模式並協調各種分佈式系統元件之間的溝通。 相反地，IronPDF 為 .NET 應用程式提供完整的 PDF 生成解決方案。開發人員可以使用 IronPDF 從 HTML 內容、照片或未處理數據創建具有專業外觀的 PDF 文件，並且他們可以根據自己的需求調整 PDF 的樣式和布局。

總而言之，開發人員可以通過整合來創建具有文件生成功能的功能豐富、可擴展且可靠的分佈式系統。瑞巴斯和IronPDF 解決方案. Rebus 和 IronPDF 提供了一個強大的基礎，用於開發尖端的 .NET 應用程式和服務，無論是用於即時文件、報告或發票生成服務，都能為消費者帶來益處。

IronPDF 也提供詳細的IronPDF 功能文件由於它的眾多功能，以及多個詳細的程式碼範例.

IronPDF 隨附優惠的終身許可證，包括在套件中。 這個方案優惠價僅需 $749，即可用於多種系統。 對授權持有者，提供全天候線上技術支援。 它還提供一個IronPDF 免費試用有關價格的更多資訊。 訪問此頁面Iron Software 網站如需瞭解有關Iron Software產品的更多信息。