欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

ASP.NET Core基于微软微服务eShopOnContainer事件总线EventBus的实现

程序员文章站 2023-11-24 18:39:10
这个EventBus的实现是基于微软微服务https://github.com/dotnet-architecture/eShopOnContainers项目的,我把它从项目中抽离出来,打包成nuget包方便大家快速集成到项目中 从Nuget.org中安装 使用 共3步: 1.添加事件 创建Your ......

这个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文件

1 public class yourevent : integrationevent
2 {
3     public string name { get; set; }
4 
5     public int age { get; set; }
6 }

1.添加事件处理器

创建youreventhandler.cs文件

 1 public class youreventhandler : iintegrationeventhandler<yourevent>
 2 {
 3     private readonly iconfiguration _configuration;
 4 
 5     public youreventhandler(iconfiguration configuration){
 6         //这里只是告诉你,可以使用依赖注入的服务.
 7         _configuration = configuration;
 8     }
 9 
10     public task handle(yourevent @event)
11     {
12         //你可以拿到 @event.name
13         //你可以拿到 @event.age
14 
15         //实现你自己的事件处理逻辑...
16     
17         return task.completedtask;
18     }
19 }

1.从控制器中发布事件

刚刚创建了一个事件,并且添加了事件处理器来处理事件,这里演示了如何发布事件;虽然刚刚添加了事件处理器,但是没有将事件处理器注册到asp.net core中,下面的安装环境将演示如何注册。

 1 public class homecontroller : controller
 2 {
 3     private readonly ieventbus _eventbus;
 4 
 5     public youreventhandler(ieventbus eventbus){
 6         _eventbus = eventbus;
 7     }
 8 
 9     [httpget]
10     public iacionresult index(){
11         _eventbus.publish(new yourevent(){
12             name: "my name",
13             age: 22
14         })
15     }
16 }

安装:注册事件和事件处理器

共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中安装

 

经典安装:

 1 public void configureservices(iservicecollection services)
 2 {
 3     services.addeventbus(configuration.getsection("rabbitmq").get<rabbitmqoption>(),
 4                     eventhandlers =>
 5                     {
 6                         eventhandlers.addeventhandler<youreventhandler1>();
 7                         eventhandlers.addeventhandler<youreventhandler2>();
 8                     });
 9 
10     services.addmvc()
11         .setcompatibilityversion(compatibilityversion.version_2_2);
12 }
13 
14 public void configure(iapplicationbuilder app, ihostingenvironment env)
15 {
16     app.useeventbus(eventbus =>
17     {
18         eventbus.subscribe<yourevent1, youreventhandler1>();
19         eventbus.subscribe<yourevent2, youreventhandler2>();
20     });
21 
22     app.usemvc();
23 }

请把yourevent和youreventhandler换成你自己的事件和事件处理器

使用autofac安装:

请先安装autofac.extensions.dependencyinjection这个包再使用以下代码

 1 public iserviceprovider configureservices(iservicecollection services)
 2 {
 3     services.addmvc()
 4         .setcompatibilityversion(compatibilityversion.version_2_2)
 5         .addcontrollersasservices();
 6 
 7     return services.addeventbusasautofacservice(configuration.getsection("rabbitmq").get<rabbitmqoption>(),
 8                 eventhandlers =>
 9             {
10                 eventhandlers.addeventhandler<youreventhandler1>();
11                 eventhandlers.addeventhandler<youreventhandler2>();
12             });
13 }
14 
15 
16 public void configure(iapplicationbuilder app, ihostingenvironment env)
17 {
18     app.useeventbus(eventbus =>
19     {
20         eventbus.subscribe<yourevent1, youreventhandler1>();
21         eventbus.subscribe<yourevent2, youreventhandler2>();
22     });
23 
24     app.usemvc();
25 }

这样刚刚我们创建的eventhandler就能正常的收到事件了;

注意:不同微服务通过事件总线交换消息,event的名字在不同的微服务项目中必须一致,因为rabbitmq是通过事件名找队列(一个队列对应一个微服务)

项目github:https://github.com/lhdboy/toosame.eventbus