ASP.NET Core中MediatR进程内发布/订阅优化实践

在ASP.NET Core项目中，当遇到一种典型的业务场景，即需要在单体系统中实现事件/消息驱动或发布/订阅的业务逻辑时，MediatR是一个非常流行的解决方案。MediatR是一个轻量级的.NET Core库，用于简化应用程序中的消息传递和事件处理，使得代码更加模块化和可维护。 首先，让我们理解背景：在实际工作中，一位开发者的代码组织混乱，存在大量的重复代码，特别是在执行一个公共操作A时。通常，这种情况下会倾向于将这个操作封装成单独的服务或事件处理器，以便在业务的不同部分进行复用。但这位同事选择了复制粘贴的方式，导致代码难以理解和维护。鉴于系统的单体性质，引入进程内发布/订阅模式能够有效地减少耦合度，并提高代码的可扩展性。 在选择MediatR时，开发人员回顾了过去使用过的Prism的EventAggregator，虽然Prism可能并不适用于.NET Core，但MediatR作为现代的选择，提供了更好的.NET Core集成和设计。MediatR的使用涉及以下几个步骤： 1. 在Startup.cs文件中配置服务：通过IServiceCollection注册MediatR服务，设置Mvc兼容性和依赖注入所需的服务，如IService1、IService2、IContext以及Mediator本身。`AddMediatR(typeof(SomeEventHandler).Assembly)`这一行确保MediatR能扫描SomeEventHandler类型所在的程序集，找到并自动注册相关的处理程序。 2. 服务类的设计：例如Service1类，它实现了IService1接口，包含了MediatR的相关依赖项，如ILogger、IMediator、IContext和IService2。构造函数中传入这些依赖，使得每个服务实例都可以通过Mediator来发送和接收消息。 在Service1中，可能会有类似这样的操作： ```csharp public async Task ExecuteAOperation() { var result = await _mediator.Send(new AOperationCommand()); // 处理结果，可能更新UI或存储等 } ``` 在这个例子中，`AOperationCommand`是一个自定义的消息类型，包含执行操作所需的数据。Service1通过Mediator发送这个命令，而不是直接在类内部执行。其他服务或监听器可以通过订阅`AOperationCommand`来处理执行结果。 3. 发布者和订阅者：在业务逻辑中，Service2可能是订阅`AOperationCommand`的接收者，它会在接收到命令后执行相应的操作。同时，也可以创建专门的事件处理器或命令处理管道来进一步细化职责。 通过MediatR，开发者能够将关注点分离，将业务逻辑分解为可测试和可重用的部分，提高代码的可维护性和扩展性。这种架构模式对于处理复杂的企业级应用尤为有用，因为它有助于降低模块间的耦合，促进团队协作和代码复用。