MassTransit ：一个开源的 .NET 事件总线框架

MassTransit ：一个开源免费的 .NET 应用程序框架

什么是 MassTransit？

MassTransit 是一个 .NET 框架，用于开发分布式应用。它简化了消息驱动的开发流程。它支持多种消息协议（如 RabbitMQ、Azure Service Bus、Kafka 等），让开发者可以专注写业务代码，不用太关心底层的消息处理。

MassTransit 从 2007 年开始开发，已成为 .NET 中构建可扩展、高可用系统的重要工具。它在金融、医疗、物流等行业有广泛使用。

主要功能

MassTransit 提供以下功能：

1. 支持多种消息中间件：比如 RabbitMQ、Azure Service Bus、Amazon SQS 和 Kafka。
2. 异步通信：原生支持异步消息处理，提升性能，降低组件依赖。
3. 发布/订阅模型：内置支持事件驱动架构。
4. 错误处理和重试机制：确保消息可靠传输。
5. 消息路由和 Saga 协调：支持复杂的消息流转和分布式事务管理。
6. 可扩展性好：支持自定义中间件，满足特殊需求。
7. Open Telemetry 集成：方便监控和调试。
8. 与 ASP.NET Core 集成：配置简单，支持依赖注入。

如何使用 MassTransit？

1. 安装包

用 NuGet 安装以下两个包

dotnet add package MassTransitdotnet add package MassTransit.RabbitMQ

2. 配置 MassTransit

在 Program.cs 或 Startup.cs 中添加如下代码

using MassTransit;var builder = WebApplication.CreateBuilder(args);builder.Services.AddMassTransit(x =>{ x.UsingRabbitMq((context, cfg) => { cfg.Host(\"localhost\", \"/\", h => { h.Username(\"guest\"); h.Password(\"guest\"); }); });});

3. 定义消息结构

创建一个类表示消息内容

namespace MyApp.Contracts{ public record OrderCreated { public string OrderId { get; init; } public string CustomerName { get; init; } public DateTime Timestamp { get; init; } }}

4. 创建消费者

实现 IConsumer 接口来处理消息

using MassTransit;namespace MyApp.Consumers{ public class OrderConsumer : IConsumer<OrderCreated> { public Task Consume(ConsumeContext<OrderCreated> context) { Console.WriteLine($\"收到订单: {context.Message.OrderId} from {context.Message.CustomerName}\"); return Task.CompletedTask; } }}

5. 注册消费者

在服务中注册消费者并配置接收端点

builder.Services.AddMassTransit(x =>{ x.AddConsumer<OrderConsumer>(); x.UsingRabbitMq((context, cfg) => { cfg.ReceiveEndpoint(\"order-created\", e => { e.ConfigureConsumer<OrderConsumer>(context); }); });});

6. 发送消息

通过 IPublishEndpoint 发送消息

await publishEndpoint.Publish(new OrderCreated{ OrderId = Guid.NewGuid().ToString(), CustomerName = \"张三\", Timestamp = DateTime.UtcNow});

常见使用场景

MassTransit 适合以下场景：

• 微服务间通信：例如订单服务和库存服务之间的数据同步。
• 事件驱动架构：比如用户注册后发送邮件或更新信息。
• 分布式事务协调：使用 Saga 管理跨服务的操作。
• 实时数据处理：如交易记录或物流状态的实时更新。

版本变化

MassTransit 早期是开源项目，使用 Apache 2.0 协议。2025 年 4 月发布的 v9 版本改为商业授权，以支持长期维护。v8 版本仍保持开源。

社区资源

MassTransit 有活跃的社区，可以通过以下方式获取帮助：

• GitHub 项目页面
• 官方文档

欢迎关注我的公众号“Net分享”，技术文章第一时间推送，随缘更新 , 分享一些你可能注意不到的细节