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

.netcore 分布式事务CAP2.6之控制台使用

程序员文章站 2022-07-02 13:10:37
上一编讲了cap2.6的快速入门,这次我们来讲讲在控制台中如何使用cap2.6。因为cap2.6的内存模式目前已经可以使用了,相关组件已经更新,所以这次我们以简单的内存模式为例。 1:创建项目 创建一个名叫CAPConsoleDemo的 “控制台应用(.NET Core)” 程序,.netcore版 ......

 

上一编讲了cap2.6的快速入门,这次我们来讲讲在控制台中如何使用cap2.6。因为cap2.6的内存模式目前已经可以使用了,相关组件已经更新,所以这次我们以简单的内存模式为例。

 

1:创建项目

创建一个名叫capconsoledemo的 “控制台应用(.net core)” 程序,.netcore版本要求在2.2或以上。

 

2:添加相关引用

在nuget中添加 dotnetcore.cap  dotnetcore.cap.inmemorystorage  savorboard.cap.inmemorymessagequeue  microsoft.extensions.hosting 等组件的引用。 

 .netcore 分布式事务CAP2.6之控制台使用

  

3:构建常规host主机

常规host主机是.net core 2.1中引入的,本质是移除了web功能的webhost,以前webhost的所有依赖注入,生命周期管理,日志管理等都可以在控制台程序中使用。以后webhost都会是基于常规host来实现的。

实现方式也很简单,只要将programe.cs中改成下面这样就好了

 1 using microsoft.extensions.dependencyinjection;
 2 using microsoft.extensions.hosting;
 3 using savorboard.cap.inmemorymessagequeue;
 4 using system;
 5 
 6 namespace capconsoledemo
 7 {
 8     class program
 9     {
10         static void main(string[] args)
11         {
12             createhostbuilder(args).build().run();  //构建一个常规host
13         }
14         static ihostbuilder createhostbuilder(string[] args)
15         {
16             var build = new hostbuilder();
17             build.configureservices((hostcontext, services) =>
18             {
19                 services.addcap(option =>      //添加cap框架
20                 {
21                     option.useinmemorystorage();   //使用内存存储
22                     option.useinmemorymessagequeue();  //使用内存队列
23                     option.usedashboard();  //添加监控仪表盘
24                 });
25             });
26             return build;
27         }
28     }
29 }

 

4:添加推送程序

  4.1: 添加一个继承自ihostedservice的publish类,并在里面创建一个定时器,每秒推送一次事件。

using dotnetcore.cap;
using microsoft.extensions.hosting;
using system;
using system.threading;
using system.threading.tasks;

namespace capconsoledemo
{
    public class publish : ihostedservice
    {
        private icappublisher cappublish;  //cap发布程序
        private timer _timer;   //定时器

        public publish(icappublisher cappublish)  //自动注入cap程序
        {
            this.cappublish = cappublish;
        }

        public task startasync(cancellationtoken cancellationtoken)
        {
            _timer = new timer(work, null, timespan.zero, timespan.fromseconds(1));  //每秒运行一次推送任务
            return task.completedtask;
        }
        private void work(object state)
        {
            cappublish.publish<string>("order.created", datetime.now.tostring());  //推送order.created事件
            console.writeline("推送:" + datetime.now.tostring());
        }

        public task stopasync(cancellationtoken cancellationtoken)
        {
            return task.completedtask;
        }
    }
}

 

4.2:在programe.createhostbuilder方法中添加推送服务 services.addhostedservice<publish>();  

.netcore 分布式事务CAP2.6之控制台使用

 

4.3:f5运行程序,此时是已经可以正常推送消息了。

.netcore 分布式事务CAP2.6之控制台使用

 

5:添加监听服务

5.1:创建一个承继自icapsubscribe接口的类events,并监听order.created事件,代码如下: 

 1 using dotnetcore.cap;
 2 using system;
 3 using system.threading.tasks;
 4 
 5 namespace consoleapp2
 6 {
 7     public class events : icapsubscribe
 8     {
 9 
10 
11         [capsubscribe("order.created")]   //监听order.created事件
12         public async task ordercreatedeventhand(string msg)
13         {
14             console.writeline("--接收:"+ msg);
15         }
16 
17     }
18 }

 

5.2: 在在programe.createhostbuilder方法中添加监听服务 services.addsingleton<icapsubscribe, events>(); 

.netcore 分布式事务CAP2.6之控制台使用

  

6:大功造成

f5运行程序,可以看到程序在一边推送一边接收。

.netcore 分布式事务CAP2.6之控制台使用

 

7:同一事件,多个服务监听处理。

默认情况下,一个事件只会被一个监听者处理,即使我们创建了多个服务来监听同一事件,也只会有一个服务收到此事件,其它服务是收不到的。那么怎么让多个服务同时处理同一事件呢?答案是使用分组,在添加监听器时使用不同的分组名称。

7.1:我们将events类中的代码,稍微改动一下,使用两个都监听order.created事件的方法,但命名成不同的分组。

 1 using dotnetcore.cap;
 2 using system;
 3 using system.threading.tasks;
 4 
 5 namespace capconsoledemo
 6 {
 7     public class events : icapsubscribe
 8     {
 9 
10 
11         [capsubscribe("order.created", group = "group1")]   //监听order.created事件,并命名为group1
12         public async task ordercreatedeventhand(string msg)
13         {
14             console.writeline("--group1接收:" + msg);
15         }
16 
17 
18         [capsubscribe("order.created", group = "group2")]   //监听order.created事件,并命名为group2
19         public async task group2(string msg)
20         {
21             console.writeline("--group2接收:" + msg);
22         }
23     }
24 }

 

7.2:f5运行,如下图所示,一次推送事件,两个监听服务都处理了此事件。

.netcore 分布式事务CAP2.6之控制台使用

 

示例代码下载https://pan.baidu.com/s/1x2ucvcljq9aiqxmd3cttca