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

在錯綜複雜的 .NET 開發世界中，管理服務之間的異步通信是構建健壯且可擴展應用程式的一個關鍵方面。介紹 瑞巴斯 .NET，一個強大的庫，可以簡化 .NET 生態系統內的基於消息的通信和路由。讓我們來探索 Rebus 如何使開發人員能夠充分利用服務總線和排隊服務調用機制，使用提供的關鍵字。

開發人員可以將 Rebus .NET 與生成 PDF 文件的功能相結合，構建複雜的分佈式系統，作為其消息操作的一部分。 IronPDF例如，使用Rebus構建的系統可能會收到生成PDF文件的請求，使用Rebus處理程序處理該請求，然後使用IronPDF生成文件並回覆。

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

Rebus 是什麼？

分散式系統的核心需求是高效的訊息路由和處理。 瑞巴斯其直觀的API和全面的功能，Rebus成為分散式應用程式中不同組件之間的橋樑。無論是協調微服務之間的通訊，還是管理異步任務，Rebus皆可提供必要的工具來簡化訊息處理和傳遞。

服務匯流排和訊息路由

使用 Rebus，基於預定義條件路由訊息變得輕而易舉。開發者可以利用 Rebus 的路由功能將訊息導向特定的處理器或佇列，確保每個訊息有效到達其預期的目的地。通過使用 Rebus 的擴展方法定義路由規則，開發者可以根據其應用架構的獨特需求自定義訊息流程。

多功能消息模式

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

非同步訊息

Rebus.NET 使分散式系統的元件能夠相互通信而不需等待回應或互相阻塞。這種非同步通信提高了系統的敏捷性和可擴展性。

分散式架構

Rebus.NET 擁有開發分散式系統的目標，其中使用多個進程或網絡作為元件之間通信的方式。它提供了處理消息序列化和反序列化的功能，保持消息傳遞的可靠性，並管理消息隊列。

可擴展性

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

錯誤處理和重試技術

Rebus.NET 內建了重試和錯誤處理技術，即使在出現短暫中斷或網絡問題時，也能確保訊息的一致處理。開發人員可以設定重試策略和錯誤處理技術，以滿足應用程序的韌性需求。

訊息加密與安全性

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

非同步訊息處理

非同步訊息處理是 Rebus 的核心功能之一。通過使用 await bus 模式，開發人員可以讓應用程式代碼等待訊息的到來，並非同步地執行相應的訊息處理程式。這允許非阻塞訊息處理，確保即使在高負載下，應用程式也能保持響應和可擴展性。

故障容忍和失敗訊息管理

在分布式系統中，故障是不可避免的。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有多種方式，包括 將 HTML 頁面轉換為 PDF 插入文本、圖片和形狀到已存在的文件中。更好的是，您可以創建新的 PDF 文件使用 HTML 文本 應用程式代碼、圖片或未處理的數據。

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

IronPDF 的優點

一些 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 現在可以整合以支援和管理 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 的樣式和佈局。

總而言之，通過結合以上技術，開發人員可以創建具備豐富功能、可擴展且可靠的分佈式系統，並集成文件生成功能。 瑞巴斯 和 IronPDFRebus 和 IronPDF 提供了一個強大的基礎，用於開發尖端的 .NET 應用程式和服務，這些應用程式和服務可讓消費者受益，無論是即時文件、報告還是發票生成服務。

IronPDF 也提供詳細的 文檔 由於它的眾多功能，以及多個 程式碼範例IronPDF附帶一個價格實惠的終身許可證包。整套價格非常優惠，只需749美元即可適用於各種系統。對於持有許可證的用戶，IronPDF提供全天候的線上工程支援。此外，它還提供 免費試用 如需有關價格的更多資訊，請造訪此 網站 如需瞭解有關Iron Software產品的更多信息。