MassTransit - 具有 Entity Framework Core 的 Saga 存储库

Question

非常感谢您。

我的项目面向 .NET Core 2.2。

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

使用此代码

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"));

}

Answer 1

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

如果您使用的是旧版本的 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