Masstransit - 带有 Entity Framework Core 的 Saga 存储库

问题描述

非常感谢您。

我的项目面向 .NET Core 2.2。

我正在尝试定义一个使用 Masstransit 6.2.5 的服务，该服务使用带有 sql 数据库的 SAGA Machine。

使用此代码

services.AddMasstransit(cfg =>
              {
                  cfg.AddConsumersFromNamespaceContaining<SubmitVolunteerConsumer>(); //add consumer
                  cfg.AddSagaStateMachine<UserStateMachine,UserState>(typeof(UserStateMachineDeFinition))

                  .EntityFrameworkRepository(r =>
                  {
                      r.ConcurrencyMode = ConcurrencyMode.pessimistic;

                      services.AddDbContext<DbContext,UserStateDbContext>((provider,build) =>
                      {
                          build.UsesqlServer(connectionString,m =>
                          {
                              m.MigrationsAssembly(Assembly.GetExecutingAssembly().GetName().Name);
                              m.MigrationsHistoryTable($"__{nameof(UserStateDbContext)}");
                          });
                      });

                  });

                  cfg.AddBus(provider => RabbitMqBus.ConfigureBus(provider,false));
              });

导致问题，因为它需要 Masstransit.EntityFrameworkCore 6.2.5（但是，这是使用 Microsoft.EntityFrameworkCore.Relational (3.1.3)），这在我尝试调用/使用 DBContext 时导致错误

遇到这个错误

无法从程序集“Microsoft.EntityFrameworkCore,Version=3.1.3.0,Culture=neutral,PublicKeyToken=adb9793829ddae60”加载类型“Microsoft.EntityFrameworkCore.Infrastructure.IDbContextOptionsExtensionWithDebugInfo”。

能否请您帮我找到一种在 Saga 机器上使用 sql Server 而不使用引用 Entity Framework Core 3.x 的 nuget 的方法？

顺便说一下，这是我的 Dbcontext

public UserStateDbContext(DbContextOptions options)
  : base(options)
{
}

protected override IEnumerable<ISagaClassMap> Configurations
{
    get { yield return new UserStateMap(); }
}

protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
    IConfigurationRoot configuration = new ConfigurationBuilder()
      .SetBasePath(AppDomain.CurrentDomain.BaseDirectory)
      .AddJsonFile("appsettings.json")
      .Build();
        optionsBuilder.UsesqlServer(configuration.GetConnectionString("GRPPortal"));

}

解决方法

为什么说“不使用引用实体框架 3.x 的 nuget”？要使用 MassTransit 6.2.5，需要依赖 EF Core 3.1.3+，因为它的 EF Core 持久性。

如果您使用的是旧版本的 EF Core 并且无法升级，那么您需要查看仍支持您的 EF Core 版本的旧版本 MassTransit。这可能需要针对 MassTransit 的依赖项进行其他绑定重定向，如果您的项目中有较新版本。

如果您使用的是 EF6 并且不想添加 EFCore，则可以使用 MassTransit.EntityFrameworkIntegration

如果您使用的是较新的 EF Core 版本，那么这可能可以通过绑定重定向来解决，但是，鉴于 EF Core 相当不稳定的状态，例如您使用的是 EF Core 5.x，这可能不是支持直到发布更新版本的 MassTransit。

如果您只是不想引入任何对 EF Core 的依赖，以使 MassTransit 在没有 EF 的情况下与 SQL Server 一起工作，那么还有其他选择，例如使用 NHibernate。您还可以考虑编写自己的持久性存储库。我不认为这会非常困难，因为所有官方持久性的源代码都可以在这里找到：https://github.com/MassTransit/MassTransit/tree/77eb5d724c8e33ebba6bb846b2a277e4d55fa65a/src/Persistence

entity-framework-core masstransit