我在我的 asp.net 核心项目中使用 CQS 模式。让我们从一个例子开始，以更好地解释我想要实现的目标。我创建了一个命令:

public class EmptyCommand : INotification{}

命令处理程序:

public class EmptyCommandHandler : INotificationHandler<EmptyCommand>
{
    public Task Handle(EmptyCommand notification, CancellationToken cancellationToken)
    {
        return Task.FromResult(string.Empty);
    }
}

查询:

public class EmptyQuery : IRequest<string>{}

查询处理程序:

public class EmptyQueryHandler : IRequestHandler<EmptyQuery, string>
{
    public Task<string> Handle(EmptyQuery notification, CancellationToken cancellationToken)
    {
        return Task.FromResult(string.Empty);
    }
}

这是一个简单的示例，说明如何运行命令并从 EmptyCommandHandler 和 EmptyQueryHandler 查询和调用 Handle 方法:

readonly IMediator _mediator;

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

public async Task<IActionResult> Index()
{
    await _mediator.Publish(new EmptyCommand());
    var queryResult = await _mediator.Send(new EmptyQuery());   
    return View();  
}

请记住，查询可以返回其他类型，不一定是 string。 我想创建某种桥接类，例如MediatorBoostrapper，它允许我在每次调用 Publish 方法时运行一些业务逻辑(例如，通过 Logger 记录命令/查询)，然后 从命令处理程序调用 public Task Handle(EmptyCommand notification,... 方法。解决方案必须是通用的，因此每次运行 Publish 时都会调用此方法方法。我还希望能够对 Send 方法执行相同的操作。

我正在考虑创建 public class MediatorBoostrapper : IMediator 但不确定该类的正确实现应该是什么以及我的想法是否好。 有任何想法吗？干杯

编辑

1. 我想要一个如何使用 Behaviors 的例子 每次我运行查询的 Send 方法时，创建一种从通用处理程序运行一些外部方法的通用方法。我想要一个类似的 Publish 方法示例，我用它来发送命令。

2. 我想要一个如何使用 Polymorphic dispatch 的例子 用于创建 GenericCommandHandler 和 GenericQueryHandler

我在 GitHub 上创建了一个示例项目，可以找到 here 您可以随意尝试使用您的解决方案扩展此项目。

最佳答案

这次我想从头开始回答问题。

2.

TL;DR Polymorphic Dispatch cannot be used for the CQS

在使用了 MediatR 库一段时间后，阅读了我的问题下的评论并咨询了我的 friend ，我发现Polymorphic Dispatch(PD) 只能用于创建通用处理程序命令的情况。 Queries 无法实现 PD 方案。基于Documentation ，处理程序是逆变而不是协变的。这意味着 PD 仅在 TResponse 的情况下起作用。是常量类型。对于查询，这是错误的，每个查询处理程序都可以返回不同的结果。

我还找到了this issue .我认为了解只有在您的容器支持的情况下才能使用多态分派(dispatch)是一件很有趣的事情。

1. Behaviors是使用 MediatR 时 CQS 的唯一解决方案。 基于#Steve 和 comment from jbogard 在我的问题下的评论我找到了如何使用 Behaviors 和 IRequestHandler 来实现严格的命令模式。完整评论:

Just to summarize the changes, there are 2 main flavors of requests: those that return a value, and those that do not. The ones that do not now implement IRequest<T> where T : Unit. This was to unify requests and handlers into one single type. The diverging types broke the pipeline for many containers, the unification means you can use pipelines for any kind of request.

It forced me to add the Unit type in all cases, so I've added some helper classes for you.

• IRequestHandler<T> - implement this and you will return Task<Unit>.
• AsyncRequestHandler<T> - inherit this and you will return Task.
• RequestHandler<T> - inherit this and you will return nothing (void).

For requests that do return values:

• IRequestHandler<T, U> - you will return Task<U>
• RequestHandler<T, U> - you will return U

I got rid of the AsyncRequestHandler because it really wasn't doing anything after the consolidation, a redundant base class.

例子

a) 命令管理:

public class EmptyCommand : IRequest{...}

public class EmptyCommandHandler : RequestHandler<EmptyCommand>
{
    protected override void Handle(EmptyCommand request){...}
}

b) 查询管理:

// can be any other type not necessarily `string`
public class EmptyQuery : IRequest<string>{...}

public class EmptyQueryHandler : IRequestHandler<EmptyQuery, string>
{
    public Task<string> Handle(EmptyQuery notification, CancellationToken cancellationToken)
    {
        return Task.FromResult("Sample response");
    }
}

c) 样本 LogginBehavior类:

public class LoggingBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
    where TRequest : IRequest<TResponse>
{
    readonly ILogger<LoggingBehavior<TRequest, TResponse>> _logger;

    public LoggingBehavior(ILogger<LoggingBehavior<TRequest, TResponse>> logger)
    {
        _logger = logger;
    }

    public async Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken, RequestHandlerDelegate<TResponse> next)
    {
        var requestType = typeof(TRequest).Name;
        var response = await next();

        if (requestType.EndsWith("Command"))
        {
            _logger.LogInformation($"Command Request: {request}");
        }
        else if (requestType.EndsWith("Query"))
        {
            _logger.LogInformation($"Query Request: {request}");
            _logger.LogInformation($"Query Response: {response}");
        }
        else
        {
            throw new Exception("The request is not the Command or Query type");
        }

        return response;
    }

}

d) 注册 LoggingBehavior添加命令

services.AddTransient(typeof(IPipelineBehavior<,>), typeof(LoggingBehavior<,>));

到ConfigureServices的正文Startup.cs 中的方法。

e) 如何运行示例命令和查询的示例:

await _mediator.Send(new EmptyCommand());
var result = await _mediator.Send(new EmptyQuery());

关于c# - 在 asp .net core 中为 MediatR 库的 Send 和 Publish 方法添加通用处理程序，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53895522/