.netcore 分散式事務CAP2.6之控制台使用
- 2019 年 10 月 3 日
- 筆記
上一編講了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
