经验总结

  1. 首页 > 生活 > >

MASA Framework -- EventBus入门与设计

生活百科

概述事件总线是一种事件发布/订阅结构，通过发布订阅模式可以解耦不同架构层级，同样它也可以来解决业务之间的耦合，它有以下优点

  • 松耦合
  • 横切关注点
  • 可测试性
  • 事件驱动
发布订阅模式通过下图我们可以快速了解发布订阅模式的本质
  1. 订阅者将自己关心的事件在调度中心进行注册
  2. 事件的发布者通过调度中心把事件发布出去
  3. 订阅者收到自己关心的事件变更并执行相对应业务
  4. 其中发布者无需知道订阅者是谁，订阅者彼此之间也互不认识，彼此之间互不干扰
事件总线类型在Masa Framework中，将事件划分为
  • 进程内事件 (Event)
本地事件，它的发布与订阅需要在同一个进程中，订阅方与发布方需要在同一个项目中
  • 跨进程事件 (IntegrationEvent)
【MASA Framework -- EventBus入门与设计】集成事件，它的发布与订阅一定不在同一个进程中，订阅方与发布方可以在同一个项目中，也可以在不同的项目中
下面我们会用一个注册用户的例子来说明如何使用本地事件
入门
  • 安装.NET 6.0
  1. 新建ASP.NET Core 空项目Assignment.InProcessEventBus，并安装Masa.Contrib.Dispatcher.Events
dotnet new web -o Assignment.InProcessEventBuscd Assignment.InProcessEventBusdotnet add package Masa.Contrib.Dispatcher.Events --version 0.7.0-preview.7
  1. 注册EventBus (用于发布本地事件), 修改Program.cs
builder.Services.AddEventBus();
  1. 新增RegisterUserEvent类并继承Event，用于发布注册用户事件
public record RegisterEvent : Event{    public string Account { get; set; }    public string Email { get; set; }    public string Password { get; set; }}
  1. 新增注册用户处理程序
在指定事件处理程序方法上增加特性 EventHandler，并在方法中增加参数 RegisterUserEvent
public class UserHandler{    private readonly ILogger<UserHandler>? _logger;    public UserHandler(ILogger<UserHandler>? logger = null)    {        //todo: 根据需要可在构造函数中注入其它服务 (需支持从DI获取)        _logger = logger;    }    [EventHandler]    public void RegisterUser(RegisterUserEvent @event)    {        //todo: 1. 编写注册用户业务        _logger?.LogDebug("-----------{Message}-----------", "检测用户是否存在并注册用户");        //todo: 2. 编写发送注册通知等        _logger?.LogDebug("-----------{Account} 注册成功 {Message}-----------", @event.Account, "发送邮件提示注册成功");    }}
注册用户的处理程序可以放到任意一个类中，但其构造函数参数必须支持从DI获取，且处理程序的方法仅支持 Task或 Void 两种, 不支持其它类型

经验总结扩展阅读


上一篇：MindSpore Graph Learning

下一篇：篮球锻炼腿部肌肉的方法 篮球腿部训练方法