ASP.NET Core基於微軟微服務eShopOnContainer事件總線EventBus的實現

這個EventBus的實現是基於微軟微服務https://github.com/dotnet-architecture/eShopOnContainers項目的，我把它從項目中抽離出來，打包成nuget包方便大家快速集成到項目中

從Nuget.org中安裝

PM> Install-Package Toosame.EventBus.RabbitMQ -Version 1.1.2

使用

共3步：

1. 添加事件
2. 添加事件處理器
3. 從控制器發布事件

1.添加事件

創建YourEvent.cs文件

public class YourEvent : IntegrationEvent
{
    public string Name { get; set; }

    public int Age { get; set; }
}

1.添加事件處理器

創建YourEventHandler.cs文件

public class YourEventHandler : IIntegrationEventHandler<YourEvent>
{
    private readonly IConfiguration _configuration;

    public YourEventHandler(IConfiguration configuration){
        //這里只是告訴你，可以使用依賴注入的服務.
        _configuration = configuration;
    }

    public Task Handle(YourEvent @event)
    {
        //你可以拿到 @event.Name
        //你可以拿到 @event.Age

        //實現你自己的事件處理邏輯...
    
        return Task.CompletedTask;
    }
}

1.從控制器中發布事件

剛剛創建了一個事件，並且添加了事件處理器來處理事件，這里演示了如何發布事件；雖然剛剛添加了事件處理器，但是沒有將事件處理器注冊到ASP.NET Core中，下面的安裝環境將演示如何注冊。

public class HomeController : Controller
{
    private readonly IEventBus _eventBus;

    public YourEventHandler(IEventBus eventBus){
        _eventBus = eventBus;
    }

    [HttpGet]
    public IAcionResult Index(){
        _eventBus.Publish(new YourEvent(){
            Name: "my name",
            Age: 22
        })
    }
}

安裝：注冊事件和事件處理器

共2步：

　　1.配置appsettings.json

　　2.在Startup.cs中安裝

1.配置appsettings.json

{
  "Logging": {
    "LogLevel": {
      "Default": "Warning"
    }
  },
  "RabbitMQ": {
    "EventBusConnection": "<yourRabbitMqHost>[:port(default 5672)]",
    "EventBusUserName": "<rabbitMqUserName>",
    "EventBusPassword": "<rabbitMqPassword>",
    "EventBusRetryCount": 5,
    "EventBusBrokeName": "<rabbitMqExchangeName>",
    "SubscriptionClientName": "<queueName>" //在微服務中，不同的微服務的應該是不同的名字
  }
}

2.在Startup.cs中安裝

 

經典安裝：

public void ConfigureServices(IServiceCollection services)
{
    services.AddEventBus(Configuration.GetSection("RabbitMQ").Get<RabbitMQOption>(),
                    eventHandlers =>
                    {
                        eventHandlers.AddEventHandler<YourEventHandler1>();
                        eventHandlers.AddEventHandler<YourEventHandler2>();
                    });

    services.AddMvc()
        .SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
}

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
{
    app.UseEventBus(eventBus =>
    {
        eventBus.Subscribe<YourEvent1, YourEventHandler1>();
        eventBus.Subscribe<YourEvent2, YourEventHandler2>();
    });

    app.UseMvc();
}

請把YourEvent和YourEventHandler換成你自己的事件和事件處理器

使用Autofac安裝：

請先安裝Autofac.Extensions.DependencyInjection這個包再使用以下代碼

public IServiceProvider ConfigureServices(IServiceCollection services)
{
    services.AddMvc()
        .SetCompatibilityVersion(CompatibilityVersion.Version_2_2)
        .AddControllersAsServices();

    return services.AddEventBusAsAutofacService(Configuration.GetSection("RabbitMQ").Get<RabbitMQOption>(),
                eventHandlers =>
            {
                eventHandlers.AddEventHandler<YourEventHandler1>();
                eventHandlers.AddEventHandler<YourEventHandler2>();
            });
}


public void Configure(IApplicationBuilder app, IHostingEnvironment env)
{
    app.UseEventBus(eventBus =>
    {
        eventBus.Subscribe<YourEvent1, YourEventHandler1>();
        eventBus.Subscribe<YourEvent2, YourEventHandler2>();
    });

    app.UseMvc();
}

這樣剛剛我們創建的EventHandler就能正常的收到事件了；

注意：不同微服務通過事件總線交換消息，Event的名字在不同的微服務項目中必須一致，因為RabbitMQ是通過事件名找隊列（一個隊列對應一個微服務）

項目github:https://github.com/lhdboy/Toosame.EventBus