MassTransit for C# (.NET): 完整指南与示例

1. 什么是 MassTransit 以及为什么需要它

MassTransit 是一个强大、开源且广泛使用的库，用于在 .NET 平台上构建分布式应用程序。它提供了对各种消息代理系统（如 RabbitMQ、Azure Service Bus、Amazon SQS/SNS、ActiveMQ 和 Kafka（通过连接器））的高级抽象。MassTransit 的主要目标是简化通过异步消息进行交互的服务开发，使开发人员无需深入了解特定代理的底层细节。

为什么需要 MassTransit？在现代微服务架构中，服务之间需要可靠且异步地进行通信。与可能导致级联故障和紧耦合的直接 HTTP 调用不同，消息交换被广泛采用。MassTransit 负责处理诸如连接和通道管理、故障重试、错误处理、分布式事务（通过 Saga）、队列和主题管理、消息序列化/反序列化等复杂任务，并提供用于发送、发布和消费消息的便捷 API。

该库实现了几个关键模式：命令-查询分离（通过发送命令）、发布-订阅（通过发布事件）、请求-响应（通过异步消息实现同步通信）和 Saga 模式（用于管理长时间运行的业务流程）。因此，MassTransit 已成为在 .NET 上构建可靠、可扩展且可测试的分布式系统的事实标准。

2. 安装

MassTransit 通过 NuGet 安装。根据您使用的消息代理，您需要安装主包和特定传输的包。

基本安装（无传输）：

dotnet add package MassTransit

对于 RabbitMQ：

dotnet add package MassTransit.RabbitMQ

对于 Azure Service Bus：

dotnet add package MassTransit.Azure.ServiceBus.Core

对于 Amazon SQS：

dotnet add package MassTransit.AmazonSQS

对于 Kafka：

dotnet add package MassTransit.Kafka

3. 快速入门 — 最小工作示例

以下是一个使用 RabbitMQ 发送和接收消息的最简单示例。请确保您已启动 RabbitMQ（例如，通过 Docker：docker run -d --hostname my-rabbit --name some-rabbit -p 5672:5672 -p 15672:15672 rabbitmq:3-management）。

using System;\nusing System.Threading.Tasks;\nusing MassTransit;\n\n// 1. 定义消息契约\npublic record OrderSubmitted\n{\n    public Guid OrderId { get; init; }\n    public string CustomerName { get; init; }\n}\n\n// 2. 定义消费者\npublic class OrderSubmittedConsumer : IConsumer<OrderSubmitted>\n{\n    public async Task Consume(ConsumeContext<OrderSubmitted> context)\n    {\n        var message = context.Message;\n        Console.WriteLine($"[Consumer] 收到订单: {message.OrderId} 来自 {message.CustomerName}");\n        await Task.CompletedTask;\n    }\n}\n\n// 3. 配置并启动总线\npublic class Program\n{\n    public static async Task Main()\n    {\n        var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>\n        {\n            cfg.Host("localhost", "/", h =>\n            {\n                h.Username("guest");\n                h.Password("guest");\n            });\n\n            cfg.ReceiveEndpoint("order-queue",