node.js - nodejs單進程產生的數據庫連接多線程并發問題探討
問題描述
舉例,假設有100個請求node服務器,每個請求會執行一次查詢,修改數據庫操作。假設10個請求按順序被node接收處理 等待各自判定庫存查詢數據庫io操作,但是庫存只有5個,問題來了,這時候10個查詢都判定庫存還有,然后繼續下面的下單操作。當100個請求甚至更多時,問題會被更加放大 又不能同步加鎖,哪位朋友有比較合理的思路 不吝賜教~
問題解答
回答1:站內搜“搶購”https://segmentfault.com/sear...
極端情況為“秒殺”https://segmentfault.com/sear...
回答2:你這種情況應該加上事務
----- 更新下答案 -----
查詢和實際數據不一致的問題是無法避免的,我的理解題主的意思應該是在更新callback之前有其他用戶購買成功的情況會導致購買失敗的問題,因此可以通過加鎖解決,其實如果異步操作都使用 promise 的情況下,可以通過Promise 模擬順序調用來實現類似java方法加鎖的特性
通過 decorator 對返回 promise 的方法實現類似java synchronized 關鍵字的同步調用
// decoratorlet pfunction sync(target, name) { const method = target[name] target[name] = function(...args) { if (p) { p = p.then(() => method.apply(target, args)) } else { p = method.apply(target, args) } return p }}class Model { constructor () { // super() this._cardCount = 5 sync(this, ’buyOneCard’) } // @sync // 注解需要編譯,暫時手動調用下 buyOneCard (user) { console.log(’buyonecard’, this._cardCount) return new Promise((resolve, reject) => { setTimeout(() => {this._cardCount = --this._cardCount this._cardCount < 0 ? reject(this._cardCount) : resolve(this._cardCount) }, 100) }) }}const m = new Model()for(let i=0;i<10;i++) m.buyOneCard().then(c => console.log(c))
chrome 下運行通過。。
----- 再更新 ----
github 上已經有類似工具https://github.com/sindresorh...
回答3:謝謝樓上兩位,首先我描述的場景是正常商品銷售,如果是搶購倒好辦 直接用redis隊列可以解決,但是商品種類多的時候 這種方式不可取。
回復樓上,這里面事務是肯定有的,但是事務并不能解決這種并發超賣的情景。 最后,如果這是用java可以很方便用隊列或同步鎖解決,但是node并不適用以上場景,redis也只能解決搶購,誰有還有合適的方案 ,期待中~回答4:
事務 + 條件更新 從設計上避免了超賣。
相關文章:
