.NET 8 中利用 MediatR 实现高效消息传递

怆然忧遂

前言

MediatR 是 .NET 下的一个实现消息传递的库，轻量级、简洁高效，用于实现进程内的消息传递机制。它基于中介者设计模式，支持请求/响应、命令、查询、通知和事件等多种消息传递模式。通过泛型支持，MediatR 可以智能地调度不同类型的消息，非常适合用于领域事件处理。
在本文中，将通过一个简单的示例来介绍如何使用 MediatR 库在 .NET 8 项目中处理命令。我们将定义一个命令、一个处理器以及一个用于发送命令的服务，演示如何发送一个命令并处理它。
准备工作

1、创建项目
创建一个新的 .NET 8 WebAPI 标准项目，选择启用 OpenAPI 支持和使用控制器；

1. dotnet new console -n ManageCore.MediatrDemo
2. cd ManageCore.MediatrDemo

复制代码

2、添加 MediatR 包
使用以下命令添加 MediatR 包到项目中。

1. dotnet add package MediatR

复制代码

<img alt="">

实现示例

1、注册 MediatR
在 Program.cs 文件中，我们需要注册 MediatR 服务。

1. // Add services to the container.  
2. builder.Services.AddMediatR(mr =>{
3.    mr.RegisterServicesFromAssembly(typeof(Program).Assembly);
4. });

复制代码

2、创建通知类
在项目中定义了一个简单的通知类 InfoDemo，它是 INotification 接口的实现。

1. using MediatR;
3. namespace ManageCore.MediatrDemo
4. {
5.     public record InfoDemo(string Msg) : INotification;
6. }

复制代码

首先声明了一个名为 InfoDemo 的记录类型（record type）。
记录类型是一种特殊的类，主要用于表示不可变的数据类型，并提供了默认的实现来简化对象的创建和比较。

• public record InfoDemo(string Msg)：这里定义了一个名为 InfoDemo 的记录类型，它接受一个字符串类型的构造函数参数 Msg。这个参数将会成为 InfoDemo 类的一个只读属性。
  
• : INotification：这里指定了 InfoDemo 类实现了 INotification 接口。在 MediatR 中，INotification 接口用于标记一个类型作为通知（Notification）处理，这意味着这个类型将用于发送通知而不需要等待响应。
  

注意：这段代码定义了一个名为 InfoDemo 的通知类，它包含一个只读属性 Msg，用于携带消息文本。这个类可以被用来发送通知，而不期待任何响应或结果。在实际应用中，你可能会使用 MediatR 的 IMediator 接口来发送这种通知，并由其他组件来处理这些通知。
3、创建处理器类
创建一个通知处理器类 InfoDemoHandler ，用于处理通知并返回响应。
它是 INotificationHandler 接口的实现。
它接受一个 ILogger 类型的构造函数参数 _logger，并实现了 INotificationHandler 接口。INotificationHandler 接口是 MediatR 提供的接口，用于处理 T 类型的通知。

1. using MediatR;
3. namespace ManageCore.MediatrDemo
4. {
5.     /// <summary>
6.     /// 通知处理器类
7.     /// </summary>
8.     /// <param name="_logger"></param>
9.     public class InfoDemoHandler(ILogger<InfoDemoHandler> _logger) : INotificationHandler<InfoDemo>
10.     {
11.         /// <summary>
12.         ///
13.         /// </summary>
14.         /// <param name="notification"></param>
15.         /// <param name="cancellationToken"></param>
16.         /// <returns></returns>
17.         public Task Handle(InfoDemo notification, CancellationToken cancellationToken)
18.         {
19.             _logger.LogInformation($"InfoDemoHandler Received: {notification}. {DateTimeOffset.Now}");
20.             return Task.CompletedTask;
21.         }
22.     }
23. }

复制代码

这段代码实现了 INotificationHandler 接口，并在 Handle 方法中处理 InfoDemo 类型的通知。
当 MediatR 接收到 InfoDemo 类型的通知时，它会调用 InfoDemoHandler 的 Handle 方法来处理该通知。
4、创建控制器类
定义一个名为 MediatorDemoController 的 ASP.NET Core 控制器，使用 MediatR 发布通知。

1. using MediatR;
2. using Microsoft.AspNetCore.Mvc;
4. namespace ManageCore.MediatrDemo.Controllers
5. {
6.     [ApiController]
7.     [Route("[controller]")]
8.     public class MediatorDemoController : ControllerBase
9.     {
10.         private readonly IMediator mediator;
11.         private readonly ILogger<MediatorDemoController> _logger;
13.         /// <summary>
14.         ///初始化
15.         /// </summary>
16.         /// <param name="mediator"></param>
17.         /// <param name="logger"></param>
18.         public MediatorDemoController(IMediator mediator, ILogger<MediatorDemoController> logger)
19.         {
20.             this.mediator = mediator;
21.             _logger = logger;
22.         }
24.         /// <summary>
25.         /// MediatorDemo 方法
26.         /// </summary>
27.         /// <returns></returns>
28.         [HttpGet(Name = "MediatorDemoMethod")]
29.         public string MediatorDemoMethod()
30.         {
31.             var information = new InfoDemo("Mediator 控制器消息 ");
32.             mediator.Publish(information);
33.             _logger.LogInformation($"{DateTimeOffset.Now} : MediatorDemoController Send: {information}.");
34.             return $"Ok";
35.         }
36.     }
37. }

复制代码

说明：这段代码定义了一个名为MediatorDemoController 的控制器类，它使用 MediatR 发布了一个名为InfoDemo的通知。当调用MediatorDemoMethod方法时，它会创建一个InfoDemo类型的通知实例，通过mediator发布该通知，并记录一条日志。
运行示例

1、启动 ASP.NET Core 应用程序
启动应用程序后MediatorDemoController控制器将被注册，并且构造函数将被调用来注入IMediator和ILogger依赖项。
2、访问控制器方法
通过访问 /MediatorDemo的 GET 请求来调用MediatorDemoMethod方法。
3、创建并发布通知
在MediatorDemoMethod 方法中，创建一个InfoDemo 类型的通知实例，并通过mediator.Publish(information) 发布该通知。
4、处理通知
当通知被发布时，所有实现了INotificationHandler接口的处理器都会被调用来处理通知。
InfoDemoHandler 处理器会接收到通知，并通过日志记录器记录一条日志，显示接收到的通知及其时间戳。
5、记录日志
在控制器中，通过_logger.LogInformation记录一条日志，显示发送的通知及其时间戳。
6、返回响应
控制器方法返回"Ok"字符串，表示执行成功。
7、预期结果

<img alt="">

总结

通过这个简单的示例，可以在 .NET 8 应用程序中使用 MediatR 库来发布和处理通知，实现进程内的消息传递。这种方法有助于解耦组件，并使得应用程序更加模块化和可维护。示例不仅说明了如何使用 MediatR 来处理通知，还说明了如何实现通知处理模式。通过定义通知和处理器，我们可以将应用程序的不同部分解耦，使得代码更加清晰和易于维护。
最后

如果你觉得这篇文章对你有帮助，不妨点个赞支持一下！你的支持是我继续分享知识的动力。如果有任何疑问或需要进一步的帮助，欢迎随时留言。也可以加入微信公众号 [DotNet技术匠] 社区，与其他热爱技术的同行一起交流心得，共同成长！

 

来源:https://www.cnblogs.com/1312mn/p/18357288
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！