分布式事件

2025-09-25

267 words

1 min

分布式事件总线系统允许发布和订阅跨应用/服务边界传输的事件. 你可以使用分布式事件总线在微服务或应用程序之间异步发送和接收消息.

安装

• 添加以下 NuGet 包到你的项目(host层)
  • Lion.AbpPro.CAP
  • Lion.AbpPro.CAP.EntityFrameworkCore
  • DotNetCore.CAP.MySql (如果是其它数据库,请安装对应类型)
  • DotNetCore.CAP.RabbitMQ (如果是其它中间件,请安装对应类型)
• 添加 [DependsOn(typeof(AbpProCapEntityFrameworkCoreModule))] 到你的项目模块类.

添加模块

    [DependsOn(
        typeof(AbpProCapModule),
        typeof(AbpProCapEntityFrameworkCoreModule)
    )]
    public partial class AbpProHttpApiHostModule : AbpModule

注册服务

在(host层) Mysql,和 RabbitMq 为例

public override void ConfigureServices(ServiceConfigurationContext context)
{
    context.Services.AddAbpProCap()
}

配置

"Cap": {
    "RabbitMq": {
      "HostName": "localhost",
      "UserName": "admin",
      "Password": "1q2w3E*",
      "Port": 5672
    }
  }

发布事件

namespace AbpDemo
{
    public class MyService : ITransientDependency
    {
        private readonly IDistributedEventBus _distributedEventBus;

        public MyService(IDistributedEventBus distributedEventBus)
        {
            _distributedEventBus = distributedEventBus;
        }
        
        public virtual async Task ChangeStockCountAsync(Guid productId, int newCount)
        {
            await _distributedEventBus.PublishAsync(
                new StockCountChangedEto
                {
                    ProductId = productId,
                    NewCount = newCount
                }
            );
        }
    }
}

订阅事件

namespace AbpDemo
{
    public class MyHandler
        : IDistributedEventHandler<StockCountChangedEto>,
          ITransientDependency
    {
        public async Task HandleEventAsync(StockCountChangedEto eventData)
        {
            var productId = eventData.ProductId;
            // todo: 处理事件
        }
    }
}

发布延迟事件

订阅延迟事件