使用 MediatR 链接处理程序

Question

我们正在使用 MediatR 为我们的 dotnet 核心 WebAPI 后端实现“管道”，试图遵循 CQRS 原则。

我无法决定是否应该尝试实现 IPipelineBehavior 链，或者是否应该构造一个新的请求并从我的 Handler 方法中调用 MediatR.Send 更好（对于请求）。

场景本质上是这样的：

• 用户请求要执行的操作，即删除某些内容
• 我们必须检查该东西是否被其他人使用
• 我们必须在数据库中将该内容标记为已删除
• 我们必须实际从文件系统中删除文件。

选项1是我们现在拥有的：一个DeleteRequest，由一个类处理，其中Handler检查它是否正在使用，将其标记为已删除，然后发送一个新的@ 987654323@带参数删除。

选项2是我正在考虑的：一个DeleteRequest，它实现了标记接口IRequireCheck、IStartTask，带有一个运行的管道：

1. IPipelineBehavior<IRequireCheck>先检查一下有没有被使用，
2. IPipelineBehavior<DeleteRequest> 将数据库中的内容标记为已删除，并
3. IPipelineBehavior<IStartTask> 启动任务。

我还没有完全弄清楚选项 2 会是什么样子，但这是一般的想法。

我想我主要想知道在 TRequest1 的处理程序中调用 MediatR.Send(TRequest2) 是否是代码异味。

Answer 1

如果这些是您设置的选项 - 我说的是选项 2。从现有 Mediatr 处理程序内部发送请求可以被视为代码异味。你隐藏了副作用并打破了单一责任原则。您还将您的请求耦合在一起，您应该尽量避免无法在另一种请求之前发送一种类型的请求的情况。

但是，我认为可能还有其他选择。如果没有事先验证和标记就无法发生删除请求，您可以为您的TaskStartRequest 使用预处理器 (example here)。这样你就可以有一个请求来完成你需要的一切。这甚至可以通过简单地利用现有的 Mediatr 模式来反映您的管道示例。

Answer 2

是否需要将任务分解为多个Handlers？也许我错过了mediatr 的重点。这还不够吗？

public async Task<Result<IFailure,ISuccess>> Handle(DeleteRequest request)
{
  var thing = await this.repo.GetById(request.Id);

  if (thing.IsBeignUsed())
  {
    return Failure.BeignUsed();
  }
  var deleted = await this.repo.Delete(request.Id);
  return deleted ? new Success(request.Id) : Failure.DbError();
}