Sparkdo.EventBus.RabbitMQ 1.0.0

Sparkdo.EventBus.RabbitMQ

Sparkdo RabbitMQ 事件总线实现，提供基于 RabbitMQ 的分布式事件发布和订阅功能。

功能特性

• 基于 RabbitMQ 的分布式事件总线实现
• 支持事件的发布和订阅
• 支持发件箱和收件箱模式
• 支持工作单元集成
• 支持多租户
• 支持事件追踪和关联ID
• 与 Sparkdo 框架无缝集成

安装

<PackageReference Include="Sparkdo.EventBus.RabbitMQ" Version="x.x.x" />

核心组件

RabbitMqDistributedEventBus

RabbitMQ 分布式事件总线核心实现类，继承自 DistributedEventBusBase 并实现了 IRabbitMqDistributedEventBus 接口：

• InitializeAsync(): 初始化事件总线，创建消费者并绑定队列
• PublishAsync(): 发布事件到 RabbitMQ
• Subscribe(): 订阅事件处理程序
• Unsubscribe(): 取消订阅事件处理程序

SparkdoRabbitMqEventBusOptions

RabbitMQ 事件总线配置选项类，用于配置 RabbitMQ 相关参数：

• ConnectionName: RabbitMQ 连接名称
• ClientName: 客户端名称
• ExchangeName: 交换机名称
• ExchangeType: 交换机类型
• PrefetchCount: 预取计数
• QueueArguments: 队列参数
• ExchangeArguments: 交换机参数

SparkdoEventBusRabbitMqModule

RabbitMQ 事件总线模块配置类，负责注册相关服务：

• 配置 RabbitMQ 事件总线选项
• 注册事件总线服务
• 初始化事件总线

配置

在 appsettings.json 中配置 RabbitMQ 事件总线：

{
  "Sparkdo": {
    "RabbitMQ": {
      "EventBus": {
        "ClientName": "MyApp",
        "ExchangeName": "MyExchange",
        "ConnectionName": "Default"
      }
    }
  }
}

使用示例

发布事件

public class MyService
{
    private readonly IDistributedEventBus _eventBus;

    public MyService(IDistributedEventBus eventBus)
    {
        _eventBus = eventBus;
    }

    public async Task PublishEventAsync()
    {
        var eventData = new MyEventData { Message = "Hello World" };
        await _eventBus.PublishAsync(eventData);
    }
}

订阅事件

public class MyEventHandler : IDistributedEventHandler<MyEventData>
{
    public async Task HandleEventAsync(MyEventData eventData)
    {
        // 处理事件
        Console.WriteLine($"Received event: {eventData.Message}");
    }
}

// 在模块中注册事件处理器
public class MyModule : Module
{
    public override void Configure(IConfigureContext context)
    {
        context.Services.AddTransient<MyEventHandler>();
    }
}

扩展性

该库提供了完整的 RabbitMQ 事件总线实现，可以通过以下方式扩展：

1. 自定义事件序列化器实现 IRabbitMqSerializer 接口
2. 自定义消息消费者实现 IRabbitMqMessageConsumer 接口
3. 通过 SparkdoRabbitMqEventBusOptions 配置事件总线行为
4. 实现自定义的事件处理器

代码结构说明

本项目包含以下主要组件：

核心实现

• RabbitMqDistributedEventBus: RabbitMQ 分布式事件总线实现
• SparkdoRabbitMqEventBusOptions: RabbitMQ 事件总线配置选项
• IRabbitMqDistributedEventBus: RabbitMQ 分布式事件总线接口

配置

• SparkdoEventBusRabbitMqModule: RabbitMQ 事件总线模块
• PostConfigureSparkdoRabbitMqEventBusOptions: RabbitMQ 事件总线选项后配置

接口抽象

• IRabbitMqDistributedEventBus: RabbitMQ 分布式事件总线接口

所有公共接口和类都添加了详细的 XML 文档注释，便于开发者理解和使用。