您好,登錄后才能下訂單哦!
怎么在MySQL中利用DB實現分布式鎖?相信很多沒有經驗的人對此束手無策,為此本文總結了問題出現的原因和解決方法,通過這篇文章希望你能解決這個問題。
表設計
首先要明確DB在系統中仍然需要認為是最脆弱的一環,因此在設計時需要考慮壓力問題,即能應用實現的邏輯就不要放到DB上實現,也就是盡量少使用DB提供的鎖能力,如果是高并發業務則要避免使用DB鎖,換成Redis等緩存鎖更加有效。如清單1所示,該表中唯一的約束為lock_name,timestamp,version三者組合主鍵,下文會利用這三者實現悲觀鎖,樂觀鎖等業務場景。
清單1: 分布式鎖表結構
CREATE TABLE `lock` ( `lock_name` varchar(32) NOT NULL DEFAULT '' COMMENT '鎖名稱', `resource` bigint(20) NOT NULL COMMENT '業務主鍵', `version` int(5) NOT NULL COMMENT '版本', `gmt_create` datetime NOT NULL COMMENT '生成時間', PRIMARY KEY (`lock_name`,`resource`,`version`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
悲觀鎖實現
對于悲觀鎖業務中常見的操作有以下兩種:
針對A:
A場景當一臺機器獲取到鎖后,其他機器處于排隊狀態,鎖釋放后其他機器才能夠繼續下去,這種應用層面解決是相當麻煩,因此一般使用DB提供的行鎖能力,即select xxx from xxx for update。A場景一般都和業務強關聯,比如庫存增減,使用業務對象作為行鎖即可。需要注意的是,該方案本質上鎖壓力還是在數據庫上,當阻塞住的線程過多,且操作耗時,最后會出現大量鎖超時現象。
針對B:
針對B場景(tryLock)舉個具體業務,在集群下每臺機器都有定時任務,但是業務上要求同一時刻只能有一臺能正常調度。
解決思路是利用唯一主鍵約束,插入一條針對TaskA的記錄,版本則默認為1,插入成功的算獲取到鎖,繼續執行業務操作。這種方案當機器掛掉就會出現死鎖,因此還需要有一個定時任務,定時清理已經過期的鎖,清理維度可以根據lock_name設置不同時間清理策略。
定時任務清理策略會額外帶來復雜度,假設機器A獲取到了鎖,但由于CPU資源緊張,導致處理變慢,此時鎖被定時任務釋放,因此機器B也會獲取到鎖,那么此時就出現同一時刻兩臺機器同時持有鎖的現象,解決思路:把超時時間設置為遠大于業務處理時間,或者增加版本機制改成樂觀鎖。
insert into lock set lock_name='TaskA' , resource='鎖住的業務',version=1,gmt_create=now() success: 獲取到鎖 failed:放棄操作 釋放鎖
樂觀鎖實現
針對樂觀鎖場景,舉個具體業務,在后臺系統中經常使用大json擴展字段存儲業務屬性,在涉及部分更新時,需要先查詢出來,合并數據,寫入到DB,這個過程中如果存在并發,則很容易造成數據丟失,因此需要使用鎖來保證數據一致性,相應操作如下所示,針對樂觀鎖,不存在死鎖,因此這里直接存放業務id字段,保證每一個業務id有一條對應的記錄,并且不需要對應的定時器清除。
select * from lock where lock_name='業務名稱', resource='業務id'; 不存在: insert into lock set lock_name='業務名稱', resource='業務id' , version=1; 獲取版本: version 業務操作: 取數據,合并數據,寫回數據 寫回到DB: update lock set version=version+1 where lock_name='業務名稱' and resource='業務id' and version= #{version}; 寫回成功: 操作成功 寫回失敗: 回滾事務,從頭操作
看完上述內容,你們掌握怎么在MySQL中利用DB實現分布式鎖的方法了嗎?如果還想學到更多技能或想了解更多相關內容,歡迎關注億速云行業資訊頻道,感謝各位的閱讀!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。