Automatonymous - 使用发送活动调用 RaiseEvent 时未找到有效负载

问题描述

我一直在努力让 MasstransitStateMachine 工作，但我似乎不明白这应该如何工作。

当我尝试在状态机中结合 PayloadNotFoundException Activity 调用 stateMachine.RaiseEvent(instance,stateMachine.DeployApplicationRequest,request) 时，我收到的错误（完整代码如下）是 .Send()。我一直在努力追查此事，但一无所获。

这里是相关的代码和意图的解释：

我通过 webAPI 帖子收到部署应用程序的请求，并将请求转换为 DeployApplicationRequest。

public record DeployApplicationRequest
    {
        // State machine properties
        public Guid CorrelationId { get; init; }
        public ChatApplication ChatApplication { get; init; }
        public string ChannelId { get; init; }
        public string UserId { get; init; }


        // Command
        public DeployApplication DeployApplication { get; init; }
    }

    public enum ChatApplication
    {
        Slack,Teams
    }

这个请求封装了两件事：API 需要维护的状态，以便它知道如何将结果路由回请求者（状态机属性）和要发送到服务总线的 Command。

命令 DeployApplication 如下所示：

public record DeployApplication
    {
        public Guid CorrelationId { get; init;}
        public string InitiatedBy { get; init; }
        public DateTime CreatedDate { get; init; }
        public string Environment { get; init; }
        public string PullRequestId { get; init; }
    }

我创建了一个状态实例来保存请求的详细信息（例如它是通过 Slack 还是 Teams 传入的）。我不想将此信息发布到总线上：

public class DeployApplicationState : SagaStateMachineInstance
    {
        public Guid CorrelationId { get; set; }
        public string CurrentState { get; set; }

        public ChatApplication ChatApplication { get; set; }
        public string ChannelId { get; set; }
        public string UserId { get; set; }
    }

我创建了一个 StateMachine 来处理这个：

public class DeployApplicationStateMachine : MasstransitStateMachine<DeployApplicationState>
    {
        private readonly ILogger<DeployApplicationStateMachine> logger;
        public DeployApplicationStateMachine(ILogger<DeployApplicationStateMachine> logger)
        {
            this.logger = logger;

            InstanceState(x => x.CurrentState);

            Event(() => DeployApplicationRequest,x => x.CorrelateById(context => context.Message.CorrelationId));

            Initially(
                When(DeployApplicationRequest)
                    .Then(x => {
                        x.Instance.CorrelationId = x.Data.CorrelationId;
                        x.Instance.ChannelId = x.Data.ChannelId;
                        x.Instance.ChatApplication = x.Data.ChatApplication;
                        x.Instance.UserId = x.Data.UserId;
                    })
                    .Send(context => context.Init<DeployApplication>(context.Data.DeployApplication))
                    .TransitionTo(Submitted));
        }

        public Event<DeployApplicationRequest> DeployApplicationRequest { get; private set; }

        public State Submitted { get; private set; }
    }

为了触发初始事件（因为请求不是通过消费者而是通过控制器传入），我已将状态机注入 Masstransit 客户端，并调用 RaiseEvent 方法：

public class MasstransitDeployClient : IDeployClient
    {
        private readonly DeployApplicationStateMachine stateMachine;
        public MasstransitDeployClient(DeployApplicationStateMachine stateMachine)
        {
            this.stateMachine = stateMachine;
        }

        public async Task Send(DeployApplicationRequest request)
        {
            var instance = new DeployApplicationState
            {
                CorrelationId = request.CorrelationId,ChannelId = request.ChannelId,ChatApplication = request.ChatApplication,UserId = request.UserId
            };

            await stateMachine.RaiseEvent(instance,request);
            // This works for sending to the bus,but I lose the state @R_974_4045@ion
            //await sendEndpointProvider.Send(request.DeployApplication);
        }
    }

容器配置如下：

services.AddMasstransit(x =>
            {
                x.AddSagaStateMachine<DeployApplicationStateMachine,DeployApplicationState>()
                    .InMemoryRepository();

                x.UsingInMemory((context,cfg) =>
                {
                    cfg.ConfigureEndpoints(context);
                });
                
                
            });

            EndpointConvention.Map<DeployApplication>(new Uri($"queue:{typeof(DeployApplication).FullName}"));

            services.AddMasstransitHostedService();

引发事件工作正常，如果我在状态机中不包括 Submitted，状态机将成功转移到 .Send(...)。第二个我介绍 Activity 我得到 PayloadNotFoundException。我在周末尝试了大约 15 种不同的方法来做这件事，但没有成功，我希望有人能帮助我看到我的方法中的错误。

感谢阅读！顺便说一句，很棒的图书馆。我会想方设法为此做出贡献，这是我遇到过的最有用的库之一（Chris，你的 Youtube 视频很棒）。

解决方法

Saga 状态机不旨在直接从控制器调用。您应该发送（或发布）一条消息，然后该消息将通过消息代理发送到 saga。

如果您想这样做，您可以改用 MassTransit Mediator，但您仍将通过 Mediator 向 saga 发送消息，然后由 MassTransit 处理。

TL;DR - 您不要将 RaiseEvent 与 saga 状态机一起使用。