日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

.netcore 分布式事务CAP2.6之控制台使用

發布時間:2023/12/4 编程问答 29 豆豆
生活随笔 收集整理的這篇文章主要介紹了 .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之控制台使用的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。