上一编讲了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
