.netcore 分散式事務CAP2.6 快速入門
CAP介紹：
CAP是一個用來解決微服務或者分散式系統中分散式事務問題的一個開源專案解決方案。可以解決跨伺服器的資料一致性問題。一個簡單的列子，如：訂單系統建立訂單後需要通知郵件通知使用者下單成功，解決方案有下面幾種：
1：建立訂單時同步呼叫郵件傳送，郵件傳送失敗則整個訂單建立失敗，這樣保證了一致性，但效能和可用性有非常大的問題。或者不管郵件傳送狀態，失敗了就算了，這樣使用者就可能收不到通知郵件了。
2：建立訂單時通過訊息佇列推送一個訂單建立成功的事件，另外建立一個服務來監聽消費此事件，並執行郵件傳送的功能。這種方案存在往訊息佇列推送資料失敗的可能，存在和方案1一樣的問題。
3：建立訂單時同時往一個叫“訂單建立成功”的事件表中插入相關資料，兩者在同一事務中。 另外建立一個服務定時查詢此表，發現有待處理的資料時，執行郵件傳送，成功後把此資料刪除或更新為已處理。此方案保證了最終一致性和可用性，但得定時掃描，效能和及時性有問題。
4：建立訂單時同時往一個叫“訂單建立成功”的事件表中插入相關資料，兩者在同一事務中。並且通過訊息佇列推送此訊息，如果推送失敗，則定時掃描“訂單建立成功”表將失敗的資料重新推送。另外建立一個服務來監聽消費此事件，這種方案集成了方案1和方案2的優點，即保證了最終一致性，也保證了可用性。
從上面來看最優的方案顯示是方案4，我們這次的主角CAP也正是採用了此種方案來實現的，我們這裡介紹的方案4還是比較簡單的，CAP的實現要更加的嚴謹、更加強大，我們不需要建過程表，也不需要處理訊息佇列的問題，底層很多的細節都不需要我們考慮，只管用就好了。CAP資料庫儲存支援：Sql Server，MySql，PostgreSql，MongoDB。訊息佇列支援：RabbitMQ，Kafka，Azure Service Bus等。
各多CAP的介紹可以參考官網，詳細的CAP理論可以參考其它文章。 官網 http://cap.dotnetcore.xyz/ ，開源地址：https://github.com/dotnetcore/CAP ,作者blog https://www.cnblogs.com/savorboard/
快速開始
CAP2.6是2019-8-29釋出的，目前官網上的文件快速開始已經無法使用，因為裡面用了 Savorboard.CAP.InMemoryMessageQueue 元件，該元件還是2.51,不支援最新的CAP2.6版本，應該得過段時間才會修復文件，或者等 Savorboard.CAP.InMemoryMessageQueue元件更新。現在我們就在這開始我們的“快速開始”吧。我們將基於rabbitmq和sqlserver資料庫來實現。
1：建立專案
開啟VS建立一個名叫CapDemo的webapi專案，版本選擇ASP.NET Core 2.2。CAP2.6不支援2.2以下的.net core
2：新增CAP引用
在Nuget中新增 DotNetCore.CAP DotNetCore.CAP.RabbitMQ DotNetCore.CAP.SqlServer 的引用。
3:配置CAP
在Startup.cs的ConfigureServices方法中新增以下程式碼
services.AddCap(c =>
{
c.UseSqlServer(@"Data Source=.\sql2014;Initial Catalog=Test;User ID=sa;Password=sa"); //使用SqlServer資料庫,連線地址請依實際修改
c.UseRabbitMQ( mq =>
{
mq.HostName = "192.168.150.134"; //RabitMq伺服器地址，依實際情況修改此地址
mq.Port = 5672;
mq.UserName = "admin"; //RabbitMq賬號
mq.Password = "admin"; //RabbitMq密碼
});
});
4：釋出事件
將 CapDemo.Controllers.ValuesController中的所有方法全部刪除。新增引用 using DotNetCore.CAP; ，並新增以下方法
[HttpGet]
public async Task<string> Get([FromServices]ICapPublisher capPublish)
{
await capPublish.PublishAsync<string>("Order.Created", "hello，訂單建立成功啦"); //釋出Order.Created事件
return "訂單建立成功啦";
}
5：訂閱事件
在CapDemo.Controllers.ValuesController中新增以下方法：
[NonAction]
[CapSubscribe("Order.Created")] //監聽Order.Created事件
public async Task OrderCreatedEventHand(string msg)
{
Console.WriteLine(msg);
}
6：最後一步：啟動測試
在OrderCreatedEventHand方法內打個斷點，F5啟動專案訪問https://localhost:44304/api/values介面。因為此例中第一次訪問時可能釋出事件比訂閱事件要快，導致還沒訂閱就把事件釋出出去了，這樣的事件會丟失，所以我們再F5重新整理一下介面，可以看到程式就進入到了訂閱事件裡面。
後記：
新增監控儀表盤監控CAP執行狀況：
1：只需要在Startup.cs的AddCap方法中新增配置： c.UseDashboard(); 就萬事大吉了，一個功能強大的事件管理介面就出來了，具體如下圖：
2： 重新編譯並啟動專案，進入https://localhost:44304/cap ，從開啟的介面裡可以看到CAP的各種事件和狀態。
資料庫變化
我們再看看資料庫裡面的變化吧，從下圖可以看出CAP自動建立了兩個表，並且記錄了釋出的訊息，和接收到的訊息。這些資料會定時刪除。這些都是不需要我們管的。
本示例原始碼下載：https://pan.baidu.com/s/1fHXSW20JHSoaYPH748VRKg