MediatR让进程内通信如此简单，基于MediatR实现事件订阅发布功能("简化进程内通信：基于MediatR实现高效事件订阅发布功能")

原创

ithorizon 7个月前 (10-20) 阅读数 20 #后端开发

简化进程内通信：基于MediatR实现高效事件订阅发布功能

在现代软件架构中，进程内通信是尽也许减少损耗系统解耦、攀升模块自由性的关键因素。MediatR 是一个简洁且强势的请求-响应中介者模式实现，它让进程内通信变得更加简洁。本文将详细介绍怎样基于 MediatR 实现事件订阅发布功能，从而简化进程内通信。

一、MediatR 简介

MediatR 是一个用于进程内通信的库，它基于中介者模式，允许开发者定义请求和处理程序之间的松耦合关系。MediatR 适用于 C# 编程语言，并且已经被广泛应用于各种大型项目中。它提供了以下优点：

解耦请求发送者和接收者

易于扩展和维护

拥护异步处理

内置失误处理和日志记录

二、事件订阅发布模式

事件订阅发布模式是一种常见的进程内通信行为，它允许发布者将事件通知给一个或多个订阅者。这种模式可以有效地降低模块间的耦合度，尽也许减少损耗系统的可扩展性。下面我们将使用 MediatR 来实现这一功能。

三、实现步骤

1. 创建项目并安装 MediatR NuGet 包


dotnet new console -n MediatREventDemo
cd MediatREventDemo
dotnet add package MediatR

2. 定义事件和事件处理程序


public record MyEvent(string Message);
public class MyEventHandler : INotificationHandler
{
    public Task Handle(MyEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"Received event with message: {notification.Message}");
        return Task.CompletedTask;
    }
}

3. 配置 MediatR 服务


public class Program
{
    public static void Main(string[] args)
    {
        var mediator = new MediatorBuilder()
            .RegisterServices(serviceCollection =>
            {
                serviceCollection.AddMediatR(typeof(Program).Assembly);
            })
            .Build();
        mediator.Publish(new MyEvent("Hello, MediatR!"));
    }
}

4. 运行程序，观察输出于是

Received event with message: Hello, MediatR!

四、事件订阅发布进阶

在实际项目中，我们也许需要处理多种事件，并且也许需要对事件进行分类。MediatR 拥护多种事件处理程序，并且可以轻松扩展。以下是一个进阶示例：

1. 定义不同类型的事件


public record UserCreatedEvent(string UserId, string UserName);
public record UserDeletedEvent(string UserId);

2. 创建相应的事件处理程序


public class UserCreatedEventHandler : INotificationHandler
{
    public Task Handle(UserCreatedEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"User {notification.UserName} with ID {notification.UserId} was created.");
        return Task.CompletedTask;
    }
}
public class UserDeletedEventHandler : INotificationHandler
{
    public Task Handle(UserDeletedEvent notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"User with ID {notification.UserId} was deleted.");
        return Task.CompletedTask;
    }
}

3. 配置 MediatR 服务并发布事件


public class Program
{
    public static void Main(string[] args)
    {
        var mediator = new MediatorBuilder()
            .RegisterServices(serviceCollection =>
            {
                serviceCollection.AddMediatR(typeof(Program).Assembly);
            })
            .Build();
        mediator.Publish(new UserCreatedEvent("123", "Alice"));
        mediator.Publish(new UserDeletedEvent("123"));
    }
}

4. 运行程序，观察输出于是

User Alice with ID 123 was created.

User with ID 123 was deleted.