.NET Core 實踐:事件通知和非同步處理

来源:http://www.cnblogs.com/TO-WW/archive/2017/08/09/7309544.html
-Advertisement-
Play Games

首先讓我們來先看一個例子: 這是一個簡單的用戶下單購買商品的業務模型,輸入端是用戶,相關物料有訂單和貨物,相關的內部服務有業務(訂單)、財務(支付)、倉儲(備貨)和物流(運輸)。 從圖中我們可以看到,用戶首先向業務部門下了一個訂單,業務部門根據用戶提供的內容生成了一份訂單給客戶,並要求客戶根據訂單金 ...


首先讓我們來先看一個例子:

這是一個簡單的用戶下單購買商品的業務模型,輸入端是用戶,相關物料有訂單和貨物,相關的內部服務有業務(訂單)、財務(支付)、倉儲(備貨)和物流(運輸)。

從圖中我們可以看到,用戶首先向業務部門下了一個訂單,業務部門根據用戶提供的內容生成了一份訂單給客戶,並要求客戶根據訂單金額支付費用。此時用戶會拿著訂單向財務部門付款,財務部門收款後告訴業務部門,此訂單的貨款已經收到,業務部門通知倉儲部門備貨,倉儲部門備貨完成後通知業務部門貨物已經準備完畢,再由業務部門通知物流部門去倉庫取貨並送給用戶,最後用戶簽收,流程結束。

在這個流程中我們可以發現,總共十個步驟中,除了創建訂單、付款和簽收外,其他的用戶實際上並不關心。在生活中,我們實際上是付完款就回家等著收貨了。如果我們把上述四個部門看作四個微服務,並同步調用,則運算模型如下:

從圖中我們可以看出,用戶發起一個請求(支付貨款)後,將按照順序一步一步的執行所有的步驟,直到用戶取到貨物才能結束,如果這段時間比較長,則需要用戶一直等待結果,直到用戶等的不耐煩離開(響應超時)。先不論用戶體驗如何,這種模型的處理效率實在是過於低下,如果貨物運送需要若幹天,則業務流程就要堵塞若幹天,新的業務就進不來。

如果我們設計一種新的處理模型,在用戶支付完成後,把這些用戶不關心的環節放到後臺處理,就可以極大的提升處理效率,增加吞吐量。

如上圖所示,當用戶發起一個請求後(支付貨款),先處理與支付相關的業務邏輯,然後立刻將處理結果(支付成功,等待收貨)反饋給用戶,這時用戶的前臺流程就告一段落了。在此之後,我們通過一種方式通知其它相關的微服務(訂單、倉儲、物流),告知他們要進行哪些工作。這些業務一般不需要即時反饋,因此前臺人員並不需要等待他們反饋結果,可以直接接受下一個任務。

在這種模型下,我們在微服務之外引入了事件通知服務(如 AWS SNS),當微服務向通知服務發佈事件時,只會向通知服務中持久化一條數據,然後微服務就執行完畢並向調用者即時反饋結果了。此後,再由事件通知服務在合適的時候遠程調用其他微服務的回調函數,完成業務流程。

事件通知非同步調用可以在一定程度上提升微服務的性能和吞吐量,並且各大雲服務提供商都有提供類似的服務,如亞馬遜雲的SNS服務,騰訊雲的CMQ服務,阿裡雲的Message Service等,都可以輕鬆的集成到項目當中。

但是,非同步調用也存在一些不足:

1. 如果發佈時發生異常,消息可能會丟失,導致業務流程永久性暫停。如:付款後未能通知業務部門,導致倉儲沒有備貨、物流沒有運輸,最終用戶拿不到貨物。

2. 如果微服務回調函數發生異常,可能導致最終數據不一致。如:倉儲備貨過程出錯,但是業務和物流部門都以為已經備好貨了,業務部門告知用戶已經開始運輸,物流部門卻沒有取到貨,最終用戶依然拿不到貨。然而業務部門發佈的事件已經調用過物流部門的回調函數,雖然沒有成功,但是發佈的消息卻已經被消費掉了,業務部門也沒有辦法重新發送事件通知給倉儲,所以這件事只能線下處理(運維人員手動修改數據)。

要保證數據一致性和服務可靠性,就不得不提到消息隊列和分散式事務。

“消息隊列”是在消息的傳輸過程中保存消息的容器,我將會在下一篇中探討消息隊列的相關內容。謝謝!

 


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

-Advertisement-
Play Games
更多相關文章
  • 國際化 我之前 WinForm 國際化都是湊一些代碼搞起(請看文後 Reference)。 最近發現還有個官方國際化方法: 每設置一個語言後,設計器會自動生成對應的 resx 文件,如:Form1.resx (Default), Form1.zh-Hans.resx , Form1.en-US.re ...
  • /// <summary> /// 計算傳入的時間距離今天的時間差 /// </summary> /// <param name="dt"></param> /// <param name="yy"></param> /// <param name="mm"></param> /// <param ...
  • 1.好好學習,天天總結 2.Good Good Coding,Day Day Up! ...
  • (轉載)http://www.cnblogs.com/michaely/p/3340087.html MVC是眾所周知的模式,即:將應用程式分解成三個組成部分:model(模型),view(視圖),和 controller(控制 器)。其中: M 管理應用程式的狀態(通常存儲到資料庫中),並約束改變 ...
  • 關於她 LindAgile是大叔在這兩年裡的新寵兒,它主推模塊化,插件化,敏捷化,主要於LindAgile基礎項目,LindAgile.Http項目,LindAgile.Modules項目和幾個擴展模塊項目組成,那幾個擴展模塊主要體現的AOP的特性,需要哪些模塊,就在應用程式里註冊哪些。 LindA ...
  • 俺剛畫的一張圖片 ...
  • 一、要求 項目功能方便客戶查詢化學品信息業務現狀客戶查詢方式多樣化,如通過名稱查詢、同義詞查詢、CAS號查詢等目前數據量是1千萬數據顯示形式比較單調業務目標精確滿足客戶查詢需求豐富數據顯示形式查詢速度控制在1-2s 二、解決方法 分析客戶行為發現客戶有一半概率是通過產品名稱查詢,一半概率是通過其他方 ...
  • 前言 本文將簡單介紹兩種基於Flume的日誌收集系統可能的架構方案,可根據不同的實際場景參考使用。 方案一 示例圖如下: 說明: 每個日誌源(http上報、日誌文件等)對應一個Agent-c用於收集對應日誌, 收集來的日誌可以流到Agent-s-1或Agent-s-2; Agent-c的Sink處理 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...