CodeWF.EventBus
CodeWF.EventBus 是一个轻量的进程内事件总线库，适合在 WPF、WinForms、Avalonia UI、ASP.NET Core 和控制台程序中做模块解耦。它支持 Command 命令分发，也支持 Query<T> 查询回传，便于实现简单 CQRS。
適合場景
- 桌面應用模塊之間不想直接引用彼此的服務或 viewmodel。
- asp.net core 中希望用輕量事件總線拆分控制器、業務處理器和查詢邏輯。
- 控制台、winforms、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() 会把扫描得到的处理器接入事件总线。