- VisualStudio2022插件的安装及使用-编程手把手系列文章
- pprof-在现网场景怎么用
- C#实现的下拉多选框,下拉多选树,多级节点
- 【学习笔记】基础数据结构:猫树
MediatR 是 .NET 下的一个实现消息传递的库,轻量级、简洁高效,用于实现进程内的消息传递机制。它基于中介者设计模式,支持请求/响应、命令、查询、通知和事件等多种消息传递模式。通过泛型支持,MediatR 可以智能地调度不同类型的消息,非常适合用于领域事件处理.
在本文中,将通过一个简单的示例来介绍如何使用 MediatR 库在 .NET 8 项目中处理命令。我们将定义一个命令、一个处理器以及一个用于发送命令的服务,演示如何发送一个命令并处理它.
1、创建项目 。
创建一个新的 .NET 8 WebAPI 标准项目,选择启用 OpenAPI 支持和使用控制器; 。
dotnet new console -n ManageCore.MediatrDemo cd ManageCore.MediatrDemo
2、添加 MediatR 包 。
使用以下命令添加 MediatR 包到项目中.
dotnet add package MediatR
1、注册 MediatR 。
在 Program.cs 文件中,我们需要注册 MediatR 服务.
// Add services to the container. builder.Services.AddMediatR(mr =>{ mr.RegisterServicesFromAssembly(typeof(Program).Assembly); });
2、创建通知类 。
在项目中定义了一个简单的通知类 InfoDemo,它是 INotification 接口的实现.
using MediatR; namespace ManageCore.MediatrDemo { public record InfoDemo(string Msg) : INotification; }
首先声明了一个名为 InfoDemo 的记录类型(record type).
记录类型是一种特殊的类,主要用于表示不可变的数据类型,并提供了默认的实现来简化对象的创建和比较.
public record InfoDemo(string Msg)
:这里定义了一个名为 InfoDemo
的记录类型,它接受一个字符串类型的构造函数参数 Msg
。这个参数将会成为 InfoDemo
类的一个只读属性。: INotification
:这里指定了 InfoDemo
类实现了 INotification
接口。在 MediatR
中,INotification
接口用于标记一个类型作为通知(Notification)处理,这意味着这个类型将用于发送通知而不需要等待响应。注意:这段代码定义了一个名为 InfoDemo 的通知类,它包含一个只读属性 Msg,用于携带消息文本。这个类可以被用来发送通知,而不期待任何响应或结果。在实际应用中,你可能会使用 MediatR 的 IMediator 接口来发送这种通知,并由其他组件来处理这些通知.
3、创建处理器类 。
创建一个通知处理器类 InfoDemoHandler ,用于处理通知并返回响应.
它是 INotificationHandler<InfoDemo> 接口的实现.
它接受一个 ILogger<InfoDemoHandler> 类型的构造函数参数 _logger,并实现了 INotificationHandler<InfoDemo> 接口。INotificationHandler<T> 接口是 MediatR 提供的接口,用于处理 T 类型的通知.
using MediatR; namespace ManageCore.MediatrDemo { /// <summary> /// 通知处理器类 /// </summary> /// <param name="_logger"></param> public class InfoDemoHandler(ILogger<InfoDemoHandler> _logger) : INotificationHandler<InfoDemo> { /// <summary> /// /// </summary> /// <param name="notification"></param> /// <param name="cancellationToken"></param> /// <returns></returns> public Task Handle(InfoDemo notification, CancellationToken cancellationToken) { _logger.LogInformation($"InfoDemoHandler Received: {notification}. {DateTimeOffset.Now}"); return Task.CompletedTask; } } }
这段代码实现了 INotificationHandler<InfoDemo> 接口,并在 Handle 方法中处理 InfoDemo 类型的通知.
当 MediatR 接收到 InfoDemo 类型的通知时,它会调用 InfoDemoHandler 的 Handle 方法来处理该通知.
4、创建控制器类 。
定义一个名为 MediatorDemoController 的 ASP.NET Core 控制器,使用 MediatR 发布通知.
using MediatR; using Microsoft.AspNetCore.Mvc; namespace ManageCore.MediatrDemo.Controllers { [ApiController] [Route("[controller]")] public class MediatorDemoController : ControllerBase { private readonly IMediator mediator; private readonly ILogger<MediatorDemoController> _logger; /// <summary> ///初始化 /// </summary> /// <param name="mediator"></param> /// <param name="logger"></param> public MediatorDemoController(IMediator mediator, ILogger<MediatorDemoController> logger) { this.mediator = mediator; _logger = logger; } /// <summary> /// MediatorDemo 方法 /// </summary> /// <returns></returns> [HttpGet(Name = "MediatorDemoMethod")] public string MediatorDemoMethod() { var information = new InfoDemo("Mediator 控制器消息 "); mediator.Publish(information); _logger.LogInformation($"{DateTimeOffset.Now} : MediatorDemoController Send: {information}."); return $"Ok"; } } }
说明:这段代码定义了一个名为MediatorDemoController 的控制器类,它使用 MediatR 发布了一个名为InfoDemo的通知。当调用MediatorDemoMethod方法时,它会创建一个InfoDemo类型的通知实例,通过mediator发布该通知,并记录一条日志.
1、启动 ASP.NET Core 应用程序 。
启动应用程序后MediatorDemoController控制器将被注册,并且构造函数将被调用来注入IMediator和ILogger<MediatorDemoController>依赖项.
2、访问控制器方法 。
通过访问 /MediatorDemo的 GET 请求来调用MediatorDemoMethod方法.
3、创建并发布通知 。
在MediatorDemoMethod 方法中,创建一个InfoDemo 类型的通知实例,并通过mediator.Publish(information) 发布该通知.
4、处理通知 。
当通知被发布时,所有实现了INotificationHandler<InfoDemo>接口的处理器都会被调用来处理通知.
InfoDemoHandler 处理器会接收到通知,并通过日志记录器记录一条日志,显示接收到的通知及其时间戳.
5、记录日志 。
在控制器中,通过_logger.LogInformation记录一条日志,显示发送的通知及其时间戳.
6、返回响应 。
控制器方法返回"Ok"字符串,表示执行成功.
7、预期结果 。
通过这个简单的示例,可以在 .NET 8 应用程序中使用 MediatR 库来发布和处理通知,实现进程内的消息传递。这种方法有助于解耦组件,并使得应用程序更加模块化和可维护。示例不仅说明了如何使用 MediatR 来处理通知,还说明了如何实现通知处理模式。通过定义通知和处理器,我们可以将应用程序的不同部分解耦,使得代码更加清晰和易于维护.
如果你觉得这篇文章对你有帮助,不妨点个赞支持一下!你的支持是我继续分享知识的动力。如果有任何疑问或需要进一步的帮助,欢迎随时留言。也可以加入微信公众号 [DotNet技术匠] 社区,与其他热爱技术的同行一起交流心得,共同成长! 。
。
最后此篇关于.NET8中利用MediatR实现高效消息传递的文章就讲到这里了,如果你想了解更多关于.NET8中利用MediatR实现高效消息传递的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
在后台开启了“URL Rewrite”,看起来一切正常,可是点击某一栏目的时候却怎么都进不去,显示的依然是论坛的首页。看了一下论坛目录下,原来这下面并没有自己的.htaccess文件,所以默认使用的
本文实例为大家分享了.net发送邮件的实现代码,供大家参考,具体内容如下 关键代码: 需要引用命名空间: using System.Net.Mail; using System.Net;
今天的一个小测试是老师让用.NET用控件来制作一个拉菜单要求如下: 将鼠标移到父菜单上弹出3个子菜单,而且每个子菜单都有超链接。 以下是我自己做的代码: 复制代
我有以下内容 static const unsigned int chromosome = 6; double bestFitness[chromosomes]; for(int i = 0; i
关于附图,我需要一个计算算法来将 A 轴向下移动 n 英寸,将 B 轴从左向右移动 m 英寸,以便组件圆 D 遵循抛物线的曲线;圆 D 并不总是 10 英寸,可以更小。我不是数学专业的,所以这对我来说
我正在尝试利用我的格式字符串错误,它存在于这个程序中: #include #include #include #include #include void foo(char* tmp, ch
用Matplotlib和Seaborn这类Python库可以画出很好看的图,但是这些图只是静态的,难以动态且美观地呈现数值变化。要是在你下次的演示、视频、社交媒体Po文里能用短视频呈现数据变化,是不
1、进程介绍 进程:正在执行的程序,由程序、数据和进程控制块组成,是正在执行的程序,程序的一次执行过程,是资源调度的基本单位。 程序:没有执行的代码,是一个静态的。 2、线程
1、前言 在开发过程中,有时会遇到需要控制任务并发执行数量的需求。 例如一个爬虫程序,可以通过限制其并发任务数量来降低请求频率,从而避免由于请求过于频繁被封禁问题的发生。 接下来
Opera 管理着一个漏洞赏金计划,研究人员可以在该计划中报告 Opera 软件中的漏洞并获得奖励。 这篇文章就是我发现的一个漏洞——网页可能会从用户那里检索本地文件的屏幕截图。 考虑到 O
C++ 文件查找 在C++中我们要如何查找文件呢?我们需要一个结构体和几个大家可能不太熟悉的函数。这些函数和结构体在的头文件中,结构体为struct _finddata_t ,函数为_findfi
1、前言 本文利用 fsockopen() 函数,编写一个功能简单的端口扫描器。 2、关键技术 本实例的端口号是固定的,通过对数组的遍历,利用 fsockopen() 函数连接,如果连接成功,
最近在将一些项目的rest api迁移到.net core中,最开始是用的Nginx做反向代理,将已经完成切换的部分切入系统,如下图所示: 由于迁移过程中也在进行代码重构,需要经常比较频繁的测
前言 最近学习了python,感觉挺多地方能用到它的。打包 测试 上传 爬电影....而且代码量是真少。人生苦短,我用python。而今天写的这个是因为下载电影时总会发现除了视频还会有这两个文件,
1、Monkey测试简介 Monkey测试是Android平台自动化测试的一种手段,通过Monkey程序模拟用户触摸屏幕、滑动Trackball、按键等操作来对设备上的程序进行压力测试,检测程序
一直想写一套生成静态页面的文章系统 但面对生成静态后的一些复杂数据库交互问题。又望而却步! 于是就想 有没有 在不耽误数据交互的情况下,而又能降低服务器负
Qt 利用大量第 3 方库进行图像编码、压缩、加密、音频和视频编解码器支持等。 从历史上看,当我想使用它们时,我总是必须将它们作为附加依赖项包含在内。我一直想知道是否有一种方法可以简单地重用 Qt 已
我想知道是否可以使用属性将功能“混合”到类/方法/属性中。 就像是: [TrackChanges] public Foo { get; set; } 如果可能的话,有谁会如何实现? 最佳答
有些站点位于共享主机(Windows 2003 Server)上,因此我无法访问服务器配置。 我到处都读到关于杠杆浏览器缓存的信息,特别是静态文件(jpg,css,js等)的信息,但是...在我的情况
我想在我的项目中使用 Julia 的主要原因之一是它的速度,尤其是在计算积分方面。 我想在某个区间 [a,b] 上积分一维函数 f(x)。一般来说,Julia 的 quadgk 函数将是一个快速而准确
我是一名优秀的程序员,十分优秀!