NServiceBus+Saga開發分散式應用

来源:https://www.cnblogs.com/sword-successful/archive/2019/10/23/11729082.html
-Advertisement-
Play Games

前言 當你在處理非同步消息時,每個單獨的消息處理程式都是一個單獨的handler,每個handler之間互不影響。這時如果一個消息依賴另一個消息的狀態呢? 這時業務邏輯怎麼處理? 借用我們上篇文章的業務場景,如果在Ship項目里需要發送一個ShipOrder Command。這個ShipOrder需要 ...


前言

      當你在處理非同步消息時,每個單獨的消息處理程式都是一個單獨的handler,每個handler之間互不影響。這時如果一個消息依賴另一個消息的狀態呢? 這時業務邏輯怎麼處理?

image.png

     借用我們上篇文章的業務場景,如果在Ship項目里需要發送一個ShipOrder Command。這個ShipOrder需要依賴Sales.OrderPlaced和Bill.OrderBilled Command的狀態,目前我們的兩個單獨的Message Handler都沒有保持任何的狀態欄位,所以這時如果我們需要完成這個業務模型,就需要跟蹤他們的狀態。

什麼是Saga

    這個就是本篇文章要提的saga,定義在NServiceBus框架里,他的本質是一個消息驅動模型里的狀態機,或者也可以理解為一系列消息處理程式用來共用狀態的業務模型。我理解在消息隊列里如果我們要保證消息一致性通常會自己創建一張Event表,這裡saga維持狀態的角色有點像我們這裡的Event表。
   
屏幕快照 2019-10-23 20.46.15.png
   好的,回到正題上,如果我們需要在Shipping Service里發送一個ShipOrder,發送他之前需要確定OrderPlaced和OrderBilled的狀態,確保這兩個消息都收到以後才能發送ShipOrder。

如何使用Saga

   當然,我暫且理解Saga的目的是為了處理在長時間運行的任務里保證數據一致性這樣的一個角色。

Saga狀態

  saga狀態主要是告訴NServiceBus在處理數據一致性的判斷邏輯,這裡需要繼承抽象類ContainSagaData,在我們這個業務場景中則主要是判斷OrderPlaced和OrderBilled消息是否已經接收到並處理。

public class ShippingPolicyData:ContainSagaData
{
   public string OrderId { get; set; }
   public bool IsOrderPlaced { get; set; }
   public bool IsOrderBilled { get; set; }
}

Saga如何工作

   有了狀態以後,我們還需要一個“handler”來告訴NServiceBus,在這個handler里主要用來處理消息數據一致性,我看了官方文檔後,他們建議我們這裡的handler角色使用Policy尾碼命名,當然我覺的也可以用Saga尾碼命名,比如ShippingPolicy或者ShippingSaga。
   同時這裡我們這個handler覺色還要繼承Saga類,Saga類主要重寫方法ConfigureHowToFindSaga,這個方法的作用主要是在接受的消息和我們的Saga實體之間建立映射關係。

 public class ShipPolicy:Saga<ShippingPolicyData>,
        IAmStartedByMessages<OrderPlaced>,
        IAmStartedByMessages<OrderBilled> //都可以創建Saga實例
    {
        private static ILog log = LogManager.GetLogger<ShipPolicy>();

        protected override void ConfigureHowToFindSaga(SagaPropertyMapper<ShippingPolicyData> mapper)
        {
            mapper.ConfigureMapping<OrderPlaced>(t=>t.OrderId).ToSaga(sagaData=>sagaData.OrderId);
            mapper.ConfigureMapping<OrderBilled>(t=>t.OrderId).ToSaga(sagaData=>sagaData.OrderId);
            
        }

        public Task Handle(OrderPlaced message, IMessageHandlerContext context)
        {
            log.Info("OrderPlaced message received ");
            this.Data.IsOrderPlaced = true;
            return ProcessOrder(context);
        }

        public Task Handle(OrderBilled message, IMessageHandlerContext context)
        {
            
            log.Info("OrderBilled message received");
            this.Data.IsOrderBilled = true;
            return ProcessOrder(context);
        }

        private async Task ProcessOrder(IMessageHandlerContext context)
        {
            if (Data.IsOrderBilled && Data.IsOrderPlaced)
            {
                await context.SendLocal(new ShipOrder()
                {
                    OrderId = Data.OrderId
                });
                
                MarkAsComplete();
            }
        }
    }

    
    這個類里你會發現還實現了介面IAmStartedByMessages, 這個介面主要是告訴Saga,不論是那種消息類型先進來,都可以創建一個Saga實例,就比如是Event表,不管那個消息進來,都需要先插入一條數據,後續消息再進來時要更新數據狀態,當然,這裡的Saga實例也好,Event表也好,關鍵問題就是有效標識,或者叫主鍵,我們這個業務模型里,OrderPlaced和OrderBilled都包含一個屬性OrderId, 這裡Saga實例則使用這個OrderId做關鍵屬性。

發送ShipOrder Command

    到這裡也就是我們的OrderPlaced和OrderBIlled消息都收到了,業務邏輯符合要求,可以發送ShipOrder消息了,也就是用戶創建了訂單,付了款,可以發貨了。
image.png

新建ShipOrder類

public class ShipOrder:ICommand
{
    public string OrderId { get; set; }
}

新建ShipOrderHandler

public class ShipOrderHandler:IHandleMessages<ShipOrder>
{
   private static ILog log = LogManager.GetLogger<ShipOrderHandler>();
   public Task Handle(ShipOrder message, IMessageHandlerContext context)
   {
       log.Info($"Order [{message.OrderId}] - Successfully shipped");
       return Task.CompletedTask;
   }
}

運行Shipping項目,看到下圖,則說明程式運行成功,我們這個業務場景里OrderPlaced消息肯定先接受到,OrderBilled消息後接受到。
屏幕快照 2019-10-23 20.29.05.png

參考鏈接

https://docs.particular.net/tutorials/nservicebus-sagas/1-getting-started/
https://docs.particular.net/nservicebus/sagas/


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 一、json數據 python數據類型與json對應關係表如下: 以上就是關於json的所有數據類型。 什麼是json? 定義: 講json對象,不得不提到JS對象: 合格的json對象: 不合格的json對象: python數據類型和json的轉換 JavaScript數據類型和json的轉換 p ...
  • 前面的章節,講解了[Spring Boot集成Spring Cache]( https://blog.csdn.net/Simple_Yangger/article/details/102693316),Spring Cache已經完成了多種Cache的實現,包括EhCache、RedisCache ...
  • 前面的章節,講解了[Spring Boot集成Spring Cache]( https://blog.csdn.net/Simple_Yangger/article/details/102693316),Spring Cache已經完成了多種Cache的實現,包括EhCache、RedisCache ...
  • 在python腳本中我們經常看到如下的代碼: # hello.py def hello(): print("hello world!") def test(): hello() if __name__ == '__main__': test() 通常,一個python文件有兩種使用方法: (1)直接 ...
  • 繼承Thread類 實現Runnable介面 匿名內部類的兩種寫法 基於java.util.concurrent.Callable工具類的實現,帶返回值 基於java.util.Timer工具類的實現 基於java.util.concurrent.Executors工具類,基於線程池的實現 更多信息 ...
  • 集成 websocket 的四種方案 1. 原生註解 pom.xml WebSocketConfig 說明: 這個配置類很簡單,通過這個配置 spring boot 才能去掃描後面的關於 websocket 的註解 WsServerEndpoint 說明 這裡有幾個註解需要註意一下,首先是他們的包都 ...
  • [TOC] GIL全局解釋鎖 1. GIL本質上是一個互斥鎖。 2. GIL是為了阻止同一個進程內多個進程同時執行(並行) 單個進程下的多個線程無法實現並行,但能實現併發 3. 這把鎖主要是因為Cpython的記憶體管理不是線程安全的 保證線程在執行任務時不會被垃圾回收機制回收 多線程的作用 1. 計 ...
  • 本節內容: 1、剖析Hello,World程式 1.1初始類(class)與名稱空間(namespace) 2、類庫的引用 2.1DLL的引用(黑盒引用) 2.2項目引用(白盒引用) 2.3建立自己的類庫項目 3、依賴關係 4、排除錯誤 1、剖析Hello,World程式 1.1、類(class)構 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...