悠悠楠杉
网站页面
.NET 8 中如何利用 MediatR 实现高效消息传递
06/11
首先，你需要在你的.NET 8项目中安装MediatR。通过NuGet包管理器安装是最简单的办法：
bash
dotnet add package MediatR --version 7.0.0
步骤二：定义消息
在MediatR中，首先定义一个或多个消息（通常是类），这些类将作为不同组件间通信的载体。
```csharp
public class GetArticleRequest : IRequest
{
public string Title { get; set; }
public string Keyword { get; set; }
public string Description { get; set; }
}
public class GetArticleResponse
{
public string ArticleBody { get; set; } = string.Empty;
}
```
步骤三：创建消息处理器
接下来，为每个消息创建一个处理器（Handler），这通常是处理逻辑的地方。
```csharp
public class GetArticleHandler : IRequestHandler<GetArticleRequest, GetArticleResponse>
{
private readonly IMemoryCache _cache; // 假设我们使用IMemoryCache来缓存数据
private readonly IArticleService _articleService; // 假设我们有一个服务来获取文章内容
public GetArticleHandler(IMemoryCache cache, IArticleService articleService)
{
_cache = cache;
_articleService = articleService;
}
public Task<GetArticleResponse> Handle(GetArticleRequest request, CancellationToken cancellationToken)
{
// 从缓存或服务中获取文章内容，并设置到响应中返回
var cachedArticle = _cache.Get<string>(request.Title); // 假设缓存中有文章内容
if (cachedArticle != null) return Task.FromResult(new GetArticleResponse { ArticleBody = cachedArticle }); // 使用缓存内容直接返回结果
var articleBody = _articleService.GetArticleContent(request.Title); // 从服务获取文章内容，然后缓存起来并返回结果，这里略去了错误处理和缓存逻辑的详细实现。
_cache.Set(request.Title, articleBody); // 缓存文章内容以便下次使用
return Task.FromResult(new GetArticleResponse { ArticleBody = articleBody }); // 返回新获取的文章内容
}
}
```
步骤四：注册服务和中介者处理器到依赖注入容器中
在你的依赖注入配置中注册GetArticleHandler和相关的服务。例如，在Startup.cs中：
csharp
public void ConfigureServices(IServiceCollection services)
{
services.AddMediatR(typeof(Startup).Assembly); // 注册所有中介者处理器和服务接口到依赖注入容器中。这需要确保所有相关的类都标记为可用（例如通过IServiceCollectionExtensions）。
services.AddMemoryCache(); // 添加内存缓存服务，如果需要的话。 你的 IMemoryCache 将用于这里作为示例。
// 其他服务注册逻辑...
}
