室內(nèi)裝修設(shè)計圖紙seo快速軟件
前言
在分布式系統(tǒng)中，由于各個系統(tǒng)服務(wù)之間的獨立性和網(wǎng)絡(luò)通信的不確定性，要確保跨系統(tǒng)的事務(wù)操作的最終一致性是一項重大的挑戰(zhàn)。今天給大家推薦一個.NET開源的處理分布式事務(wù)的解決方案基于 .NET Standard 的 C# 庫：CAP。
CAP項目介紹
CAP 是一個基于 .NET Standard 的 C# 庫，它是一種處理分布式事務(wù)的解決方案，同樣具有 EventBus 的功能，它具有輕量級、易使用、高性能等特點。CAP 是一個EventBus，同時也是一個在微服務(wù)或者SOA系統(tǒng)中解決分布式事務(wù)問題的一個框架。它有助于創(chuàng)建可擴展，可靠并且易于更改的微服務(wù)系統(tǒng)。
什么是 EventBus？
事件總線是一種機制，它允許不同的組件彼此通信而不彼此了解。組件可以將事件發(fā)送到Eventbus，而無需知道是誰來接聽或有多少其他人來接聽。組件也可以偵聽Eventbus上的事件，而無需知道誰發(fā)送了事件。這樣，組件可以相互通信而無需相互依賴。同樣，很容易替換一個組件。只要新組件了解正在發(fā)送和接收的事件，其他組件就永遠不會知道。
CAP架構(gòu)預覽
CAP支持的存儲
SQL Server、MySQL、PostgreSql、MongoDB、In-Memory Storage。
CAP 支持以下幾種運輸方式
RabbitMQ、Kafka、Azure Service Bus、Amazon SQS、NATS、In-Memory Queue、Redis Streams、Apache Pulsar。
怎么選擇運輸器
項目源碼
快速開始
安裝DotNetCore.CAP Nuget包
CAP 支持主流的消息隊列作為傳輸器：
我本地安裝的是DotNetCore.CAP.RabbitMQ。
//你可以按需選擇下面的包進行安裝:
PM>?Install-Package?DotNetCore.CAP.Kafka
PM>?Install-Package?DotNetCore.CAP.RabbitMQ
PM>?Install-Package?DotNetCore.CAP.AzureServiceBus
PM>?Install-Package?DotNetCore.CAP.AmazonSQS
PM>?Install-Package?DotNetCore.CAP.NATS
PM>?Install-Package?DotNetCore.CAP.RedisStreams
PM>?Install-Package?DotNetCore.CAP.Pulsar
CAP 提供了主流數(shù)據(jù)庫作為存儲：
我本地安裝的是DotNetCore.CAP.MongoDB。
//?按需選擇安裝你正在使用的數(shù)據(jù)庫:
PM>?Install-Package?DotNetCore.CAP.SqlServer
PM>?Install-Package?DotNetCore.CAP.MySql
PM>?Install-Package?DotNetCore.CAP.PostgreSql
PM>?Install-Package?DotNetCore.CAP.MongoDB
配置CAP到 Program.cs 文件中，如下：
????????????builder.Services.AddCap(x?=>{//如果你使用的 EF 進行數(shù)據(jù)操作，你需要添加如下配置：//配置數(shù)據(jù)庫上下文x.UseEntityFramework<AppDbContext>();//如果你使用的 MongoDB，你可以添加如下配置：x.UseMongoDB("ConnectionStrings");??//注意，僅支持MongoDB?4.0+集群//CAP?RabbitMQ?配置x.UseRabbitMQ(rab?=>?{rab.HostName?=?"192.0.1.1";rab.Password?=?"123456";rab.Port?=?5672;rab.UserName?=?"123456";});});
發(fā)布
在 Controller 中注入 ICapPublisher 然后使用 ICapPublisher 進行消息發(fā)送。
public?class?PublishController?:?Controller
{private?readonly?ICapPublisher?_capBus;public?PublishController(ICapPublisher?capPublisher){_capBus?=?capPublisher;}//不使用事務(wù)[Route("~/without/transaction")]public?IActionResult?WithoutTransaction(){_capBus.Publish("xxx.services.show.time",?DateTime.Now);//?Publish?delay?message_capBus.PublishDelayAsync(TimeSpan.FromSeconds(delaySeconds),?"xxx.services.show.time",?DateTime.Now);return?Ok();}//Ado.Net?中使用事務(wù)，自動提交[Route("~/adonet/transaction")]public?IActionResult?AdonetWithTransaction(){using?(var?connection?=?new?MySqlConnection(ConnectionString)){using?(var?transaction?=?connection.BeginTransaction(_capBus,?autoCommit:?true)){//業(yè)務(wù)代碼_capBus.Publish("xxx.services.show.time",?DateTime.Now);}}return?Ok();}//EntityFramework?中使用事務(wù)，自動提交[Route("~/ef/transaction")]public?IActionResult?EntityFrameworkWithTransaction([FromServices]AppDbContext?dbContext){using?(var?trans?=?dbContext.Database.BeginTransaction(_capBus,?autoCommit:?true)){//業(yè)務(wù)代碼_capBus.Publish("xxx.services.show.time",?DateTime.Now);}return?Ok();}
}
訂閱
Action Method
在 Action 上添加 CapSubscribeAttribute 來訂閱相關(guān)消息。
public?class?PublishController?:?Controller
{[CapSubscribe("xxx.services.show.time")]public?void?CheckReceivedMessage(DateTime?datetime){Console.WriteLine(datetime);}
}
Service Method
如果你的訂閱方法沒有位于 Controller 中，則你訂閱的類需要繼承 ICapSubscribe：
namespace?xxx.Service
{public?interface?ISubscriberService{void?CheckReceivedMessage(DateTime?datetime);}public?class?SubscriberService:?ISubscriberService,?ICapSubscribe{[CapSubscribe("xxx.services.show.time")]public?void?CheckReceivedMessage(DateTime?datetime){}}
}項目源碼地址
更多項目實用功能和特性歡迎前往項目開源地址查看👀，別忘了給項目一個Star支持💖。
GitHub開源地址：GitHub - dotnetcore/CAP: Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
官方文檔：CAP
優(yōu)秀項目和框架精選
該項目已收錄到C#/.NET/.NET Core優(yōu)秀項目和框架精選中，關(guān)注優(yōu)秀項目和框架精選能讓你及時了解C#、.NET和.NET Core領(lǐng)域的最新動態(tài)和最佳實踐，提高開發(fā)工作效率和質(zhì)量?？右淹?#xff0c;歡迎大家踴躍提交PR推薦或自薦（讓優(yōu)秀的項目和框架不被埋沒🤞）。
https://github.com/YSGStudyHards/DotNetGuide/blob/main/docs/DotNet/DotNetProjectPicks.md
DotNetGuide技術(shù)社區(qū)交流群
- DotNetGuide技術(shù)社區(qū)是一個面向.NET開發(fā)者的開源技術(shù)社區(qū)，旨在為開發(fā)者們提供全面的C#/.NET/.NET Core相關(guān)學習資料、技術(shù)分享和咨詢、項目推薦、招聘資訊和解決問題的平臺。
- 在這個社區(qū)中，開發(fā)者們可以分享自己的技術(shù)文章、項目經(jīng)驗、遇到的疑難技術(shù)問題以及解決方案，并且還有機會結(jié)識志同道合的開發(fā)者。
- 我們致力于構(gòu)建一個積極向上、和諧友善的.NET技術(shù)交流平臺，為廣大.NET開發(fā)者帶來更多的價值和成長機會。
歡迎加入DotNetGuide技術(shù)社區(qū)微信交流群👪