上一編講了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

&n