REA 這個(gè)詞我第一次看到時(shí)心里想的是“這又是哪個(gè)新中間件”后來一查才發(fā)現(xiàn)它是一套在業(yè)務(wù)系統(tǒng)里非常值得認(rèn)真研究的建模思想全稱 Resource-Event-Agent翻譯過來就是資源-事件-代理。這篇筆記就來聊聊我完整落地過一遍 REA 框架的實(shí)戰(zhàn)記錄從它到底解決什么問題、核心概念怎么區(qū)分到具體怎么把一套訂單加庫(kù)存系統(tǒng)改造成 REA 結(jié)構(gòu)最后把實(shí)操中踩過的坑和排查經(jīng)驗(yàn)一并整理出來。適合正在做訂單、庫(kù)存、供應(yīng)鏈、財(cái)務(wù)對(duì)賬或者積分系統(tǒng)重構(gòu)的后端開發(fā)、架構(gòu)師也適合被“訂單狀態(tài)字段越堆越亂”折磨到懷疑人生的同學(xué)。1. REA 到底想解決建模里的哪些問題1.1 傳統(tǒng)表結(jié)構(gòu)建模越做越重的三個(gè)信號(hào)我見過太多系統(tǒng)是這樣一步一步走向失控的第一個(gè)信號(hào)訂單表字段開始爆炸。下單時(shí)間、支付時(shí)間、發(fā)貨時(shí)間、確認(rèn)收貨時(shí)間、退款狀態(tài)、發(fā)票狀態(tài)、優(yōu)惠券明細(xì)、贈(zèng)品信息……全都塞在訂單主表里?？雌饋砗孟褚粡埍砭蛪蛴昧藢?shí)際上每次要加一個(gè)新狀態(tài)就要跟著改一堆歷史數(shù)據(jù)、檢查一堆兼容邏輯一個(gè)不小心就把線上訂單狀態(tài)搞壞了。第二個(gè)信號(hào)對(duì)賬靠人肉拉數(shù)據(jù)拼。財(cái)務(wù)月底要核對(duì)庫(kù)存金額、應(yīng)收應(yīng)付業(yè)務(wù)說自己按訂單跑了財(cái)務(wù)說自己按流水算了兩邊數(shù)字對(duì)不上。原因很簡(jiǎn)單系統(tǒng)里根本沒有一個(gè)統(tǒng)一的事件賬本錢和貨被拆散在不同的業(yè)務(wù)表里面只能靠人寫臨時(shí) SQL 去拉、去導(dǎo)、去手工比對(duì)。第三個(gè)信號(hào)業(yè)務(wù)規(guī)則的執(zhí)行邏輯散落在各處。你今天在訂單 Service 里改庫(kù)存扣減邏輯明天發(fā)現(xiàn)采購(gòu)入庫(kù)那邊又用了一套完全不一樣的扣減規(guī)則后天發(fā)現(xiàn)盤點(diǎn)調(diào)整又是第三套。不是代碼寫得差是底層模型壓根沒有達(dá)成共識(shí)導(dǎo)致大家各做各的。這三大信號(hào)本質(zhì)上都是同一個(gè)根因我們?cè)谟谩皢螕?jù)視角”建表卻希望這套模型能支持“事實(shí)追溯”。單據(jù)只是業(yè)務(wù)的呈現(xiàn)形式真正應(yīng)該留在系統(tǒng)里的是業(yè)務(wù)事實(shí)本身。1.2 把“憑證驅(qū)動(dòng)”換成“事件驅(qū)動(dòng)”不妨用快遞舉個(gè)例子。快遞到了哪兒、中轉(zhuǎn)了幾次你不會(huì)只往包裹上寫一個(gè)“最后位置”字段而是每到一個(gè)節(jié)點(diǎn)就掃描一條記錄。查包裹在哪兒看最新一條物流記錄就行出問題要追責(zé)看完整時(shí)間線就行。訂單系統(tǒng)也是一樣的道理。傳統(tǒng)做法是在訂單上維護(hù) status 字段從待支付改成已支付、已支付改成已發(fā)貨每次修改都是覆蓋歷史。等到哪天你想知道“這個(gè)訂單在 3 月 15 號(hào)到底處于什么狀態(tài)”你發(fā)現(xiàn)狀態(tài)早就被覆蓋了根本查不回來。REA 的核心轉(zhuǎn)變就是把“狀態(tài)覆蓋”改成“事件追加”。每次業(yè)務(wù)動(dòng)作都作為一條不可變的事件記錄保存下來當(dāng)前狀態(tài)可以隨時(shí)從事件流推導(dǎo)出來歷史也能隨時(shí)回溯。做對(duì)賬的時(shí)候全部以事件流為準(zhǔn)繩錢和貨的來龍去脈清清楚楚。1.3 哪些業(yè)務(wù)適合 REA哪些沒必要REA 不是一個(gè)萬能銀彈它天生適合那些“有價(jià)值流動(dòng)、需要審計(jì)追溯、涉及多方參與”的場(chǎng)景。適合用 REA不太需要 REA電商訂單、庫(kù)存、進(jìn)銷存純內(nèi)容管理系統(tǒng)、博客、CMS供應(yīng)鏈與多級(jí)倉(cāng)儲(chǔ)簡(jiǎn)單 CRUD 展示型應(yīng)用財(cái)務(wù)應(yīng)收應(yīng)付、資金賬戶靜態(tài)報(bào)表平臺(tái)積分、優(yōu)惠券、會(huì)員點(diǎn)數(shù)體系無狀態(tài)接口聚合服務(wù)選型邏輯很簡(jiǎn)單如果業(yè)務(wù)從頭到尾都只是“單表增刪改查”沒有跨表價(jià)值流轉(zhuǎn)也沒有審計(jì)要求那 REA 只會(huì)給你增加額外復(fù)雜度。但如果你的系統(tǒng)每天要處理庫(kù)存、資金、積分這類“會(huì)變來變?nèi)ミ€要說得清為什么變”的數(shù)據(jù)REA 的價(jià)值會(huì)隨著業(yè)務(wù)復(fù)雜度的提升越來越明顯。2. 資源、事件、代理三個(gè)核心概念怎么用2.1 資源能衡量?jī)r(jià)值、能被業(yè)務(wù)流轉(zhuǎn)的存量資源不是說“數(shù)據(jù)庫(kù)里的一張表”它有明確特征可以被消耗、產(chǎn)出、交換而且能衡量?jī)r(jià)值。舉個(gè)例子電商系統(tǒng)里商品庫(kù)存是資源入一箱貨庫(kù)存增加賣一件貨庫(kù)存減少現(xiàn)金和應(yīng)收應(yīng)付是資源每筆交易的資金流動(dòng)會(huì)改變它們的余額積分、優(yōu)惠券、服務(wù)時(shí)長(zhǎng)、帶寬流量包這類虛擬資產(chǎn)同樣是非常典型的資源。判斷一個(gè)東西到底算不算資源我有個(gè)簡(jiǎn)潔標(biāo)準(zhǔn)如果它的數(shù)量會(huì)增加或減少而且業(yè)務(wù)上要求你必須能回答“為什么增加、為什么減少、誰觸發(fā)的”它就應(yīng)該建模成資源。反之比如訂單編號(hào)、商品名稱這些只是屬性描述不是資源。這里特別提醒一個(gè)坑不要什么字段都往資源里塞。資源只保存“存量狀態(tài)”和“基礎(chǔ)屬性”像成本分?jǐn)傄?guī)則、審批流程配置這些業(yè)務(wù)規(guī)則不能作為資源字段堆進(jìn)去否則又會(huì)退化回普通的寬表設(shè)計(jì)。2.2 事件不可變、可追溯、有明確時(shí)間點(diǎn)事件是整套 REA 模型里最重要的概念也是我落地時(shí)體會(huì)最深的部分。事件表示業(yè)務(wù)發(fā)生瞬間的一個(gè)事實(shí)。采購(gòu)入庫(kù)是一次事件銷售出庫(kù)是一次事件積分兌換是一次事件庫(kù)存盤點(diǎn)調(diào)整也是一次事件。事件必須包含這幾個(gè)要素什么時(shí)間發(fā)生哪些資源流入哪些資源流出哪些代理參與事件類型是什么事件一旦寫入就不能修改、不能刪除。如果業(yè)務(wù)操作有錯(cuò)誤比如入庫(kù)數(shù)量錄錯(cuò)了正確的做法不是去 UPDATE 那條事件記錄而是新增一條“沖正事件”把錯(cuò)誤影響抵消掉再把正確數(shù)量入賬。這樣看事件流的時(shí)候能看到錯(cuò)誤發(fā)生與修正的全過程審計(jì)非常舒服。我第一次做這種設(shè)計(jì)時(shí)會(huì)有點(diǎn)不習(xí)慣因?yàn)橐郧傲?xí)慣了“改狀態(tài)”現(xiàn)在改成“追加事實(shí)”。但這其實(shí)反而讓代碼邏輯更清晰所有寫操作都是 append不需要處理復(fù)雜的更新邏輯。2.3 代理參與主體要區(qū)分角色不要無腦建“用戶表”代理是參與事件的各類主體。最常見的有內(nèi)部員工、外部客戶、供應(yīng)商還有系統(tǒng)本身。但代理不等于用戶表。我在項(xiàng)目里犯過一個(gè)典型的錯(cuò)以為代理就是“用戶”那張表。后來發(fā)現(xiàn)同一個(gè)用戶可能同時(shí)是內(nèi)部采購(gòu)審批人、也可能是供應(yīng)商對(duì)接人甚至在某些場(chǎng)景下還需要虛擬代理比如“系統(tǒng)自動(dòng)巡檢”。所以落地時(shí)代理要拆成兩層代理實(shí)體用來標(biāo)識(shí)“誰”對(duì)應(yīng)真實(shí)的賬號(hào)、公司或系統(tǒng)參與角色用來標(biāo)識(shí)“以什么身份參與”比如買家、賣家、審批人、經(jīng)辦人。一個(gè)事件和一個(gè)代理之間是多對(duì)多關(guān)系。某個(gè)銷售出庫(kù)事件里客戶是買方、銷售員是經(jīng)辦人、倉(cāng)管員是發(fā)貨執(zhí)行人這些都是同一條事件上的不同角色。2.4 “誰-何時(shí)-何物”的關(guān)系連線規(guī)則把三要素串起來會(huì)得到幾條非常穩(wěn)定的規(guī)則我每次建模都會(huì)拿它來做自檢沒有任何資源會(huì)憑空增加一定有某個(gè)事件讓它流入沒有任何資源會(huì)憑空減少一定有某個(gè)事件讓它流出任何事件都必須有至少一個(gè)代理參與資金類和實(shí)物類資源的流入流出必須雙向配對(duì)也就是價(jià)值守恒。拿一條銷售出庫(kù)來說事件流入資源流出資源參與代理銷售出庫(kù)應(yīng)收賬款/現(xiàn)金增加庫(kù)存商品減少客戶、銷售、倉(cāng)管采購(gòu)入庫(kù)庫(kù)存商品增加應(yīng)付賬款增加供應(yīng)商、采購(gòu)員、倉(cāng)管你看這不是“隨手記一筆庫(kù)存的變化”而是把業(yè)務(wù)動(dòng)作從源頭到結(jié)果連成了一閉環(huán)。任何一筆庫(kù)存增加都能追溯到對(duì)應(yīng)的采購(gòu)入庫(kù)事件任何一筆資金流動(dòng)也都能追溯到對(duì)應(yīng)的業(yè)務(wù)事件。這套規(guī)則做順了以后對(duì)賬就是按事件流直接展開不用再人肉拼數(shù)據(jù)。3. 一個(gè)訂單庫(kù)存系統(tǒng)的 REA 落地實(shí)錄3.1 先梳理業(yè)務(wù)事件別急著建表我改造某一個(gè)電商后臺(tái)的時(shí)候第一步不是畫表而是拉著業(yè)務(wù)把關(guān)鍵動(dòng)作一條一條列出來。這里特別關(guān)鍵一定要先把“業(yè)務(wù)上有哪些事實(shí)發(fā)生”想清楚再談表怎么建。當(dāng)時(shí)整理出來的核心事件清單大致如下事件類型說明涉及資源變化采購(gòu)入庫(kù)商品到貨庫(kù)存增加庫(kù)存流入應(yīng)付賬務(wù)對(duì)應(yīng)變化銷售出庫(kù)客戶下單并發(fā)貨庫(kù)存減少庫(kù)存流出應(yīng)收賬務(wù)對(duì)應(yīng)變化庫(kù)存盤點(diǎn)調(diào)整實(shí)盤和系統(tǒng)不一致手動(dòng)修正庫(kù)存流入或流出退貨入庫(kù)客戶退回商品庫(kù)存流入退款/紅沖對(duì)應(yīng)金額拒收取消訂單取消需要恢復(fù)庫(kù)存庫(kù)存回流資金沖銷這一步做完你就發(fā)現(xiàn)業(yè)務(wù)看起來五花八門但落到 REA 模型里無非就是不同事件類型去改變不同資源的方向和數(shù)量。這個(gè)認(rèn)知確立以后后面建表和寫代碼都變得特別順。3.2 檢查事件之間的雙向約束和守恒關(guān)系列完事件清單我做了第二件事拿“雙向約束”去校驗(yàn)每個(gè)事件有沒有配對(duì)好。比如采購(gòu)入庫(kù)這個(gè)事件它不能只看作“庫(kù)存商品增加了”還要看到“應(yīng)付賬款增加了”。否則庫(kù)存這邊加了一百箱貨財(cái)務(wù)那邊卻不知道要付多少錢月底一查賬資金流和貨物流就對(duì)不上。銷售出庫(kù)同理庫(kù)存減少只是其中一側(cè)另一側(cè)是應(yīng)收賬款或者現(xiàn)金增加。退貨入庫(kù)則是相反方向的鏡像操作。我當(dāng)時(shí)畫了一張很簡(jiǎn)單的對(duì)照表把每個(gè)事件的兩側(cè)資源變化都列清楚事件資源側(cè) A資源側(cè) B配對(duì)邏輯采購(gòu)入庫(kù)庫(kù)存 100應(yīng)付 100貨到即欠款銷售出庫(kù)庫(kù)存 -2應(yīng)收 2貨出即債權(quán)退貨入庫(kù)庫(kù)存 1應(yīng)收 -1貨回則退債現(xiàn)金收款現(xiàn)金 2應(yīng)收 -2錢到則消債這步的價(jià)值在于業(yè)務(wù)規(guī)則還沒寫代碼就已經(jīng)被結(jié)構(gòu)化地推演過一遍很多后續(xù)開發(fā)階段才會(huì)發(fā)現(xiàn)的口徑問題在建模階段就能被擋掉。3.3 數(shù)據(jù)庫(kù)表怎么設(shè)計(jì)建模確認(rèn)后我把表結(jié)構(gòu)設(shè)計(jì)成下面這套。這里需要說明的是這是基于常見實(shí)踐整理出的通用落地方案實(shí)際項(xiàng)目可以按需增加字段和索引。資源表CREATE TABLE resource ( resource_id BIGINT PRIMARY KEY, resource_name VARCHAR(128) NOT NULL, resource_type VARCHAR(32) NOT NULL, -- inventory / cash / receivable / points measure_unit VARCHAR(16) NOT NULL, -- 計(jì)量單位箱、件、元、分 description VARCHAR(256), created_time DATETIME NOT NULL, updated_time DATETIME NOT NULL );代理表CREATE TABLE agent ( agent_id BIGINT PRIMARY KEY, agent_name VARCHAR(128) NOT NULL, agent_type VARCHAR(32) NOT NULL, -- internal / customer / supplier / system contact_info VARCHAR(128), status TINYINT NOT NULL DEFAULT 1, created_time DATETIME NOT NULL, updated_time DATETIME NOT NULL );事件表只做追加不更新不刪除CREATE TABLE business_event ( event_id BIGINT PRIMARY KEY, event_type VARCHAR(64) NOT NULL, -- purchase_in / sale_out / return_in ... occurred_at DATETIME NOT NULL, description VARCHAR(256), request_id VARCHAR(64) NOT NULL, -- 冪等鍵防重復(fù)提交 created_time DATETIME NOT NULL, UNIQUE KEY uk_request_id (request_id) );事件與資源的關(guān)聯(lián)明細(xì)表CREATE TABLE event_resource_item ( item_id BIGINT PRIMARY KEY, event_id BIGINT NOT NULL, resource_id BIGINT NOT NULL, direction VARCHAR(8) NOT NULL, -- in / out quantity DECIMAL(18,4) NOT NULL, unit_price DECIMAL(18,4) NULL, remark VARCHAR(128), KEY idx_event_id (event_id), KEY idx_resource_id (resource_id) );事件與代理的關(guān)聯(lián)明細(xì)表CREATE TABLE event_agent_item ( item_id BIGINT PRIMARY KEY, event_id BIGINT NOT NULL, agent_id BIGINT NOT NULL, role_type VARCHAR(32) NOT NULL, -- buyer / seller / auditor / operator KEY idx_event_id (event_id), KEY idx_agent_id (agent_id) );這幾張表的配合方式是業(yè)務(wù)發(fā)生一筆動(dòng)作業(yè)務(wù)事件寫一條主記錄再通過明細(xì)表掛上它影響的多個(gè)資源、參與的多個(gè)代理。所有查詢都可以從事件主鍵出發(fā)把完整鏈路撈出來。3.4 服務(wù)層代碼如何保證一致性表結(jié)構(gòu)定了之后最核心的實(shí)現(xiàn)就是寫事件落庫(kù)和資源余額更新的服務(wù)。我用的偽代碼是這樣的實(shí)際項(xiàng)目可以用任意語言照這套邏輯去寫class InventoryServiceImpl: tx_manager.transaction def record_inventory_event(self, event_type, occurred_at, agent_ids, resource_id, direction, quantity, request_id, description): # 1. 冪等校驗(yàn)同一個(gè) request_id 不能重復(fù)入賬 if self.event_repo.exists_by_request_id(request_id): self.logger.warning(duplicated request: %s, request_id) return False # 2. 保存事件主記錄 event_id self.event_repo.insert( event_typeevent_type, occurred_atoccurred_at, descriptiondescription, request_idrequest_id, ) # 3. 保存事件-資源明細(xì) self.event_resource_repo.insert( event_idevent_id, resource_idresource_id, directiondirection, quantityquantity, ) # 4. 保存事件-代理明細(xì) for agent_id, role_type in agent_ids: self.event_agent_repo.insert( event_idevent_id, agent_idagent_id, role_typerole_type, ) # 5. 更新資源余額 balance self.balance_repo.lock_for_update(resource_id) if direction in: balance.quantity balance.quantity quantity elif direction out: if balance.quantity quantity: raise InsufficientStockError(resource_id) balance.quantity balance.quantity - quantity self.balance_repo.update(balance) return True這里最關(guān)鍵的一點(diǎn)是步驟 5 里的lock_for_update。庫(kù)存扣減是典型的并發(fā)敏感操作必須在事務(wù)里對(duì)目標(biāo)資源余額做行級(jí)鎖否則兩個(gè)線程同時(shí)賣最后一件商品就可能會(huì)出現(xiàn)超賣。另外注意事件明細(xì)表和資源余額表是在同一個(gè)事務(wù)里提交的。這樣能保證要么事件和余額一起成功要么一起回滾不會(huì)出現(xiàn)“事件記了但庫(kù)存沒減”或者“庫(kù)存減了但事件沒記”這類臟數(shù)據(jù)。3.5 展示層怎么做查詢有人擔(dān)心事件驅(qū)動(dòng)模型查詢會(huì)變慢因?yàn)槊看我串?dāng)前庫(kù)存都要去掃事件流。實(shí)際落地根本不用這么干。我的做法是維護(hù)一套“最新余額表”也就是物化視圖或者定時(shí)聚合任務(wù)。資源主表里始終保存當(dāng)前可用數(shù)量事件流保存每一次變化的完整軌跡。平時(shí)業(yè)務(wù)查詢走余額表十億級(jí)事件量也不怕審計(jì)和對(duì)賬的時(shí)候才去翻事件明細(xì)那本來就不追求毫秒級(jí)性能。這套設(shè)計(jì)本質(zhì)上是把“寫模型”和“讀模型”分開寫側(cè)是追加流水讀側(cè)是查詢余量。比傳統(tǒng)的“主表更新狀態(tài) 流水表存歷史”要清晰得多因?yàn)闊o論是寫還是讀各自走一條最舒服的路徑。4. 常見問題與排坑實(shí)錄4.1 事件粒度到底該細(xì)到什么程度落地 REA 時(shí)最常被問的問題就是一個(gè)下單動(dòng)作到底要拆成幾個(gè)事件拆太細(xì)比如把“點(diǎn)擊下單”也記錄成事件系統(tǒng)會(huì)被海量無意義事件淹沒真正要追溯業(yè)務(wù)時(shí)反而找不著重點(diǎn)。拆太粗比如把 “下單支付發(fā)貨” 全部塞進(jìn)一個(gè)事件里那中間任何一步失敗這條事件到底算成功還是失敗就成了說不清的事。我習(xí)慣的粒度標(biāo)準(zhǔn)是只有“真正改變資源狀態(tài)”的動(dòng)作才值得記成事件。點(diǎn)擊下單本身不改變庫(kù)存和資金所以不用建事件但確認(rèn)支付會(huì)讓資金增加所以支付成功必須建事件出庫(kù)會(huì)讓庫(kù)存減少所以發(fā)貨出庫(kù)也必須獨(dú)立建事件。4.2 庫(kù)存可用數(shù)、在途數(shù)、預(yù)占數(shù)怎么處理REA 模型下的資源余額只代表“當(dāng)前時(shí)點(diǎn)的存量”但實(shí)際業(yè)務(wù)還經(jīng)常需要區(qū)分可用庫(kù)存、在途庫(kù)存、預(yù)占庫(kù)存。這些怎么辦我給出的解決方式是不同口徑建不同的資源賬戶而不是在一個(gè)資源余額表上硬加一堆狀態(tài)字段。比如同一件商品可以拆成“可用庫(kù)存”和“預(yù)占庫(kù)存”兩個(gè)資源賬戶。下單時(shí)從可用庫(kù)存扣減、轉(zhuǎn)入預(yù)占庫(kù)存發(fā)貨時(shí)再?gòu)念A(yù)占庫(kù)存扣減同時(shí)記一條出庫(kù)事件。這樣每個(gè)口徑的余額都是獨(dú)立的查數(shù)清清楚楚不會(huì)出現(xiàn)“可用數(shù)到底是負(fù)數(shù)還是預(yù)占沒扣掉”這種糊涂賬。4.3 金額、成本價(jià)要不要全部建模成資源資金和庫(kù)存是自古以來的對(duì)賬難題所以金額相關(guān)的東西最容易觸發(fā) REA 建模沖動(dòng)。但我實(shí)際做下來的體會(huì)是不是所有金額都要建模成獨(dú)立資源否則資源表會(huì)膨脹得讓你哭出來。一個(gè)務(wù)實(shí)的方案是事件明細(xì)上直接保存單價(jià)和金額字段只有“真正獨(dú)立的資金賬戶”才建模成資源。應(yīng)收應(yīng)付這種需要長(zhǎng)期跟蹤余額的賬戶值得用資源建模而單筆訂單里的商品銷售金額只要跟著事件明細(xì)記錄就足夠了。判斷邏輯依然是那條老標(biāo)準(zhǔn)這個(gè)金額需不需要回答“當(dāng)前還剩多少”如果不需要直接作為事件屬性保存就可以。4.4 老系統(tǒng)改造時(shí)歷史數(shù)據(jù)怎么遷移這是所有改造項(xiàng)目最頭疼的一環(huán)REA 也不例外。如果你試圖把過去三年的所有訂單全部分解成事件再重新入賬工作量會(huì)大到項(xiàng)目直接夭折。正確做法是區(qū)分處理對(duì)于改造時(shí)間點(diǎn)之前的歷史數(shù)據(jù)生成一條“期初初始化事件”直接把當(dāng)時(shí)的庫(kù)存余額、應(yīng)收應(yīng)付余額一次性寫入資源余額表作為起點(diǎn)快照對(duì)于改造時(shí)間點(diǎn)之后的增量數(shù)據(jù)嚴(yán)格按照事件驅(qū)動(dòng)方式入賬。這套“快照 增量”的策略既能保證歷史數(shù)據(jù)可追溯又能把遷移成本控制在一個(gè)可接受范圍內(nèi)。我實(shí)際落地時(shí)發(fā)現(xiàn)賬實(shí)相符的關(guān)鍵不在于歷史是否拆得足夠細(xì)而在于期初快照選取得準(zhǔn)不準(zhǔn)。4.5 排坑小貼士最后把我踩過幾次坑之后總結(jié)出來的幾條實(shí)操經(jīng)驗(yàn)寫在這里每一條都是血淚教訓(xùn)冪等鍵一定要做。REA 事件只追加不更新一旦重復(fù)提交庫(kù)存余額和資金余額就會(huì)被無辜多記一次。事件表里加上唯一 request_id冪等校驗(yàn)放在事務(wù)最前面能擋住絕大多數(shù)重復(fù)請(qǐng)求。時(shí)間字段全部用 UTC 存儲(chǔ)。業(yè)務(wù)顯示層再轉(zhuǎn)本地時(shí)區(qū)。如果數(shù)據(jù)庫(kù)混著本地時(shí)間和 UTC 存月底對(duì)賬時(shí)你會(huì)被時(shí)區(qū)問題折磨瘋掉。事件表和余額表的更新必須同一個(gè)事務(wù)。沒有例外。拆成兩個(gè)事務(wù)的話一定會(huì)遇到“事件記錄成功但余額更新失敗”的中間態(tài)。庫(kù)存扣減一定要鎖定余額行。不用悲觀鎖或者分布式鎖高并發(fā)下超賣就是一句話的事。定期跑一次對(duì)賬任務(wù)。讓系統(tǒng)每天晚上自動(dòng)把當(dāng)天所有事件流按資源維度匯總和余額表做一次比對(duì)。有差異就報(bào)警不要等到月底才發(fā)現(xiàn)問題。這套 REA 模型我后來也在別的業(yè)務(wù)模塊里試過包括積分賬戶、卡券核銷、渠道傭金結(jié)算基本思路完全通用。真正理解它的精髓之后你會(huì)發(fā)現(xiàn)所謂架構(gòu)設(shè)計(jì)很多時(shí)候不是代碼寫得有多炫而是把業(yè)務(wù)的因果關(guān)系在數(shù)據(jù)模型層面擺得足夠正、足夠穩(wěn)。