首页 > 解决方案 > MediatR 错误:向容器注册您的处理程序

问题描述

我有一个 .Net Core 应用程序,我在其中使用 .AddMediatR 扩展名为我的命令和处理程序注册程序集

在 Startup.cs 的 ConfigureServices 中,我使用了官方包 MediatR.Extensions.Microsoft.DependencyInjection 中的扩展方法,并带有以下参数:

启动.cs

 services.AddBLL();

依赖注入.cs

public static IServiceCollection AddBLL(this IServiceCollection services)
    {
        services.AddAutoMapper(Assembly.GetExecutingAssembly());
        services.AddMediatR(Assembly.GetExecutingAssembly());
        services.AddTransient(typeof(IPipelineBehavior<,>), typeof(RequestPerformanceBehaviour<,>));
        services.AddTransient(typeof(IPipelineBehavior<,>), typeof(RequestValidationBehavior<,>));

        return services;
    }

命令处理程序类如下:ListEpostaHesapariHandler.cs

public class ListEpostaHesaplariRequest : IRequest<ResultDataDto<List<ListEpostaHesaplariDto>>>
{
    public FiltreEpostaHesaplariDto Model { get; set; }
}

public class ListEpostaHesaplariHandler : IRequestHandler<ListEpostaHesaplariRequest, ResultDataDto<List<ListEpostaHesaplariDto>>>
{
    private readonly IBaseDbContext _context;
    private readonly IMapper _mapper;

    public ListEpostaHesaplariHandler(IBaseDbContext context, IMapper mapper)
    {
        _context = context;
        _mapper = mapper;
    }

    public async Task<ResultDataDto<List<ListEpostaHesaplariDto>>> Handle(ListEpostaHesaplariRequest request, CancellationToken cancellationToken)
    {
        await Task.Delay(1);

        var resultDataDto = new ResultDataDto<List<ListEpostaHesaplariDto>>() { Status = ResultStatus.Success };

        try
        {
            var foo = _context.EpostaHesaplari;

            var filtreliEpostaHesaplari = Filtre(request.Model, foo);

            var epostaHesaplariDto = _mapper.Map<List<ListEpostaHesaplariDto>>(filtreliEpostaHesaplari);

            resultDataDto.Result = epostaHesaplariDto;
        }
        catch (Exception ex)
        {
            resultDataDto.Status = ResultStatus.Error;
            resultDataDto.AddError(ex.Message);
        }

        return resultDataDto;
    }

这是我使用 MediatR 的控制器

基本控制器.cs

  public abstract class BaseController : Controller
{
    private IMediator _mediator;
    public static int? birimIDD;
    protected IMediator Mediator
    {
        get
        {
            return _mediator ??= HttpContext.RequestServices.GetService<IMediator>();
        }
    }
}

家庭控制器.cs

[HttpPost]
    public async Task<IActionResult> MailGonderAsync()
    {

        FiltreEpostaHesaplariDto filtre = new FiltreEpostaHesaplariDto();
        filtre.Durum = true;
        var req = new ListEpostaHesaplariRequest() { Model = filtre };
        var response = await Mediator.Send(req);
    }

到目前为止没问题 await Mediator.Send(req); 此响应即将成功

问题从这里开始

send.cs(在类业务逻辑层)

public class EmailSend : IEmailSingleSender
{
    private readonly IMediator _mediator;

    public EmailSend(IMediator mediator)
    {
        _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));

    }

    public async Task Send(EmailParamsDto emailParamsDto)
    {
        try
        {
            FiltreEpostaHesaplariDto filtre = new FiltreEpostaHesaplariDto();
            filtre.Durum = true;
            var req = new ListEpostaHesaplariRequest() { Model = filtre };
            var response = await _mediator.Send(req);

            SmtpClient smtpClient = new SmtpClient();
            smtpClient.Port = _emailSetting.Port;
            smtpClient.Host = _emailSetting.Server;
            smtpClient.EnableSsl = _emailSetting.UseSsl;
            NetworkCredential networkCredential = new NetworkCredential();
            networkCredential.UserName = _emailSetting.UserName;
            networkCredential.Password = _emailSetting.Password;
            smtpClient.Credentials = networkCredential;
            MailMessage mail = new MailMessage();
            mail.IsBodyHtml = _emailSetting.IsHtml;
            mail.From = new MailAddress(_emailSetting.UserName, emailParamsDto.Subject);
            mail.To.Add(new MailAddress(emailParamsDto.Receiver));
            //mail.CC.Add(_emailSetting.AdminMail);
            mail.Body = emailParamsDto.Body;
            mail.Subject = emailParamsDto.Subject;
            mail.Priority = emailParamsDto.MailPriority;

            await smtpClient.SendMailAsync(mail);
        }
        catch (Exception ex)
        {

            throw ex;
        }
    }
}

当这行在 Send 方法中执行时,我得到了异常:

var response = await _mediator.Send(req); 

2[IUC.BaseApplication.BLL.Handlers.Yonetim.EpostaHesaplariHandlers.ListEpostaHesaplariRequest,IUC.BaseApplication.COMMON.Models.ResultDataDto为 MediatR.IRequestHandler 1[System.Collections.Generic.List`1[IUC.BaseApplication.BLL.Models.Yonetim.EpostaHesaplariDto.ListEpostaHesaplariDto]]]类型的请求构造处理程序时出错。向容器注册您的处理程序。有关示例,请参阅 GitHub 中的示例。

标签: c#asp.net-coredependency-injectionmediatr

解决方案


services.AddMediatR(Assembly.GetExecutingAssembly());

你所有的处理程序和命令都在你传递的这个程序集中?


推荐阅读