交易系統之資料庫弱依賴解決方案

来源:https://www.cnblogs.com/jingdongkeji/archive/2023/03/23/17246230.html
-Advertisement-
Play Games

作者:京東科技 杜曉玉 前言 資料庫,交易系統中最核心依賴,數據持久化屬於最核心服務。 隨著互聯網的普及,大流量高併發的場景越來越多,7*24的交易系統對高可用要求越來越高,同時在“數據為王”大環境下,交易數據最終通過資料庫進行持久化存儲,資料庫成為整個系統最終重要服務,不能出一點問題,尤其核心P0 ...


作者:京東科技 杜曉玉

前言

資料庫,交易系統中最核心依賴,數據持久化屬於最核心服務。

隨著互聯網的普及,大流量高併發的場景越來越多,7*24的交易系統對高可用要求越來越高,同時在“數據為王”大環境下,交易數據最終通過資料庫進行持久化存儲,資料庫成為整個系統最終重要服務,不能出一點問題,尤其核心P0系統哪怕瞬間的DB操作異常可能造成大量異常交易,可能產生致命的問題,所以核心系統弱依賴資料庫都是必須考慮的。

資料庫弱依賴的整體思路:將最可靠鏈路再增加上備用鏈路替換,解決方案主要通過其他存儲介質+補償機制替換同步的DB操作,預期效果:資料庫出現故障期間也能保證系統運行正常不影響線上業務開展。

本期介紹下實踐過的三種解決方案:DB災備機制方案、DB高併發替換方案、財富系統弱依賴DB方案。

一、DB災備機制方案

日常引發資料庫操作出現異常的常見情況:網路鏈路異常、執行工單導致資料庫性能下降、慢SQL導致資料庫異常等,並且從發現問題到解決往往時間不短,尤其核心交易鏈路都已無法容忍短時間的異常故障,所以首先考慮增加災備機制,出現異常時間段內也要保證交易成功率,哪怕可以損失一點性能要求。DB災備機制方案是2016年接觸到並實施第一版弱依賴資料庫方案。方案主要思路:DB操作故障時間段內,通過其他存儲介質臨時存儲數據,並通過MQ非同步補償還原DB操作,達到最終數據一致性。

圖1 DB災備流程

具體改造點:

1.DB操作增加災備處理邏輯,出現異常時將數據存儲到緩存,併發送MQ,再通過消費MQ非同步還原DB數據操作;

2.數據查詢鏈路,必須支持先查緩存再查資料庫,並且減少外部查詢請求;

3.資料庫的DB操作性能非常好(毫秒級),災備處理鏈路同步操作入緩存+MQ發送,整體性能耗時變高了,需合理設置MQ發送超時時間,當時接入團隊內部MQSender組件,處理髮送失敗後非同步自動重發,提升災備處理鏈路的成功率,同時保障了MQ消息無丟失。

二、DB高併發替換方案

資料庫的連接數是寶貴且有限,凡是連接資料庫的系統,不可能無限進行機器擴容支持流量的增長,同時資料庫支持TPS也是有上限,例如Mysql5.6.x版本建議最大500~1000之間,尤其對高性能和高併發的系統來說,在高要求的性能指標下,資料庫吞吐量成為支撐大流量的瓶頸,如果通過增加資料庫伺服器,成本往往也是無法承擔。

2018年有幸參與到P0核心交易系統的高可用升級項目,目標將交易系統tps提升至2w以上,當時20台資料庫物理機(單機單實例,Mysql版本5.6.x),在高性能指標要求下,系統壓測tps峰值最高可達到1~1.5w。為達成目標,同時考慮資源成本,項目升級改造方案思路:通過緩存+MQ組合將資料庫操作完全非同步化,同時利用MQ消費批量拉取策略,批量拉取數據進行DB批量操作,減少資料庫操作次數提升效率。中間件選擇上充分利用緩存組件的高性能、高吞吐、支持連接數更大的優勢,保證了高性能同時也解決應用擴容問題。同時考慮到MQ平臺上部署其他應用topic影響發送性能,搭建單獨獨享MQ集群,保證MQ發送的性能要求,多次大促期間MQ發送耗時tp999都小於50ms。中間件達到高性能要求後,將DB操作替換成同步入緩存+發送MQ,提升交易鏈路吞吐量,壓測結果也達到tps>2w+目標。

圖2 DB高併發替換

具體改造點:

1.交易鏈路中DB操作全為insert,無update,滿足了非同步化後DB操作可進行批處理;

2.搭建單獨MQ平臺,保證了MQ發送性能,同時接入團隊內部MQSender組件,處理髮送失敗的非同步自動重發,保證整體鏈路的成功率;

3.緩存組件,本身具備高吞吐量並且可快速擴容,非同步化後交易鏈路吞吐量大幅提升。同時緩存接入R2M、JIMDB雙緩存,針對不同機房設置主從操作,例如金融機房同步主操作R2M,非同步操作JIMDB,性能最優。雙緩存機制防止單個緩存組件出現故障後可快速切換,保證整體鏈路成功率;

4.非同步化後通過MQ消費還原DB操作,通過合理設置MQ拉取策略,批量進行DB操作,減少DB操作提升效率;同時增加非同步化延遲的UMP監控,監控從交易發起到非同步入庫完整鏈路耗時,可直觀非同步化後MQ消費能力,便於動態調整;

5.減少外部系統的查詢訴求,統一以交易完成消息進行觸達扭轉,必要查詢請求全部查緩存,上游要具備查詢異常時重試機制。

三、財富系統弱依賴DB方案

財富交易系統參考以上兩版方案,並結合自身交易場景多、交易鏈路長、數據狀態多情況。基於此設計出一版以流水數據驅動交易數據扭轉的方案,大概思路:交易鏈路少變動,交易數據的DB操作不變動,增加中轉層將交易鏈路DB操作轉換為逐筆流水數據的持久化操作,再非同步消費MQ還原交易數據的DB操作,通過將新增中轉層做到弱依賴DB,達到整個交易鏈路弱依賴DB。結合系統的流量現狀,查詢流量大交易流量TPS未達上萬,當下主要目標加強交易鏈路的健壯性。

流水數據持久化的操作:並行執行DB入庫、入緩存,二者其一操作成功則直接返回成功,並非同步發送補償操作的MQ,如果DB出現故障期間緩存操作正常也可保證系統運行正常,不影響線上業務開展。例如消費場景的弱依賴DB改造,正常收到交易請求後,首先業務校驗+防重冪等>創建訂單>扣減用戶份額>更新訂單狀態,將創建訂單、更新訂單狀態的操作改造為創建兩筆流水數據的操作,交易鏈路不進行大的改造前提下,通過將流水數據持久化做到弱依賴DB,這樣交易過程中即使DB出現故障時只要緩存組件正常運行即可保障消費交易正常完成,再通過非同步消費MQ還原創建訂單、更新訂單的操作。方案落地後得到了很好的驗證,曾經歷過資料庫因執行大的變更工單導致資料庫出現性能故障,消費交易鏈路不受影響,保證業務正常運行和用戶體驗。

圖3 財富系統弱依賴DB方案

具體改造點:

1.中轉層流水數據持久化核心操作:並行執行DB的insert操作、入緩存,二者其一操作成功則直接返回成功,並非同步發送補償操作的MQ;

2.消費MQ非同步還原交易庫的DB操作時,通過數據中狀態位保證MQ消費的順序執行;

3.流水庫和緩存的雙向同步,如果流水庫或緩存出現故障時,非同步進行相互補償存儲,目前流水庫存儲全量流水數據。

4.交易鏈路主要改造兩點:一、防重冪等以流水數據為準,流水數據查詢是合併緩存和DB數據後返回;二、交易數據調用DB操作切換到創建流水數據的操作;

總結

以上資料庫弱依賴的技術方案更適用於數據偏流水式的交易系統,隨技術迭代和業務發展,技術方案也層出不窮並不斷迭代創新,歡迎大家跟我們研發團隊交流溝通,共同進步。


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

-Advertisement-
Play Games
更多相關文章
  • 使用lvs+keepalived架構架構實現後端web伺服器(該web伺服器要求搭建wordpress博客站)的負載均衡 最終客戶端訪問功能變數名稱 我的名字.wordpress.cn 能夠訪問搭建的博客站 ,達到負載均衡的目的 IP 主機名 角色 192.168.26.101 rs1 後端真實伺服器/ng ...
  • 操作系統: RHEL7.x 或CentOS 7.x 最小化安裝 配置好固定的IP,能訪問互聯網 配置好yum源(yum repolist 可以查看yum源) 本地光碟 掛載光碟,開機自動掛載 vim + /etc/fstable /dev/sr0 /mnt iso9660 defaults 0 0 ...
  • 一:存儲架構 根據存儲設備所在的位置分類 1、DAS DAS:(Direct-Attached Storage)直連式存儲。伺服器使用專用線纜(例如SCSI)和存儲設備(例如磁碟陣列)進行直連。 特點: 優點是儲設備只能連接到一臺主機使用,無法共用,成本較高,且安全性可靠性較低 缺點是容量有限,不適 ...
  • 一、線程簡介 線程是參與系統調度的最小單位。它被包含在進程之中,是進程中的實際運行單位。 一個進程中可以創建多個線程,多個線程實現併發運行,每個線程執行不同的任務。 每個線程都有其對應的標識,稱為線程 ID,線程 ID 使用 pthread_t 數據類型來表示。 二、線程的創建 線程是輕量級的併發執 ...
  • MySQL基礎:事務 事務簡介 事務是一組操作的集合,它是一個不可分割的工作單位,事務會把所有的操作作為一個整體一起向系統提交或撤銷操作請求,即這些操作要麼同時成功,要麼同時失敗。 預設MySQL的事務是自動提交的,也就是說,當執行一條DML(數據操作語言:對資料庫進行增刪改操作)語句,MySQL會 ...
  • GreatSQL社區原創內容未經授權不得隨意使用,轉載請聯繫小編並註明來源。 GreatSQL是MySQL的國產分支版本,使用上與MySQL一致。 作者: 蟹黃瓜子 文章來源:GreatSQL社區投稿 Docker是一個開源的應用容器引擎,讓開發者可以打包他們的應用以及依賴包到一個可抑制的容器中,然 ...
  • 摘要:本文主要講解數倉運維中遇到單SQL磁碟空間管控問題的解析和方案。 本文分享自華為雲社區《GaussDB(DWS)運維 -- 單SQL磁碟空間管控》,作者: 譡里個檔。 【問題描述】 執行部分SQL語句時出現如下報錯信息(具體數值可能因為配置有差異),本文針對根因和場景觸發場景,確定觸發此類問題 ...
  • GreatSQL社區原創內容未經授權不得隨意使用,轉載請聯繫小編並註明來源。 GreatSQL是MySQL的國產分支版本,使用上與MySQL一致。 作者: 王權富貴 文章來源:GreatSQL社區原創 背景 在一次日常測試中發現,kill 一個會話後,SQL語句依然在運行並沒終止;被kill的會話重 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...