CodeWF.EventBus
CodeWF.EventBus 是一个轻量的进程内事件总线库，适合在 WPF、WinForms、Avalonia UI、ASP.NET Core 和控制台程序中做模块解耦。它支持 Command 命令分发，也支持 Query<T> 查询回传，便于实现简单 CQRS。
シーンに適した
- デスクトップアプリケーションモジュールは、互いのサービスやViewModelを直接参照したくありません。
- ASP.NET Coreでは、コントローラ、ビジネスプロセッサ、クエリロジックを軽量イベントバスで分割したいと考えています。
- コンソール、Win Forms、WPF、Avaloniaプロジェクトには統一IOCコンテナはありませんが、サブスクリプションパブリッシングでプロセスを切り離したいと考えています。
- 希望比
MediatR更小、更少框架约束，同时保留 Command/Query 思路。
パッケージの選択
| バッグバッグ。 | 適用可能なシーン |
|---|---|
CodeWF.EventBus |
IOCコンテナまたは手動サブスクリプションなし。 |
CodeWF.AspNetCore.EventBus |
ASP.NET Core / MS.DI。 |
CodeWF.DryIoc.EventBus |
DryIoc / Prism。 |
CodeWF.IOC.EventBus |
コールバックを介して登録および解決機能にアクセスする他のIOCコンテナ。 |
コア型
public abstract class Command
{
}
public abstract class Query<TResponse> : Command
{
public abstract TResponse Result { get; set; }
}
例として：
public sealed class CreateProductCommand : Command
{
public string Name { get; set; } = string.Empty;
public decimal Price { get; set; }
}
public sealed class ProductQuery : Query<ProductItemDto?>
{
public Guid ProductId { get; set; }
public override ProductItemDto? Result { get; set; }
}
プロセッサが書く。
事件处理方法使用 [EventHandler] 标记，参数只能有一个，且必须继承自 Command。返回值支持 void 和 Task，方法可以是 public、private 或 static。
[Event]
public sealed class ProductEventHandler
{
[EventHandler]
private async Task HandleCreateAsync(CreateProductCommand command)
{
await Task.CompletedTask;
}
[EventHandler(Order = 1)]
private void HandleQuery(ProductQuery query)
{
query.Result = new ProductItemDto
{
Id = query.ProductId,
Name = "Demo",
Price = 99
};
}
}
IOCコンテナなし
public sealed class MainViewModel
{
private readonly IEventBus _eventBus = EventBus.Default;
public MainViewModel()
{
_eventBus.Subscribe(this);
}
[EventHandler]
private void Handle(UpdateTimeCommand command)
{
Console.WriteLine(command.Time);
}
}
コマンドとクエリの発行：
await EventBus.Default.PublishAsync(new CreateProductCommand
{
Name = "XiaoMi",
Price = 8999
});
var product = await EventBus.Default.QueryAsync(new ProductQuery
{
ProductId = Guid.NewGuid()
});
インスタンス·オブジェクトが使用されなくなった場合は、アクティブにサブスクリプションを解除することをお勧めします
EventBus.Default.Unsubscribe(this);
ASP.NET Core
using CodeWF.AspNetCore.EventBus;
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddControllers();
builder.Services.AddEventBus();
var app = builder.Build();
app.MapControllers();
app.UseEventBus();
app.Run();
AddEventBus() 会扫描程序集中的 [Event] 类并注册到容器中，UseEventBus() 会把扫描得到的处理器接入事件总线。