在 .NET 中实现异步消息与事件驱动时，用…

适用于 .NET 应用需要模块间通信、后台处理、事件发布/订阅，或使用 RabbitMQ/Azure Service Bus 等消息代理的场景。

适用场景

解决思路

1. 新项目优先选 Wolverine（MIT）作为默认消息框架，它同时覆盖 mediator + messaging，并内置 outbox、saga 和约定式 handler；已有 MassTransit 项目可继续用 MassTransit，但注意 v9 起生产使用需要商业许可证。
2. 始终使用事务性 outbox 模式：确保消息只在数据库事务成功提交后才发布，避免双写不一致。
3. 简单流程用事件编排（choreography）：当工作流只有 2-3 步时，通过发布/订阅事件推进。
4. 复杂流程用 saga：当需要补偿动作或复杂状态管理时，使用 Wolverine saga 或 MassTransit saga。
5. 消息即契约：把消息类型放在共享 contracts 项目中，保持为简单 record，并只使用基元类型。
6. 在 Program.cs 中用 builder.Host.UseWolverine(opts => { ... }) 配置 Wolverine，并用 opts.Discovery.IncludeAssembly(typeof(Program).Assembly) 自动发现当前程序集内的 handler。
7. 在 Wolverine 中配置 RabbitMQ 传输：调用 opts.UseRabbitMq(...)，设置 rabbit.HostName（本地可用 localhost，生产从配置读取如 RabbitMq:Host），然后调用 .AutoProvision() 自动创建队列/交换机；仅在开发环境调用 .AutoPurgeOnStartup() 启动时清空队列。
8. 启用 EF Core 事务性 outbox：调用 opts.Services.AddDbContextWithWolverineIntegration<AppDbContext>(x => x.UseNpgsql(...))，并调用 opts.Policies.AutoApplyTransactions() 将 handler 包裹在数据库事务中。
9. 在 DbContext 的 OnModelCreating 中调用 modelBuilder.AddIncomingWolverineMessageTable() 和 modelBuilder.AddOutgoingWolverineMessageTable() 添加 Wolverine inbox/outbox 表。
10. 定义消息契约，例如 public record OrderCreated(Guid OrderId, string CustomerId, decimal Total, DateTimeOffset CreatedAt);，放在共享 Contracts 项目中。
11. 发布事件优先使用级联消息：让 handler 返回消息对象，例如返回 (Response, OrderCreated) 元组；Wolverine 会在 handler 完成后自动发布返回值。
12. 当发布有条件或需要发布多个事件时，使用显式发布：注入 IMessageBus bus，然后调用 await bus.PublishAsync(new OrderCreated(...))。
13. 消费事件使用 Wolverine 约定式 handler：不实现接口、不继承基类，只写公开方法 Handle、HandleAsync、Consume 或 ConsumeAsync，且消息类型作为第一个参数。
14. 约定式 handler 可按签名自动发现；例如 OrderCreatedHandler.HandleAsync(OrderCreated message, NotificationsDbContext db, ILogger logger, CancellationToken ct) 中处理消息并保存到自己的 DbContext。
15. 用事务性 outbox 保证可靠性：把 AddDbContextWithWolverineIntegration、AutoApplyTransactions 和 outbox 表配置组合使用；消息只在数据库事务提交后发送，避免 dual-write。
16. 需要状态编排时使用 Wolverine saga：继承 Saga<T>，定义 Start 和 Handle 方法，用级联消息驱动流程。
17. Saga 启动：在 Start 方法中创建状态对象并返回 (state, command)；状态会被持久化，返回的命令会被发送。
18. Saga 处理完成事件：在 Handle(PaymentCompleted message) 中更新状态、调用 MarkCompleted()，并返回后续命令如 CompleteOrder。
19. Saga 补偿：在 Handle(PaymentFailed message) 中调用 MarkCompleted() 并返回补偿命令如 CancelOrder。
20. 如果使用 MassTransit：在 AddMassTransit 中调用 x.SetKebabCaseEndpointNameFormatter()、x.AddConsumers(typeof(Program).Assembly)、x.UsingRabbitMq((context, cfg) => { cfg.Host(...); cfg.ConfigureEndpoints(context); })。
21. MassTransit 发布：调用 await publishEndpoint.Publish(new OrderCreated(...), ct)。
22. MassTransit 消费：实现 IConsumer<T>，在 Consume(ConsumeContext<OrderCreated> context) 中通过 context.Message 获取消息并处理。
23. MassTransit outbox：调用 x.AddEntityFrameworkOutbox<AppDbContext>(o => { o.UsePostgres(); o.UseBusOutbox(); })。
24. MassTransit saga：使用 MassTransitStateMachine<TState> 实现。
25. 不要在没有 outbox 的情况下先 SaveChangesAsync 再 PublishAsync；应启用 Wolverine 的 AddDbContextWithWolverineIntegration + AutoApplyTransactions 让 Wolverine 自动处理。
26. 不要在消息契约中放复杂逻辑或行为；消息应是纯数据，例如 public record OrderCreated(Guid OrderId, string CustomerId, decimal Total, DateTimeOffset CreatedAt);。
27. 不要用 fire-and-forget 发布重要事件：避免 _ = Task.Run(() => bus.PublishAsync(...))；应 await bus.PublishAsync(...)，配合 outbox 保证事务性。
28. 模块间通信：新项目选 Wolverine with events（MIT 免费）；已有 MassTransit 项目继续用 MassTransit（v9 起需商业许可证）。
29. 可靠事件发布：Wolverine 和 MassTransit 都用事务性 outbox。
30. 简单 2-3 步工作流：用事件 choreography；复杂且需要补偿：用 Wolverine saga 或 MassTransit saga。
31. 本地开发 broker：用 RabbitMQ（Docker 或 Aspire）；生产云 broker：Azure Service Bus 或 RabbitMQ。
32. 如需单个库同时做 mediator + messaging：用 Wolverine（可替代 Mediator 和 MassTransit）。

适用边界 · 注意事项

• 非 .NET 技术栈，或不引入消息代理/消息框架的项目不适用。
• 只需要简单同步方法调用、没有解耦/后台处理/可靠事件需求的场景不适用。
• MassTransit v9+ 生产环境无法接受商业许可证时，不应选 MassTransit，应改用 Wolverine（MIT）。