.netcore 分布式事务CAP2.6之控制台使用
上一编讲了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 等组件的引用。
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>();
4.3:f5运行程序,此时是已经可以正常推送消息了。
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>();
6:大功造成
f5运行程序,可以看到程序在一边推送一边接收。
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运行,如下图所示,一次推送事件,两个监听服务都处理了此事件。
示例代码下载:https://pan.baidu.com/s/1x2ucvcljq9aiqxmd3cttca