Mediatr范围问题

Question

我使用Mediatr处理来自队列的消息。我可以得到一个简单的例子来工作。然而，当我试图将一个对象注入我的处理程序时，我遇到了一些问题。

public class MessageCommandHandler : IRequestHandler<MessageCommand, bool>
{
    private IMyDependency myDependency;
    public MessageCommandHandler(IMyDependency myDependency)
    {
        this.myDependency = myDependency;
    }
    
    public Task<bool> Handle(MessageCommand request, CancellationToken cancellationToken)
    {
        return Task.FromResult(true);
    }
}

这仅当我将IMyDependency注册为瞬态作用域时才有效，但是当我将其注册为作用域生存期时，它会因错误而失败。

Cannot resolve 'MediatR.IRequestHandler`2[MyNamespace.MessageCommand,System.Boolean]' from root provider because it requires scoped service 'MyNamespace.IMyDependency'

我需要能够注入具有作用域生存期的依赖项。有人有办法解决这个问题吗。

我使用的是.NET核心依赖注入框架。它的设置如下

services.AddHostedService<QueueConsumer>();
services.AddScoped<IMyDependency, MyDependency>();
services.AddMediatR(new Assembly[] { Assembly.GetExecutingAssembly() });

有什么想法吗？

Answer 1

当您使用具有作用域生存期的依赖项时，您将需要在预先创建的范围内使用它。在MVC的情况下，这将自动发生在幕后，但是如果您直接使用自己的代码，比如通过控制台应用程序或其他什么的话，您将需要自己创建作用域。

这可以通过注入一个IServiceScopeFactory实例来实现，然后使用这个工厂创建一个作用域，然后从该作用域检索依赖项。

public class MessageCommandHandler : IRequestHandler<MessageCommand, bool>
    {
        private IServiceScopeFactory _serviceScopeFactory;

        public MessageCommandHandler(IServiceScopeFactory serviceScopeFactory) 

        {
            _serviceScopeFactory = serviceScopeFactory;
        }

        public Task<bool> Handle(MessageCommand request, CancellationToken cancellationToken)
        {
            using (var scope = _serviceScopeFactory.CreateScope())
            {
                var scopedServices = scope.ServiceProvider;
                var myDependency = scopedServices.GetRequiredService<IMyDependency>();
                return Task.FromResult(true);
            }
        }
    }

但是(请注意，上面的代码是未经测试的)，在我自己的系统中，我几乎总是围绕发送中介请求的内容创建作用域，在这种情况下，任何作用域依赖项仍然会在这个范围内自动注入。

... // some other calling class / Main method etc..

using (var scope = _serviceScopeFactory.CreateScope())
    var mediator = scope.ServiceProvider.GetRequiredService<IMediator>();
    mediator.Send(new MessageCommand());
}