.NET Core 控制台应用程序 Mediatr 命令处理程序不会被调用

Question

我面临一个问题，即没有调用 Mediatr 命令处理程序。我有以下解决方案结构。

Project.sln -> Application layer (.NET standard class library) -> Jobs (.NET standard class library) -> Job Server (.NET Core console app)

这个想法是作业服务器使用调度程序（Quartz.NET）来执行作业。实际的业务逻辑在应用层。应用层使用 CQRS 模式，使用 Mediatr 进行连接。我正在使用 Microsoft 依赖注入库。

作业服务器Main方法（带 DI 代码）：

public class Program
{
    static ManualResetEvent _quitEvent = new ManualResetEvent(false);

    static void Main(string[] args)
    {
        Console.WriteLine("Job Server started");

        //DI setup
        var serviceProvider = new ServiceCollection()
            .AddQuartz()
            .AddTransient<InitializeJobServer>()
            .AddTransient<ProcessAdRssFeedsJob>()
            .AddScoped<IConfigService, ConfigService>()
            .AddScoped<IRssService, RssService>()
            .AddScoped<IBaseService, BaseService>()
            .AddMediatR(typeof(ProcessAdSectionsRssCommand).GetType().Assembly)
            .AddDbContext<MyDbContext>(options =>
                options.UseNpgsql("xxx"))
            .AddMemoryCache()
            .BuildServiceProvider();

        Console.CancelKeyPress += (sender, eArgs) => {
            _quitEvent.Set();
            eArgs.Cancel = true;
        };

        Task.Run(async () =>
        {
            await serviceProvider.GetService<InitializeJobServer>().Start();
        });

        _quitEvent.WaitOne();
        Console.WriteLine("Job Server ended");
    }
}

Quartz.net 作业中的代码：

[DisallowConcurrentExecution]
public class ProcessAdRssFeedsJob : IJob
{
    private readonly IMediator _mediator;

    public ProcessAdRssFeedsJob(IMediator mediator)
    {
        _mediator = mediator;
    }

    public Task Execute(IJobExecutionContext context)
    {
        try
        {
            _mediator.Send(new ProcessAdSectionsRssCommand());               
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex);
        }
        return null;
    }
}

媒体命令：

public class ProcessAdSectionsRssCommand : IRequest<bool>
{

    public class Handler : IRequestHandler<ProcessAdSectionsRssCommand, bool>
    {
        private readonly MyDbContext _context;
        private readonly IRssService _rssService;
        private readonly IConfigService _configService;

        public Handler(
            MyDbContext context,
            IRssService rssService,
            IConfigService configService)
        {
            _context = context;
            _rssService = rssService;
            _configService = configService;
        }

        public async Task<bool> Handle(ProcessAdSectionsRssCommand request, CancellationToken cancellationToken)
        {
            var config = await _configService.GetAllConfigs();

            var r0 = await _rssService.GetAdSectionRssUrls();
            // etc.
            return true;
        }
    }
}

调试后我得出结论，代码在初始化ProcessAdSectionsRssCommand类后停止执行（如果我创建一个空的构造函数，它将被执行）。不幸的是，我没有收到任何实际的错误消息，我认为可能会吞下某种异常。Handler据我所知，类永远不会被初始化。

• 媒体版本：6.0.0
• .NET 代码 SDK 版本：2.2
• Microsoft DI 版本（Microsoft.Extensions.DependencyInjection）：2.2.0

我怀疑这是某种 DI + Mediatr 相关问题。任何人有任何想法？谢谢。

Answer 1

我认为您在调用方法时缺少一个awaitinSend()