咨询：基于MassTransit内存版发件箱实现Azure Service Bus消息投递

核心结论 #

MassTransit的内存发件箱不需要依赖Saga/消费者，生产者端可直接启用并使用，关键是在总线配置中正确开启发件箱功能，让发送/发布操作自动利用内存暂存机制。

步骤1：配置MassTransit启用内存发件箱 #

在服务配置中，为Azure Service Bus总线全局启用内存发件箱，所有发送/发布操作都会自动使用该发件箱暂存消息：

services.AddMassTransit(x =>
{
    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("your-azure-service-bus-connection-string");
        
        // 全局启用内存发件箱，对所有发送/发布生效
        cfg.UseInMemoryOutbox(context);
    });
});

如果仅需针对特定消息类型启用发件箱，可替换为局部配置：

// 仅针对MyMessage类型的发送操作启用发件箱
cfg.Send<MyMessage>(x => x.UseInMemoryOutbox(context));

// 仅针对MyMessage类型的发布操作启用发件箱
cfg.Publish<MyMessage>(x => x.UseInMemoryOutbox(context));

步骤2：生产者端直接发送消息 #

在业务代码中，注入IPublishEndpoint或ISendEndpointProvider，正常发送/发布消息即可。当Azure Service Bus不可用时，内存发件箱会自动暂存消息，待服务恢复后自动重试发送：

public class OrderMessageProducer
{
    private readonly IPublishEndpoint _publishEndpoint;

    public OrderMessageProducer(IPublishEndpoint publishEndpoint)
    {
        _publishEndpoint = publishEndpoint;
    }

    public async Task PublishOrderCreated(Guid orderId)
    {
        var message = new OrderCreated { OrderId = orderId };
        // 发送时自动利用内存发件箱暂存
        await _publishEndpoint.Publish(message);
    }
}

关键注意事项 #

• 内存局限性：内存发件箱的暂存消息仅保存在应用进程内存中，若应用重启，未发送的消息会永久丢失，需和架构师明确并接受该风险。
• 重试策略配合：可额外配置重试策略，优化服务恢复后的消息投递效率：

  cfg.UseMessageRetry(r =>
  {
      r.Interval(3, TimeSpan.FromSeconds(5)); // 3次重试，每次间隔5秒
      r.Ignore<ServiceBusCommunicationException>(); // 针对特定异常触发重试
  });
  

• 无需Saga代码：内存发件箱的核心作用是暂存消息并自动重试，和Saga场景的事务性保障是独立功能，生产者端单独使用完全合法。

内容的提问来源于stack exchange，提问作者animat089