MassTransit 8.4.1中ExecuteDeleteAsync方法未找到问题求助

问题根源 #

报错核心原因是MassTransit 8.4.1的EntityFrameworkCore集成组件与EF Core 9.0.5存在版本兼容性冲突：

• MassTransit 8.4.1开发时适配的是EF Core 7.x/8.x版本，而EF Core 9.0.5对RelationalQueryableExtensions.ExecuteDeleteAsync的方法签名或内部实现做了调整，导致运行时无法匹配该方法。
• 另一种可能是项目中存在多版本EF Core依赖，运行时加载了不包含目标方法的旧版本组件。

解决步骤 #

1. 降级EF Core到兼容版本（最快捷方案） #

将项目中所有EF Core相关包（如Microsoft.EntityFrameworkCore、Microsoft.EntityFrameworkCore.SqlServer等）降级到8.x稳定版（例如8.0.7）：

• 通过NuGet包管理器逐一选择对应包，切换版本后保存
• 执行dotnet clean和dotnet restore清理并重新还原依赖

2. 升级MassTransit到支持EF Core 9.x的版本 #

若需保留EF Core 9.0.5，可升级MassTransit到官方发布的支持EF Core 9.x的最新版本：

• 替换MassTransit.EntityFrameworkCore、MassTransit.Azure.ServiceBus.Core等相关包到对应兼容版本
• 升级后验证项目编译和运行状态

3. 排查并解决依赖冲突 #

• 执行dotnet list package --outdated查看项目中所有过时或版本不一致的依赖
• 打开项目的.csproj文件，确保所有EF Core相关引用的版本号完全一致，移除任何重复或冲突的包引用

4. 自定义Inbox清理逻辑（临时 workaround） #

如果暂时无法调整版本，可自定义Inbox清理服务替代MassTransit内置实现：

public class CustomInboxCleanupService<TDbContext> : IHostedService, IDisposable
    where TDbContext : DbContext
{
    private readonly IServiceScopeFactory _scopeFactory;
    private readonly ILogger<CustomInboxCleanupService<TDbContext>> _logger;
    private Timer _timer;

    public CustomInboxCleanupService(IServiceScopeFactory scopeFactory, ILogger<CustomInboxCleanupService<TDbContext>> logger)
    {
        _scopeFactory = scopeFactory;
        _logger = logger;
    }

    public Task StartAsync(CancellationToken cancellationToken)
    {
        // 调整清理间隔，示例为每小时执行一次
        _timer = new Timer(ExecuteCleanup, null, TimeSpan.Zero, TimeSpan.FromHours(1));
        return Task.CompletedTask;
    }

    private void ExecuteCleanup(object state)
    {
        using var scope = _scopeFactory.CreateScope();
        var dbContext = scope.ServiceProvider.GetRequiredService<TDbContext>();
        // 保留7天内的Inbox数据，可按需调整
        var cutoffTime = DateTime.UtcNow.Subtract(TimeSpan.FromDays(7));

        try
        {
            var oldRecords = dbContext.Set<InboxState>()
                .Where(x => x.Created < cutoffTime)
                .ToList();
            
            dbContext.RemoveRange(oldRecords);
            var deletedCount = dbContext.SaveChanges();
            
            _logger.LogInformation("清理了 {Count} 条过期Inbox记录", deletedCount);
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "清理Inbox记录失败");
        }
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        _timer?.Change(Timeout.Infinite, 0);
        return Task.CompletedTask;
    }

    public void Dispose()
    {
        _timer?.Dispose();
    }
}

然后在DI容器中注册自定义服务，替换MassTransit默认的清理服务：

services.AddHostedService<CustomInboxCleanupService<YourDbContext>>();

内容的提问来源于stack exchange，提问作者ForteUnited