.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