EventBusToolkit 1.0.0

EventBusToolkit

EventBusToolkit 是一个进程内、最佳努力的事件总线类库，目标框架为 netstandard2.0。

快速使用

IEventBus bus = EventBusFactory.Create(builder => builder
    .Register<UserCreatedEvent, UserCreatedHandler>());

bus.Publish(new UserCreatedEvent("alice"));
await bus.PublishAsync(new UserCreatedEvent("alice"));

EventEnvelope<UserCreatedEvent> envelope = new EventEnvelope<UserCreatedEvent>(new UserCreatedEvent("alice"));
bus.PublishEnvelope(envelope);
await bus.PublishEnvelopeAsync(envelope);

更方便的入口

如果你想减少样板代码，可以直接使用 EventBusFactory.Create(...)：

IEventBus bus = EventBusFactory.Create(builder => builder
    .ContinueOnHandlerException()
    .Register<UserCreatedEvent, UserCreatedHandler>());

UserCreatedEvent eventData = new UserCreatedEvent("alice");
EventEnvelope<UserCreatedEvent> envelope = new EventEnvelope<UserCreatedEvent>(eventData);

bus.Publish(eventData);
bus.PublishEnvelope(envelope);

如果需要分步构建，也可以直接使用 EventBusBuilder：

EventBusBuilder builder = EventBusFactory.CreateBuilder();
builder.UseParallelDispatch();
builder.Register<UserCreatedEvent, UserCreatedHandler>();

IEventBus bus = builder.Build();

轻量 DI 接入

using EventBusToolkit;
using Microsoft.Extensions.DependencyInjection;

ServiceCollection services = new ServiceCollection();
services.AddEventBusToolkit(builder => builder.Register<UserCreatedEvent, UserCreatedHandler>());

事件上下文

EventContext 用来携带事件的元数据和扩展数据。

• EventId、CorrelationId、OccurredAtUtc 会在发布时自动补齐

EventContext context = new EventContext();
context.Items["source"] = "api";

await bus.PublishAsync(new UserCreatedEvent("alice"), context);

await bus.PublishAsync(new UserCreatedEvent("bob"), context);

日志钩子

如果你想记录总线边界日志，可以实现 IEventBusLogger 并赋给 EventBusOptions.Logger：

public sealed class ConsoleEventBusLogger : IEventBusLogger
{
    public void Log(EventBusLogEntry entry)
    {
        Console.WriteLine($"[{entry.Level}] {entry.Message} {entry.EventType?.Name}");
    }
}

EventBusOptions options = new EventBusOptions
{
    Logger = new ConsoleEventBusLogger()
};

IEventBus bus = new EventBus(new EventHandlerRegistry(), options);

回调里拿到的是一个轻量的 EventBusLogEntry，里面包含：

• Level
• Message
• EventType
• HandlerType
• Context
• HandlerCount
• Duration
• Exception

文档

• 快速示例
• 开发记录