Masstransit UseInMemoryOutbox 无法与 MultiBus Saga 配合使用？

Question

我实现了一个自定义活动来支持多总线传奇。 但我发现一个问题，即在状态传奇保存到 Redis 之前，我收到了来自 SecondBus 的已发布消息。 我认为 UseInMemoryOutbox() 应该处理这个问题，否则我错了。

public class TestActivity : Activity<SagaState, IFirstBusRequest>
{
    private readonly ISecondBus _secondBus;

    public TestActivity(ISecondBus secondBus)
    {
        _secondBus = secondBus;
    }


    public async Task Execute(BehaviorContext<SagaState, IFirstBusRequest> context, Behavior<SagaState, IFirstBusRequest> next)
    {
        var endpoint = await _secondBus.GetSendEndpoint(new Uri($"queue:second-bus-request"));
        await endpoint.Send(new { }); // send immediately
    }      
}

Answer 1

正确，这是一个已知的限制，因为另一个总线实例是完全独立的总线，并且不是接收总线上发件箱的一部分。

如果您需要涉及发件箱，请考虑在第一条总线上生成消息，并在该总线上有一个使用者，仅将该消息转发到另一条总线。

public class ForwardMessageConsumer<T> :
    IConsumer<T>
    where T : class
{
    readonly ISecondBus _bus;

    public ForwardMessageConsumer(ISecondBus bus)
    {
        _bus = bus;
    }

    public async Task Consume(ConsumeContext<T> context)
    {
        var messagePipe = new ForwardMessagePipe<T>(context);

        await _bus.Publish(context.Message, messagePipe, context.CancellationToken);
    }
}

然后，您可以只拥有一个带有这些消息转发器的端点：

x.AddConsumer<ForwardMessageConsumer<A>>()
    .Endpoint(e => e.Name = "second-bus-forwarder");
x.AddConsumer<ForwardMessageConsumer<B>>()
    .Endpoint(e => e.Name = "second-bus-forwarder");

然后，ConfigureEndpoints 会将这些使用者置于接收端点上，该接收端点会将这些消息转发到其他总线实例。

端点配置是将多个消费者放在同一个队列上，以避免多个队列只转发消息。假设将从活动中使用Publish。