0

我有一个使用 UseInMemoryOutbox() 配置的 MT 状态机，因此只有在管道中的最后一步成功完成后才会发布作为事件处理一部分的任何消息，在我的例子中，状态持久化到 Couchbase。

        Initially(When(A).
                    ThenAsync(async context =>
                    {   
                        context.Instance.IsAutoApprove = context.Data.IsAutoApprove;
                        IList<Task> publishTasks = context.Data.SomeList.Select(item =>
                        {
                            MessageA message = new MessageA
                            {
                                Content = "contentA"
                            };
                            return context.Publish(message);
                        }).ToList();

                        await Task.WhenAll(publishTasks);
                    }).TransitionTo(B));

        WhenEnter(B, f => f.If(c => c.Instance.IsAutoApprove,
            callback =>
            callback.TransitionTo(C)
            ));

        WhenEnter(C, c => c.Publish<SagaState, MessageC>(context =>
                     new MessageC
                     {
                         Content = "contentC"
                     }));

我注意到发布消息最终以不一致的顺序发布。

例如 - 假设第一个事件中的“SomeList”中有两个项目，因此消息有时按以下顺序发布：

MessageC
MessageA
MessageA

而有时

MessageA
MessageA
MessageC

等等。不保留逻辑流的顺序。

你能帮我解决这个问题吗？

我在用着

大众运输 3.5.2

MassTransit.Automatonymous 3.5.2

MassTransit.RabbitMQ 3.5.2

自动 3.5.11

绿管 1.0.9

谢谢，

4

1 回答 1

0

这是出于性能原因所做的事情，但实际上并没有什么意义，所以我提交了一个问题并关闭了它。

https://github.com/MassTransit/MassTransit/issues/945

在 v4 中，动作将按顺序执行。

于 2017-07-24T17:16:40.917 回答