.netcore 分布式事务CAP2.6之控制台使用
上一編.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中改成下面這樣就好了
4:添加推送程序? 4.1:添加一個繼承自IHostedService的Publish類,并在里面創建一個定時器,每秒推送一次事件。
4.2:在Programe.CreateHostBuilder方法中添加推送服務?services.AddHostedService<Publish>();??
4.3:f5運行程序,此時是已經可以正常推送消息了。
5:添加監聽服務
5.1:創建一個承繼自ICapSubscribe接口的類Events,并監聽Order.Created事件,代碼如下:?
5.2:在在Programe.CreateHostBuilder方法中添加監聽服務?services.AddSingleton<ICapSubscribe, Events>();?
6:大功造成
F5運行程序,可以看到程序在一邊推送一邊接收。
7:同一事件,多個服務監聽處理。
默認情況下,一個事件只會被一個監聽者處理,即使我們創建了多個服務來監聽同一事件,也只會有一個服務收到此事件,其它服務是收不到的。那么怎么讓多個服務同時處理同一事件呢?答案是使用分組,在添加監聽器時使用不同的分組名稱。
7.1:我們將Events類中的代碼,稍微改動一下,使用兩個都監聽Order.Created事件的方法,但命名成不同的分組。
7.2:F5運行,如下圖所示,一次推送事件,兩個監聽服務都處理了此事件。
示例代碼下載:https://pan.baidu.com/s/1X2uCvcLjQ9AiqxMD3CtTcA
原文鏈接:https://www.cnblogs.com/sunyuliang/p/11447565.html
.NET社區新聞,深度好文,歡迎訪問公眾號文章匯總?http://www.csharpkit.com?
總結
以上是生活随笔為你收集整理的.netcore 分布式事务CAP2.6之控制台使用的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 卓语言对泛型类的使用
- 下一篇: TestinPro应用与DevOps之路