全能網(wǎng)站服務(wù)器,選擇響應(yīng)式網(wǎng)站,自己本地可以做網(wǎng)站服務(wù)器,廣州冼村和獵德村哪個(gè)最有錢MyBatisPlus 樂觀鎖#xff1a;防止多個(gè)線程同時(shí)修改同一 Token 余額 在高并發(fā)系統(tǒng)中#xff0c;用戶資產(chǎn)類數(shù)據(jù)的更新始終是開發(fā)中的“雷區(qū)”。比如一個(gè)常見的場(chǎng)景#xff1a;用戶參與活動(dòng)需要扣除 10 個(gè) Token#xff0c;但若多個(gè)請(qǐng)求幾乎同時(shí)發(fā)起#xff0c;且服務(wù)端沒…MyBatisPlus 樂觀鎖防止多個(gè)線程同時(shí)修改同一 Token 余額在高并發(fā)系統(tǒng)中用戶資產(chǎn)類數(shù)據(jù)的更新始終是開發(fā)中的“雷區(qū)”。比如一個(gè)常見的場(chǎng)景用戶參與活動(dòng)需要扣除 10 個(gè) Token但若多個(gè)請(qǐng)求幾乎同時(shí)發(fā)起且服務(wù)端沒有做好并發(fā)控制就可能出現(xiàn)余額被超扣的問題——原本只有 15 個(gè) Token 的用戶連續(xù)兩次操作后余額變成 -5這顯然不可接受。傳統(tǒng)做法是使用數(shù)據(jù)庫行鎖SELECT FOR UPDATE或 Java 層面的synchronized來串行化訪問但這意味著性能犧牲。尤其在微服務(wù)架構(gòu)下單點(diǎn)同步無法跨實(shí)例生效而數(shù)據(jù)庫鎖又容易成為瓶頸。有沒有一種既能保障一致性、又不犧牲吞吐量的方案MyBatisPlus 的樂觀鎖機(jī)制給出了優(yōu)雅的答案。從一個(gè)真實(shí)問題說起為什么余額會(huì)變負(fù)設(shè)想這樣一個(gè)流程用戶 A 當(dāng)前有 10 個(gè) Token同時(shí)觸發(fā)兩個(gè)任務(wù)簽到獎(jiǎng)勵(lì)消耗 5 個(gè)抽獎(jiǎng)活動(dòng)也消耗 5 個(gè)兩個(gè)線程幾乎同時(shí)查詢到余額為 10都基于此值計(jì)算出新余額為 5并嘗試更新數(shù)據(jù)庫無沖突地接受了兩次更新最終結(jié)果看似正常。但再進(jìn)一步如果這兩個(gè)操作都是“減 8”呢線程1讀取余額 10判斷夠扣 → 準(zhǔn)備更新為 2線程2也讀取余額 10判斷夠扣 → 準(zhǔn)備更新為 2兩者先后執(zhí)行UPDATE user_token SET token_balance 2 WHERE user_id ?最終余額確實(shí)是 2但實(shí)際應(yīng)只允許一次成功另一次應(yīng)當(dāng)失敗。更危險(xiǎn)的是若系統(tǒng)未做兜底校驗(yàn)甚至可能讓余額變?yōu)樨?fù)數(shù)。這種“競(jìng)態(tài)條件”正是并發(fā)編程中最隱蔽卻最致命的問題之一。要解決它核心在于確?！白x取—修改—寫入”這一系列動(dòng)作的原子性。而樂觀鎖正是實(shí)現(xiàn)這一點(diǎn)的輕量化手段。什么是樂觀鎖MyBatisPlus 是怎么做的樂觀鎖的基本思想很像 Git 的合并邏輯你在本地修改文件時(shí)并不加鎖但在提交時(shí)會(huì)檢查目標(biāo)分支是否已被他人改動(dòng)。如果有沖突你就得先拉取最新代碼再重試。映射到數(shù)據(jù)庫操作中就是查詢時(shí)帶上版本號(hào)如version1更新時(shí)附加條件WHERE version 1如果期間其他事務(wù)已將該記錄版本升至 2則當(dāng)前更新影響行數(shù)為 0說明發(fā)生了沖突此時(shí)由應(yīng)用決定是否重試。MyBatisPlus 將這套機(jī)制封裝得極為簡潔。你只需在實(shí)體類中標(biāo)記一個(gè)字段為Version框架便會(huì)自動(dòng)攔截所有updateById類型的操作在生成的 SQL 中加入版本比對(duì)和自增邏輯。舉個(gè)例子當(dāng)你調(diào)用mapper.updateById(entity)時(shí)MyBatisPlus 實(shí)際執(zhí)行的 SQL 是這樣的UPDATE user_token SET token_balance #{tokenBalance}, version version 1, updated_at NOW() WHERE id #{id} AND version #{version}注意最后的AND version #{version}—— 這就是樂觀鎖的核心所在。如果此時(shí)數(shù)據(jù)庫中的version已經(jīng)不是 entity 原始讀取的那個(gè)值這條語句就不會(huì)更新任何行返回影響行數(shù)為 0。MyBatisPlus 檢測(cè)到這種情況后會(huì)拋出OptimisticLockException提醒開發(fā)者處理沖突。整個(gè)過程無需手動(dòng)拼接 SQL也不依賴復(fù)雜的事務(wù)控制真正做到了“聲明即生效”。如何快速接入三步搞定第一步定義實(shí)體類標(biāo)記版本字段Data TableName(user_token) public class UserToken { private Long id; private Long userId; private Integer tokenBalance; Version private Integer version; // 版本號(hào)字段 }?? 注意事項(xiàng)-Version字段類型推薦使用Integer或Long- 初始值建議設(shè)為1便于追蹤首次更新- 不支持浮點(diǎn)類型或字符串類型。第二步注冊(cè)樂觀鎖插件從 MyBatisPlus 3.4.0 開始推薦通過MybatisPlusInterceptor注冊(cè)內(nèi)置攔截器Configuration MapperScan(com.example.mapper) public class MyBatisPlusConfig { Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor new MybatisPlusInterceptor(); interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor()); return interceptor; } }這個(gè)配置一旦完成所有符合規(guī)則的更新操作都會(huì)自動(dòng)啟用樂觀鎖保護(hù)完全透明無感。第三步編寫業(yè)務(wù)邏輯加入重試機(jī)制光有樂觀鎖還不夠你還得應(yīng)對(duì)沖突發(fā)生后的場(chǎng)景。畢竟不能因?yàn)橐淮问【椭苯臃祷劐e(cuò)誤給用戶。合理的做法是進(jìn)行有限次重試。Service Transactional public class TokenService { Autowired private UserTokenMapper userTokenMapper; public boolean deductToken(Long userId, int amount) { int maxRetries 3; for (int i 0; i maxRetries; i) { try { // 查詢當(dāng)前余額與版本 UserToken token userTokenMapper.selectByUserId(userId); if (token null || token.getTokenBalance() amount) { throw new IllegalArgumentException(Token不足); } // 計(jì)算新余額 token.setTokenBalance(token.getTokenBalance() - amount); // 執(zhí)行更新自動(dòng)帶 version 條件 int updated userTokenMapper.updateById(token); if (updated 0) { return true; // 成功退出 } } catch (OptimisticLockException e) { // 可選記錄日志或增加退避時(shí)間 if (i maxRetries - 1) { throw new RuntimeException(操作頻繁請(qǐng)稍后再試, e); } try { Thread.sleep(50 new Random().nextInt(50)); // 隨機(jī)退避 } catch (InterruptedException ie) { Thread.currentThread().interrupt(); } } } return false; } }這里有幾個(gè)關(guān)鍵設(shè)計(jì)點(diǎn)值得強(qiáng)調(diào)重試次數(shù)不宜過多一般 2~5 次足夠避免造成響應(yīng)延遲引入隨機(jī)退避減少多個(gè)線程同時(shí)重試導(dǎo)致再次碰撞的概率盡早拋出明確異常當(dāng)重試耗盡時(shí)應(yīng)返回對(duì)用戶友好的提示而非堆棧信息事務(wù)邊界要短不要把整個(gè)循環(huán)包在一個(gè)大事務(wù)里否則容易引發(fā)鎖等待。表結(jié)構(gòu)設(shè)計(jì)與最佳實(shí)踐對(duì)應(yīng)的 MySQL 表結(jié)構(gòu)如下CREATE TABLE user_token ( id BIGINT PRIMARY KEY AUTO_INCREMENT, user_id BIGINT UNIQUE NOT NULL, token_balance INT DEFAULT 0, version INT DEFAULT 1, created_at DATETIME DEFAULT CURRENT_TIMESTAMP, updated_at DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP );幾點(diǎn)建議user_id加唯一索引方便按用戶查詢version默認(rèn)值設(shè)為1避免NULL帶來的判斷復(fù)雜度updated_at自動(dòng)更新便于追蹤最后修改時(shí)間若存在高頻查詢可結(jié)合 Redis 緩存userId - balance/version映射減少數(shù)據(jù)庫壓力。不過要注意緩存一致性問題。推薦策略是先更新數(shù)據(jù)庫再刪除緩存這樣能最大程度保證強(qiáng)一致性。即使緩存未及時(shí)重建下次查詢也會(huì)回源到數(shù)據(jù)庫獲取最新值。和悲觀鎖相比到底好在哪維度悲觀鎖樂觀鎖MyBatisPlus加鎖時(shí)機(jī)讀取即鎖定資源更新時(shí)才檢測(cè)沖突性能表現(xiàn)低并發(fā)下穩(wěn)定高并發(fā)易阻塞無鎖運(yùn)行僅沖突時(shí)重試適用場(chǎng)景寫密集、沖突頻繁讀多寫少、偶爾更新實(shí)現(xiàn)成本需顯式寫FOR UPDATE易遺漏注解驅(qū)動(dòng)零侵入對(duì)于 Token、積分、優(yōu)惠券這類“更新頻率不高但一致性要求極高”的字段樂觀鎖幾乎是首選方案。它既避免了悲觀鎖帶來的性能瓶頸又能有效防止超賣和負(fù)余額問題。實(shí)際應(yīng)用中的注意事項(xiàng)盡管樂觀鎖強(qiáng)大但在落地過程中仍有一些陷阱需要注意1. 不適合高頻寫入的熱點(diǎn)賬戶如果你的服務(wù)中有“頭部用戶”比如某個(gè)主播收到海量打賞其 Token 記錄被持續(xù)更新那么樂觀鎖的沖突率會(huì)急劇上升導(dǎo)致大量重試甚至失敗。這時(shí)可以考慮分段設(shè)計(jì)將單一余額拆分為多個(gè)子賬戶如 bucket1~bucket5分散寫壓力異步隊(duì)列將扣減請(qǐng)求放入 Kafka/RocketMQ串行消費(fèi)處理使用 CAS 型指令如 Redis 的 Lua 腳本做預(yù)檢。2. 避免在事務(wù)中長時(shí)間停留以下代碼是典型反例Transactional public void badDeduct(Long userId, int amount) { UserToken token mapper.selectById(userId); // 事務(wù)開始 Thread.sleep(5000); // 其他耗時(shí)操作 token.setTokenBalance(token.getTokenBalance() - amount); mapper.updateById(token); // 此時(shí) version 很可能已過期 }由于事務(wù)跨度太長中間可能發(fā)生其他更新導(dǎo)致最后updateById必然失敗。正確做法是縮短事務(wù)范圍只包裹真正的寫操作。3. 監(jiān)控重試率及時(shí)發(fā)現(xiàn)問題可以在日志中記錄樂觀鎖失敗次數(shù)log.warn(樂觀鎖沖突用戶ID{}第{}次重試, userId, i 1);然后通過 ELK 或 Prometheus 收集統(tǒng)計(jì)指標(biāo)。如果發(fā)現(xiàn)某類操作重試率超過 5%就要警惕是否存在熱點(diǎn)數(shù)據(jù)或邏輯缺陷。4. 前端體驗(yàn)優(yōu)化當(dāng)用戶因“操作太頻繁”被拒絕時(shí)不要返回500 Internal Error而是給出清晰提示{ code: 409, message: 操作過于頻繁請(qǐng)稍后重試 }必要時(shí)可在前端添加防抖機(jī)制限制短時(shí)間內(nèi)重復(fù)提交。它還能用在哪些地方除了 Token 余額樂觀鎖同樣適用于商品庫存扣減低并發(fā)場(chǎng)景尤其適合秒殺后補(bǔ)貨、限量兌換等非超高頻寫入場(chǎng)景。配置項(xiàng)版本管理多人編輯后臺(tái)配置時(shí)防止覆蓋彼此更改。訂單狀態(tài)流轉(zhuǎn)例如從“待支付”到“已取消”需防止重復(fù)關(guān)閉。任務(wù)調(diào)度去重分布式環(huán)境下多個(gè)節(jié)點(diǎn)搶任務(wù)可通過樂觀鎖更新任務(wù)狀態(tài)實(shí)現(xiàn)搶占。只要涉及“先查后改”的復(fù)合操作且希望避免加鎖開銷都可以考慮引入樂觀鎖。結(jié)語MyBatisPlus 的樂觀鎖不是一個(gè)炫技功能而是一個(gè)真正解決實(shí)際問題的工程利器。它用極簡的方式實(shí)現(xiàn)了“無鎖并發(fā)控制”讓我們?cè)谧非蟾咝阅艿耐瑫r(shí)不必以犧牲數(shù)據(jù)一致性為代價(jià)。更重要的是它的接入成本極低一個(gè)注解 一行配置 幾次重試就能構(gòu)建出可靠的并發(fā)更新邏輯。對(duì)于大多數(shù)中小型項(xiàng)目而言這已經(jīng)足夠應(yīng)對(duì)絕大多數(shù)競(jìng)爭(zhēng)場(chǎng)景。當(dāng)然技術(shù)沒有銀彈。面對(duì)極端高并發(fā)或熱點(diǎn)數(shù)據(jù)問題仍需結(jié)合緩存、消息隊(duì)列、分片等手段綜合治理。但至少在多數(shù)日常場(chǎng)景下MyBatisPlus 樂觀鎖已經(jīng)為我們筑起了一道堅(jiān)實(shí)的數(shù)據(jù)安全防線。