Mediatr：减少 DI 对象的数量

我有很多命令和查询，其中大多数需要相同的接口来完成不同的事情。是否有可能如何减少我的每个处理程序都需要的这种混乱，并且一遍又一遍地重复？

public class GetCoinByIdQueryHandler : IRequestHandler<GetCoinByIdQuery, CoinModel>
{
    private readonly EventsContext context;
    private readonly ICacheClient cache;
    private readonly ILogger logger;
    private readonly IMapper mapper;
    private readonly Settings settings;

    public GetCoinByIdQueryHandler(
        EventsContext context, ICacheClient cache, ILogger logger,
        IMapper mapper, IOptions<Settings> settings)
    {
        this.context = context;
        this.cache = cache;
        this.logger = logger;
        this.mapper = mapper;
        this.settings = settings.Value;
    }
 }

这可能与 Mediatr 没有直接关系，但我正在寻找一种更优雅的方法，将所有常见的参数减少到一个 DI'ed 参数。

如果有什么区别的话，我使用 Autofac 作为我的 DI 容器。

编辑：可能有所有处理程序继承自的基类，并且在基类中可以访问所有接口并将它们设置为基类上的属性，但我不知道如何实现这一点。

编辑2：Autofac 有属性注入，但这似乎不是正确的方法，所以使用 Mediatr 的人，你如何处理一遍又一遍地重复自己。我见过的每个使用 Mediatr 的开源项目似乎都没有解决重复自己的问题。

当我发现自己处于多个处理程序具有许多共同依赖项的情况时，我会考虑两件事：

1. 我的管理人员是否做得太多；和
2. 如果是这样，我是否可以在单独的类中重构一些行为

例如，在您发布的处理程序代码中，有一个缓存客户端，这可能意味着您的处理程序做了两件事：

1. 执行业务逻辑以检索硬币；和
2. 执行一些逻辑确实返回一个已经缓存的硬币，或者缓存您刚刚检索到的硬币

MediatR 的概念是行为 https://github.com/jbogard/MediatR/wiki/Behaviors它允许您在一个地方处理跨领域的问题；这可能适用于缓​​存、日志记录和异常处理。如果您熟悉 ASP.NET Core 中间件，它们遵循相同的概念，因为给出了每种行为：

1. 当前请求（或 MediatR 术语中的查询）；和
2. 管道中的下一项，可以是另一个行为或查询处理程序

让我们看看如何提取行为中的缓存逻辑。现在，您不需要完全遵循此示例，它实际上只是一种可能的实现。

首先，我们将定义一个应用于需要缓存的查询的接口：

public interface IProvideCacheKey
{
    string CacheKey { get; }
}

那么我们可以改变GetCoinByIdQuery实现该新接口：

public class GetCoinByIdQuery : IRequest<CoinModel>, IProvideCacheKey
{
    public int Id { get; set; }

    public string CacheKey => $"{GetType().Name}:{Id}";
}

接下来，我们需要创建负责缓存的 MediatR 行为。这使用IMemoryCache https://learn.microsoft.com/en-us/aspnet/core/performance/caching/memory?view=aspnetcore-2.2ASP.NET Core 中提供的仅仅是因为我不知道你的定义ICacheClient界面：

public class CacheBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
    where TRequest : IProvideCacheKey, IRequest<TResponse>
{
    private readonly IMemoryCache _cache;

    public CacheBehavior(IMemoryCache cache)
    {
        _cache = cache;
    }

    public async Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken, RequestHandlerDelegate<TResponse> next)
    {
        // Check in cache if we already have what we're looking for
        var cacheKey = request.CacheKey;
        if (_cache.TryGetValue<TResponse>(cacheKey, out var cachedResponse))
        {
            return cachedResponse;
        }

        // If we don't, execute the rest of the pipeline, and add the result to the cache
        var response = await next();
        _cache.Set(cacheKey, response);

        return response;
    }
}

最后，我们需要向 Autofac 注册该行为：

builder
    .RegisterGeneric(typeof(CacheBehavior<,>))
    .As(typeof(IPipelineBehavior<,>))
    .InstancePerDependency();

现在我们已经看到，缓存现在是一个跨领域的关注点，它的实现位于单个类中，使其易于更改和测试。

我们可以对不同的事物应用相同的模式，并使处理程序只负责业务逻辑。