Несколько конечных автоматов с автоматическим именем, использующим постоянство EFCore, не работают

Мы используем Masstransit с автоматическим именем и InMemoryRepository для сохранения саги. У нас есть около 3-х конечных автоматов, настроенных и отлично работающих. Недавно мы перешли с InMemoryRepository на EFCore для сохранения. В результате только 1-й сконфигурированный конечный автомат работал безупречно. Остальные все машины состояний даже не входят в событие Initially. Нужна помощь, чтобы понять, правильная реализация или нет. Ниже приведены детали кода:

masstransit statemachine настройка

 services.AddMassTransit(x =>
        {
            x.AddBus(provider => MassTransit.Bus.Factory.CreateUsingRabbitMq(cfg =>
            {
                cfg.Host(hostUri, hst =>
                {
                    hst.Username(appSettings.RabbitMQ.Username);
                    hst.Password(appSettings.RabbitMQ.Password);
                });

                cfg.ReceiveEndpoint("microservice-response", e =>
                {
                    AddConsumers(e, provider);
                    e.ConfigureSaga<ServiceRequest1RegisterState>(provider);
                    e.ConfigureSaga<ServiceRequest1UpdateState>(provider);
                    e.ConfigureSaga<ServiceRequest1ApproveState>(provider);
                });
            }));

            ////x.AddSagaStateMachine<ServiceRequest1RegisterStateMachine, ServiceRequest1RegisterState>()
            ////   .InMemoryRepository();
            ////x.AddSagaStateMachine<ServiceRequest1UpdateStateMachine, ServiceRequest1UpdateState>()
            ////   .InMemoryRepository();
            ////x.AddSagaStateMachine<ServiceRequest1ApproveStateMachine, ServiceRequest1ApproveState>()
            ////   .InMemoryRepository();

            x.AddSagaStateMachine<ServiceRequest1RegisterStateMachine, ServiceRequest1RegisterState>()
                .EntityFrameworkRepository(r =>
                {
                    r.ConcurrencyMode = ConcurrencyMode.Pessimistic; // or use Optimistic, which requires RowVersion

                    r.AddDbContext<DbContext, ServiceRequest1RegisterStateDbContext>((provider, builder) =>
                    {
                        builder.UseSqlServer(configuration.GetConnectionString("StateDBConnection"), m =>
                        {
                            m.MigrationsAssembly(Assembly.GetExecutingAssembly().GetName().Name);
                            m.MigrationsHistoryTable($"__{nameof(ServiceRequest1RegisterStateDbContext)}");
                        });
                    });
                });

    x.AddSagaStateMachine<ServiceRequest1UpdateStateMachine, ServiceRequest1UpdateState>()
                .EntityFrameworkRepository(r =>
                {
                    r.ConcurrencyMode = ConcurrencyMode.Pessimistic; // or use Optimistic, which requires RowVersion

                    r.AddDbContext<DbContext, ServiceRequest1UpdateStateDbContext>((provider, builder) =>
                    {
                        builder.UseSqlServer(configuration.GetConnectionString("StateDBConnection"), m =>
                        {
                            m.MigrationsAssembly(Assembly.GetExecutingAssembly().GetName().Name);
                            m.MigrationsHistoryTable($"__{nameof(ServiceRequest1UpdateStateDbContext)}");
                        });
                    });
                });

            x.AddSagaStateMachine<ServiceRequest1ApproveStateMachine, ServiceRequest1ApproveState>()
                .EntityFrameworkRepository(r =>
                {
                    r.ConcurrencyMode = ConcurrencyMode.Pessimistic; // or use Optimistic, which requires RowVersion

                    r.AddDbContext<DbContext, ServiceRequest1ApproveStateDbContext>((provider, builder) =>
                    {
                        builder.UseSqlServer(configuration.GetConnectionString("StateDBConnection"), m =>
                        {
                            m.MigrationsAssembly(Assembly.GetExecutingAssembly().GetName().Name);
                            m.MigrationsHistoryTable($"__{nameof(ServiceRequest1ApproveStateDbContext)}");
                        });
                    });
                });
        });

        services.AddSingleton<IHostedService, MassTransitBusService>();

DBContext для всех трех машин состояний выглядит так, как показано ниже.

 public class ServiceRequest1ApproveStateDbContext : SagaDbContext
{
    public ServiceRequest1ApproveStateDbContext(DbContextOptions<ServiceRequest1ApproveStateDbContext> options)
        : base(options)
    {
    }

    /// <summary>
    /// Gets the configurations.
    /// </summary>
    protected override IEnumerable<ISagaClassMap> Configurations
    {
        get { yield return new ServiceRequest1ApproveStateMap(); }
    }
}

Карта штата ниже

public class ServiceRequest1ApproveStateMap : SagaClassMap<ServiceRequest1ApproveState>
{
    protected override void Configure(EntityTypeBuilder<ServiceRequest1ApproveState> entity, ModelBuilder model)
    {
        entity.Property(x => x.CurrentState).HasMaxLength(64);
        entity.Property(x => x.Id);
        entity.Property(x => x.ServiceId);
        entity.Property(x => x.ReadyEventStatus);
    }
}

Из приведенного выше кода отлично работает только ServiceRequest1RegisterStateMachine, остальные машины состояний даже не входят в исходное состояние. Я могу подтвердить, что все миграции выполняются заранее, и все эти statemachine все работают нормально индивидуально, когда существует только 1 конфигурация репозитория, то есть, если только конфигурация репозитория для ServiceRequest1ApproveStateMachine, этот конечный автомат работает нормально. Но если все 3 конфигурации репо существуют, то работает только 1-й. Мне нужно руководство по правильной реализации сохранения саги с помощью EFCore. Стоит ли мне попробовать реализовать использование одного dbcontext, как указано в документации masstransit (https://masstransit-project.com/usage/sagas/efcore.html).


person Rahul Jacob    schedule 27.10.2020    source источник
comment
Да, я бы попытался использовать один DbContext, как показано в этом обновленном разделе (доступно в 7.0.6). Хотя, не зная фактической ошибки, я не могу предложить ничего другого. Применялись ли миграции для двух других DbContext к базе данных?   -  person Chris Patterson    schedule 27.10.2020
comment
Да, сначала были применены миграции для двух других dbcontexts. Попробую с единственной реализацией dbcontext и посмотрю, решит ли она проблему. Но просто хотел знать, действительна ли приведенная выше реализация, например, можем ли мы реализовать несколько машин состояний, как указано выше? Есть ли способ отладить оркестровку?   -  person Rahul Jacob    schedule 28.10.2020
comment
Он должен работать, если все миграции настроены правильно. Журналы из запущенных конечных автоматов помогут выявить любые проблемы, поэтому вам следует настроить ведение журнала.   -  person Chris Patterson    schedule 28.10.2020
comment
когда я изменил TContext для 1 statemachine на sagadbcontext, я получил 2 statemachine для работы, т.е. я изменил r.AddDbContext ‹DbContext, ServiceRequest1UpdateStateDbContext› ((provider, builder) = ›на r.AddDbContext‹ SagaDbContext, ServiceRequest1UpdateStateDbContext ›((provider, builder) =› ServiceRequest1RegisterStateMachine (DbContext) и ServiceRequest1UpdateStateMachine (SagaDbContext) начали работать. В то время как ServiceRequest1ApproveStateMachine по-прежнему работает.   -  person Rahul Jacob    schedule 29.10.2020
comment
Я думаю, это потому, что вы делаете это: <DbContext, ServiceRequest1RegisterStateDbContext> - выньте DbContext, и просто зарегистрируйте контекст db состояния для каждого из них. Приведение его обратно к DbContext приводит к регистрации одного контейнера для этого типа службы.   -  person Chris Patterson    schedule 30.10.2020
comment
Я говорил о AddDbContext внутри AddSagaStateMachine. Насколько я понимаю, определение AddDbContext выглядит следующим образом: void AddDbContext<TContext, TImplementation>(Action<IConfigurationServiceProvider, DbContextOptionsBuilder<TImplementation>> optionsAction = null) where TContext : DbContext Если есть другой способ его реализации, не могли бы вы объяснить, что   -  person Rahul Jacob    schedule 30.10.2020
comment
Похоже, изменение AddDbContext на ExistingDbContext() помогло. Для подтверждения необходимо провести раунд тестирования. Кроме того, преобразование было выполнено на основе примеров кода, представленных в документации по постоянству EFCore. Как вы думаете, эта реализация все еще в силе?   -  person Rahul Jacob    schedule 02.11.2020


Ответы (1)


Итак, ниже приведены изменения, которые я сделал, чтобы машина состояний работала должным образом. Изменения были внесены на основе предложения @Chris в комментариях, хотя наша первоначальная реализация statemachine была основана на документации о сохранении sqlserver efcore.

services.AddDbContext<ServiceRequest1RegisterStateDbContext>(x =>
                     x.UseSqlServer(configuration.GetConnectionString("StateDBConnection")));
        services.AddDbContext<ServiceRequest1UpdateStateDbContext>(x =>
                       x.UseSqlServer(configuration.GetConnectionString("StateDBConnection")));
        services.AddDbContext<ServiceRequest1ApproveStateDbContext>(x =>
                        x.UseSqlServer(configuration.GetConnectionString("StateDBConnection")));

services.AddMassTransit(x =>
    {
        x.AddBus(provider => MassTransit.Bus.Factory.CreateUsingRabbitMq(cfg =>
        {
            cfg.Host(hostUri, hst =>
            {
                hst.Username(appSettings.RabbitMQ.Username);
                hst.Password(appSettings.RabbitMQ.Password);
            });

            cfg.ReceiveEndpoint("microservice-response", e =>
            {
                AddConsumers(e, provider);
                e.ConfigureSaga<ServiceRequest1RegisterState>(provider);
                e.ConfigureSaga<ServiceRequest1UpdateState>(provider);
                e.ConfigureSaga<ServiceRequest1ApproveState>(provider);
            });
        }));

        ////x.AddSagaStateMachine<ServiceRequest1RegisterStateMachine, ServiceRequest1RegisterState>()
        ////   .InMemoryRepository();
        ////x.AddSagaStateMachine<ServiceRequest1UpdateStateMachine, ServiceRequest1UpdateState>()
        ////   .InMemoryRepository();
        ////x.AddSagaStateMachine<ServiceRequest1ApproveStateMachine, ServiceRequest1ApproveState>()
        ////   .InMemoryRepository();

        x.AddSagaStateMachine<ServiceRequest1RegisterStateMachine, ServiceRequest1RegisterState>()
            .EntityFrameworkRepository(r =>
            {
                r.ConcurrencyMode = ConcurrencyMode.Pessimistic; // or use Optimistic, which requires RowVersion

                r.ExistingDbContext<ServiceRequest1RegisterStateDbContext>();
            });

x.AddSagaStateMachine<ServiceRequest1UpdateStateMachine, ServiceRequest1UpdateState>()
            .EntityFrameworkRepository(r =>
            {
                r.ConcurrencyMode = ConcurrencyMode.Pessimistic; // or use Optimistic, which requires RowVersion

                r.ExistingDbContext<ServiceRequest1UpdateStateDbContext>();
            });

        x.AddSagaStateMachine<ServiceRequest1ApproveStateMachine, ServiceRequest1ApproveState>()
            .EntityFrameworkRepository(r =>
            {
                r.ConcurrencyMode = ConcurrencyMode.Pessimistic; // or use Optimistic, which requires RowVersion

                r.ExistingDbContext<ServiceRequest1ApproveStateDbContext>();
            });
    });

    services.AddSingleton<IHostedService, MassTransitBusService>();

}

person Rahul Jacob    schedule 06.11.2020