开发者更新

NServiceBus C#（开发者用法）

Jacob Mellor，Team Iron 的首席技术官
Jacob Mellor
Updated: 2026年4月21日

NServiceBus 是一款功能强大且适应性强的服务总线，专为 .NET Framework 设计，可简化分布式系统开发。 它提供的强大消息模式保证跨多个微服务和应用程序的可靠消息处理和传递。 NServiceBus 抽象了底层的消息架构，使开发人员能够专注于业务逻辑，而不是构建分布式系统的复杂性。

相比之下，IronPDF 是一个流行的 .NET 库，用于生成、查看和修改 PDF 文件。 它因易于使用和高效地从各种来源（如 ASPX 文件和 HTML）创建 PDF 而闻名。

通过结合使用 NServiceBus 和 IronPDF，开发人员可以构建可靠、可扩展且可维护的软件系统，这些系统可以在其业务运营中生成和管理 PDF 文档。

在本文中，我们将学习如何设置一个简单的 C# NServiceBus 项目并将其与 IronPDF 集成，以便您可以在分布式应用程序架构中构建流畅的工作流程来管理和生成 PDF 文档。 阅读此入门教程后，您应该确切地了解这两种有效技术如何合作以简化分布式环境中的 PDF 相关任务。

NServiceBus C#是什么？

NServiceBus 是一个功能强大且灵活的框架，使创建分布式系统和面向服务的 .NET 架构变得简单。 通过使用 NServiceBus，您可以轻松管理各种消息类型并确保可靠通信。 这尤其重要，特别是在网络应用程序和类似架构中，顺畅的消息路由和处理至关重要。 NServiceBus 的消息处理程序有效地处理接收消息，确保每个逻辑组件顺利互动。 NServiceBus 的重要功能如下：

NServiceBus C#（开发人员如何使用）：图1 - NServiceBus C#

NServiceBus 的特性

基于消息的通信

NServiceBus 鼓励系统中不同服务或组件之间的基于消息的通信。 通过解耦组件，这种方法创建了更易于扩展和管理的设计。

可靠的消息传递

通过自动管理重试、死信队列和其他故障容忍技术，确保可靠的消息传递。 在分布式系统中，网络中断和其他故障问题频繁发生，这种可靠性至关重要。

发布/订阅模型

NServiceBus 支持发布/订阅模式，使服务能够发布事件并让其他服务订阅这些事件。 这使得事件驱动架构成为可能，即系统中一部分的事件修改可以引发其他部分的响应。

Saga 管理

得益于其对saga的集成支持，长时间运行的业务流程可以通过NServiceBus进行管理。 Saga 使服务平台能够管理状态并在多个服务之间协调复杂操作。

扩展性和定制化

它提供了卓越的扩展性，使开发人员能够个性化消息处理、处理和传输过程。 由于其适应性，适用于多种场景。

与各种消息平台的集成

NServiceBus 可与包括 MSMQ、RabbitMQ、Azure Service Bus、Amazon SQS 等在内的多种消息系统集成。 这使开发人员能够选择最符合他们需求的通信基础设施解决方案。

Create and configure NServiceBus in C#

您首先需要设置开发环境，创建一个基本项目，并构建一个基本消息服务和场景，然后才能在 C# 项目中开始使用 NServiceBus。 以下是逐步指南，帮助您入门。

创建新的Visual Studio项目

在 Visual Studio 中，创建控制台项目的过程很简单。 在 Visual Studio 环境中使用以下简单步骤来启动控制台应用程序：

在使用之前，请确保您已在计算机上安装了Visual Studio。

启动新项目

点击文件，然后选择新建，最后选择项目。

NServiceBus C# (How It Works For Developers): Figure 2 - Click "New"

您可以从下面的项目模板列表中选择"控制台应用程序"或"控制台应用程序(.NET Core)"模板。

在"名称"字段中为您的项目提供名称。

NServiceBus C#（开发人员如何使用）：图3 - 提供项目名称和位置

为项目选择存储位置。

点击"创建"将开始控制台应用程序项目。

NServiceBus C# (How It Works For Developers): Figure 4 - Click "create"

安装 NServiceBus 包

导航到工具 > NuGet 包管理器 > 包管理器控制台以打开 NuGet 包管理器控制台。

运行以下命令以安装 NServiceBus NuGet 包。

PM > Install-Package NServiceBus

选择传输

NServiceBus 需要传输来接收和发送消息。 我们将坚持使用学习传输，因为它易于使用，并且在测试和开发中运行良好。

通过执行安装学习传输的包。

PM > Install-Package NServiceBus.RabbitMQ

配置 NServiceBus

设置终结点

在您的Program.cs文件中设置NServiceBus端点配置：

using NServiceBus;
using System;
using System.Threading.Tasks;
using Messages;

class Program
{
    static async Task Main()
    {
        Console.Title = "Sender";
        var endpointConfiguration = new EndpointConfiguration("SenderEndpoint");
        
        // Use RabbitMQ Transport
        var transport = endpointConfiguration.UseTransport<RabbitMQTransport>();
        transport.ConnectionString("host=localhost");
        
        // Set up error queue
        endpointConfiguration.SendFailedMessagesTo("error");
        
        // Set up audit queue
        endpointConfiguration.AuditProcessedMessagesTo("audit");
        
        // Start the endpoint
        var endpointInstance = await Endpoint.Start(endpointConfiguration).ConfigureAwait(false);
        Console.WriteLine("Press Enter to send a message...");
        Console.ReadLine();
        
        // Send a message
        var message = new MyMessage
        {
            Content = "Hello, NServiceBus with RabbitMQ!"
        };
        await endpointInstance.Send("ReceiverEndpoint", message).ConfigureAwait(false);
        Console.WriteLine("Message sent. Press Enter to exit...");
        Console.ReadLine();
        
        // Stop the endpoint
        await endpointInstance.Stop().ConfigureAwait(false);
    }
}

NServiceBus C#（开发人员如何使用）：图5 - 控制台输出示例

创建消息

新增一个类以表示消息。

public class MyMessage : IMessage
{
    public string Content { get; set; }
}

创建消息处理程序

新增一个类以处理消息。

using NServiceBus;
using System.Threading.Tasks;

public class MyMessageHandler : IHandleMessages<MyMessage>
{
    public Task Handle(MyMessage message, IMessageHandlerContext context)
    {
        Console.WriteLine($"Received message: {message.Content}");
        return Task.CompletedTask;
    }
}

发送消息

从终结点发送消息。 通过处理程序调整您的主要方法以传递消息。

using NServiceBus;
using System;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        Console.Title = "Receiver";
        var endpointConfiguration = new EndpointConfiguration("ReceiverEndpoint");
        
        // Serialization configuration
        endpointConfiguration.UseSerialization<NewtonsoftJsonSerializer>();
        
        // Use RabbitMQ Transport
        var transport = endpointConfiguration.UseTransport<RabbitMQTransport>();
        transport.UseConventionalRoutingTopology(QueueType.Quorum);
        transport.ConnectionString("host=localhost");
        
        // Set up error queue
        endpointConfiguration.SendFailedMessagesTo("error");
        
        // Set up audit queue
        endpointConfiguration.AuditProcessedMessagesTo("audit");
        endpointConfiguration.EnableInstallers();
        
        // Start the endpoint
        var endpointInstance = await Endpoint.Start(endpointConfiguration).ConfigureAwait(false);
        Console.WriteLine("Press Enter to exit...");
        Console.ReadLine();
        
        // Stop the endpoint
        await endpointInstance.Stop().ConfigureAwait(false);
    }
}

NServiceBus C#（开发人员如何使用）：图6 - 控制台输出示例

启动应用程序并构建项目。 控制台应显示消息"收到消息：Hello, NServiceBus!"

开始

在 C# 项目中，集成 NServiceBus 与 RabbitMQ 和 IronPDF 需要配置 NServiceBus 与 RabbitMQ 之间的消息以及使用 IronPDF 生成 PDF。 以下是详细的操作步骤，帮助您入门：

什么是IronPDF？

IronPDF 是一个 .NET 库，用于创建、读取、编辑和转换 PDF 文件。 使用它，程序员可以在 C# 或 VB.NET 应用程序中使用强大直观的工具处理 PDF 文件。 IronPDF 的特征和功能如下详细描述：

NServiceBus C#（开发人员如何使用）：图7 - IronPDF：C# PDF库首页

IronPDF的功能

从HTML生成PDF

将JavaScript、HTML和CSS转换为PDF。 支持媒体查询和响应式设计等现代网络标准。 用于使用 HTML 和 CSS 生成动态样式的 PDF 文档、发票和报告。

PDF编辑

在已存在的 PDF 中添加文本、图片和其他材料。 从 PDF 文件中提取文本和图片。 将多个 PDF 合并为一个文件。将 PDF 文件拆分为多个文档。 添加注释、页脚、页眉和水印。

PDF转换

将 Word、Excel、图片和其他文件格式转换为 PDF。 PDF到图像转换（PNG、JPEG等）。

性能和可靠性

其设计目标是在生产环境中具备高性能和可靠性。 高效处理大型文档。

IronPDF 的安装

通过打开 NuGet 包管理器控制台安装 IronPDF。

PM > Install-Package IronPdf

配置发送方与消息

Messages 是发送方和接收方都将使用的共享项目（类库）。 在 Messages 项目中定义消息类。 创建一个名为 Messages 的新类库项目，并将其添加到解决方案中。

定义消息：

在Messages项目中，创建一个名为GeneratePdfMessage.cs的新类：

using NServiceBus;

public class GeneratePdfMessage : IMessage
{
    public string Content { get; set; }
    public string OutputPath { get; set; }
}

在发送方和接收方项目中，包含对 Messages 项目的引用。

在发送方项目中设置 NServiceBus 终结点以使用 RabbitMQ 进行消息传递。

using NServiceBus;
using System;
using System.Threading.Tasks;
using Messages;

class Program
{
    static async Task Main()
    {
        Console.Title = "Sender";
        var endpointConfiguration = new EndpointConfiguration("SenderEndpoint");

        // Use RabbitMQ Transport
        var transport = endpointConfiguration.UseTransport<RabbitMQTransport>();
        transport.ConnectionString("host=localhost");

        // Set up error queue
        endpointConfiguration.SendFailedMessagesTo("error");

        // Set up audit queue
        endpointConfiguration.AuditProcessedMessagesTo("audit");
        endpointConfiguration.EnableInstallers();

        // Start the endpoint
        var endpointInstance = await Endpoint.Start(endpointConfiguration).ConfigureAwait(false);
        Console.WriteLine("Press Enter to send a message...");
        Console.ReadLine();

        // Send a message
        var message = new GeneratePdfMessage
        {
            Content = "<h1>Hello, NServiceBus with RabbitMQ and IronPDF!</h1>",
            OutputPath = "output.pdf"
        };
        await endpointInstance.Send("ReceiverEndpoint", message).ConfigureAwait(false);
        Console.WriteLine("Message sent. Press Enter to exit...");
        Console.ReadLine();

        // Stop the endpoint
        await endpointInstance.Stop().ConfigureAwait(false);
    }
}

终结点配置：通过调用 new EndpointConfiguration("SenderEndpoint") 初始化名为 "SenderEndpoint" 的终结点。

endpointConfiguration 是传输配置。 通过连接到本地 RabbitMQ 实例，方法 UseTransport() 将 NServiceBus 设置为使用 RabbitMQ 作为传输机制。

使用AuditProcessedMessagesTo("audit")分别配置发送失败消息和审核已处理消息的位置。

消息发送： endpointInstance.Send("ReceiverEndpoint", message)向"ReceiverEndpoint"发送GeneratePdfMessage。

配置接收方生成 PDF

在接收方项目中设置 NServiceBus 终结点以通过 RabbitMQ 接收消息并使用 IronPDF 生成 PDF。

using NServiceBus;
using System;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        Console.Title = "Receiver";
        var endpointConfiguration = new EndpointConfiguration("ReceiverEndpoint");
        
        // Use RabbitMQ Transport
        var transport = endpointConfiguration.UseTransport<RabbitMQTransport>();
        transport.ConnectionString("host=localhost");
        
        // Set up error queue
        endpointConfiguration.SendFailedMessagesTo("error");
        
        // Set up audit queue
        endpointConfiguration.AuditProcessedMessagesTo("audit");
        
        // Start the endpoint
        var endpointInstance = await Endpoint.Start(endpointConfiguration).ConfigureAwait(false);
        Console.WriteLine("Press Enter to exit...");
        Console.ReadLine();
        
        // Stop the endpoint
        await endpointInstance.Stop().ConfigureAwait(false);
    }
}

该设置对于 "ReceiverEndpoint" 接收终结点，类似于发送方配置。

消息处理程序

在Receiver项目中，创建一个名为GeneratePdfMessageHandler.cs的新类。

using NServiceBus;
using System;
using System.Threading.Tasks;
using Messages;
using IronPdf;

public class GeneratePdfMessageHandler : IHandleMessages<GeneratePdfMessage>
{
    public Task Handle(GeneratePdfMessage message, IMessageHandlerContext context)
    {
        Console.WriteLine($"Received message to generate PDF with content: {message.Content}");
        
        // Generate PDF
        var renderer = new HtmlToPdf();
        var pdf = renderer.RenderHtmlAsPdf(message.Content);
        pdf.SaveAs(message.OutputPath);
        Console.WriteLine($"PDF generated and saved to: {message.OutputPath}");
        
        return Task.CompletedTask;
    }
}

GeneratePdfMessage类型的消息。

NServiceBus C#（开发人员如何使用）：图8 - 控制台输出示例

处理方法： 接收到消息后，Handle函数使用IronPDF创建PDF。 消息中的HTML内容由HtmlToPdf渲染代码转换为PDF，随后保存到指定的输出路径。

NServiceBus C#（开发人员如何使用）：图9 - 使用NServiceBus与RabbitMQ结合IronPDF生成的PDF输出

结论

NServiceBus 可以与 RabbitMQ 和 IronPDF 集成在 C# 中，提供一个可扩展和稳定的解决方案，用于需要动态和可靠生成 PDF 的分布式系统。 这种组合利用了 NServiceBus 的消息处理能力，RabbitMQ 作为消息代理的可靠性和适应性，以及 IronPDF 的强大 PDF 编辑工具。 由此产生的架构可保证服务之间的解耦，实现自主管理和可伸缩。

即使在网络或应用程序故障的情况下，RabbitMQ 也确保消息的传递。 NServiceBus 使消息路由和处理更加简单，而 IronPDF 使将 HTML 文本转换为高质量 PDF 文档成为可能。 该集成不但改善了系统的可维护性和可靠性，还为开发复杂的大型应用程序提供了灵活的框架。

最后，通过将 IronPDF 和 Iron Software 加入您的 .NET 编程工具包中，您可以高效地处理条形码、生成 PDF、执行 OCR，并与 Excel 连接。 IronPDF的许可页面，从$999开始，无缝融合其特性和Iron Software官方站点灵活套件的性能、兼容性及易用性，以提供额外的网页应用及功能并更高效发展。

如果有定制项目特定需求的明确许可证选项，开发人员可以自信地选择最佳模式。 这些优势使开发人员能够有效且透明地处理各种问题。

Jacob Mellor，Team Iron 的首席技术官
Jacob Mellor
首席技术官

Jacob Mellor 是 Iron Software 的首席技术官，也是一位开创 C# PDF 技术的有远见的工程师。作为 Iron Software 核心代码库的原始开发者，他从公司成立之初就开始塑造公司的产品架构，与首席执行官 Cameron Rimington 一起将公司转变为一家拥有 50 多名员工的公司，为 NASA、特斯拉和全球政府机构提供服务。

相关文章