HMENetCore.EventBus 6.0.48

HMENetCore.EventBus

简介

HMENetCore.EventBus 是一个用于应用程序各部分之间通过事件进行解耦通信的组件。它允许发布者发布事件，同时订阅者监听并处理这些事件，而无需直接相互引用。

.NET支持

• 跨平台支持: Supports .NET Standard 2.1, .NET 6, .NET 8, and .NET 9.

安装

dotnet add package HMENetCore.EventBus --version 6.0.48

快速入门

服务注册

builder.Services.AddEventBus(
    config: builder.Configuration.Get<RabbitMQEventBusConfig>()!,
    eventHandlerTypes: Assembly.GetExecutingAssembly()
        .GetTypes()
        .Where(t => t.IsClass && !t.IsAbstract 
               && typeof(IIntegrationEventHandler).IsAssignableFrom(t))
);

事件发布

public record OrderEvent(string OrderId, decimal Amount, DateTime CreatedAt);
public class OrderService
{
    private readonly IEventBus _eventBus; 
    public async Task UpdateOrder(OrderEvent Order)
    {
        await _eventBus.PublishAsync("OrderEvent", 
            new OrderEvent(Order.OrderId, Order.Amount));
    }
}

订阅事件处理方式

1. 基础接口实现

/// <summary>
/// 直接实现IIntegrationEventHandler
/// </summary>
[EventName("UserUpdated")]
public class BasicHandler : IIntegrationEventHandler
{

    public async Task Handle(string eventName, string eventData)
    {
        // 处理逻辑
        Console.WriteLine($"收到事件：{eventName}，数据：{eventData}");
    }
}

2. 强类型处理（推荐）

/// <summary>
/// 继承JsonIntegrationEventHandler
/// </summary>
[EventName("OrderEvent")]
public class TypedHandler : JsonIntegrationEventHandler<OrderEvent>
{

    public override Task HandleJson(string eventName, OrderEvent eventData)
    {
        // 通过eventData.OrderId访问强类型数据
        return Task.CompletedTask;
    }
}

3. 动态JSON处理

/// <summary>
/// 继承DynamicIntegrationEventHandler
/// </summary>
[EventName("PaymentProcessed")]
public class DynamicHandler : DynamicIntegrationEventHandler
{

    public override Task HandleDynamic(string eventName, JsonElement eventData)
    {
        var amount = eventData.GetProperty("Amount").GetDecimal();
        // 处理逻辑
        Console.WriteLine($"收到事件：{eventName}，数据：{amount}");
    }
}

批量订阅

[EventName("xxxx")]
[EventName("xxxxxx")]
public class OrderEventHandler : IIntegrationEventHandler
{

    public async Task Handle(string eventName, string eventData)
    {
        switch(eventName)
        {
            case "OrderCreated":
                // 处理逻辑...
                break;
            case "OrderCancelled":
                // 处理逻辑...
                break;
        }
    }
}

实践

事件设计

📌 使用过去时态命名（如OrderShipped） 📌 事件类声明为readonly record 📌 包含完整的上下文信息

错误处理

⚠️ 业务异常应被捕获处理 🔄 系统异常会自动重试3次

性能优化

🚀 高频事件使用批量处理模式 💾 大消息体考虑使用外部存储