悲觀鎖和樂(lè)觀鎖是用來(lái)解決并發(fā)問(wèn)題的兩種思想，在不同的平臺(tái)有著各自的實(shí)現(xiàn)。例如在Java中，synchronized就可以認(rèn)為是悲觀鎖的實(shí)現(xiàn)(不嚴(yán)謹(jǐn)，有鎖升級(jí)的過(guò)程，升級(jí)到重量級(jí)鎖才算)，Atomic***原子類(lèi)可以認(rèn)為是樂(lè)觀鎖的實(shí)現(xiàn)。

悲觀鎖

具有強(qiáng)烈的獨(dú)占和排他特性，在整個(gè)處理過(guò)程中將數(shù)據(jù)處于鎖定狀態(tài)，一般是通過(guò)系統(tǒng)的互斥量來(lái)實(shí)現(xiàn)。當(dāng)其他線程想要獲取鎖時(shí)會(huì)被阻塞，直到持有鎖的線程釋放鎖。

樂(lè)觀鎖

對(duì)數(shù)據(jù)的修改和訪問(wèn)持樂(lè)觀態(tài)度，假設(shè)不會(huì)發(fā)生沖突，只有當(dāng)數(shù)據(jù)提交更新時(shí)才會(huì)對(duì)數(shù)據(jù)沖突與否進(jìn)行檢測(cè)，如果沒(méi)有沖突則順利提交更新，否則快速失敗，返回一個(gè)錯(cuò)誤給用戶，讓用戶選擇接下來(lái)該如何去做，一般來(lái)說(shuō)失敗后會(huì)繼續(xù)重試，直到提交更新成功為止。

MySQL本身就支持鎖機(jī)制，例如我們有一個(gè)「先查再寫(xiě)」的需求，我們希望整個(gè)流程是一個(gè)原子操作，中間不能被打斷，這時(shí)候就可以通過(guò)給查詢(xún)的數(shù)據(jù)行加「排他鎖」來(lái)實(shí)現(xiàn)。只要當(dāng)前事務(wù)不釋放鎖，其他事務(wù)要想獲得排他鎖，MySQL就會(huì)將其阻塞，直到當(dāng)前事務(wù)釋放鎖。這種MySQL底層的排他鎖就稱(chēng)作「悲觀鎖」。

MySQL本身不提供樂(lè)觀鎖的功能，需要開(kāi)發(fā)者自己實(shí)現(xiàn)。普遍的做法是在表中加一個(gè)version列，用來(lái)標(biāo)記數(shù)據(jù)行的版本，當(dāng)我們需要更新數(shù)據(jù)時(shí)，必須比對(duì)version版本，version一致說(shuō)明這個(gè)期間數(shù)據(jù)沒(méi)有被其他事務(wù)修改過(guò)，否則說(shuō)明數(shù)據(jù)已經(jīng)被其他事務(wù)修改，需要自旋重試了。

實(shí)戰(zhàn)

假設(shè)數(shù)據(jù)庫(kù)有兩張表：商品表和訂單表。

用戶下單后需要執(zhí)行兩個(gè)操作：

1. 商品表減去庫(kù)存。
2. 訂單表創(chuàng)建一條記錄。

初始數(shù)據(jù)：ID為1的商品有100的庫(kù)存，訂單表數(shù)據(jù)為空。

客戶端啟動(dòng)10個(gè)線程并發(fā)下單，分別在無(wú)鎖、悲觀鎖、樂(lè)觀鎖的場(chǎng)景下有哪些表現(xiàn)。

如下是創(chuàng)建表的sql語(yǔ)句：

-- 商品表
CREATE TABLE `goods` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `goods_name` varchar(50) NOT NULL,
  `price` decimal(10,2) NOT NULL,
  `stock` int(11) DEFAULT '0',
  `version` int(10) unsigned NOT NULL DEFAULT '0',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8
-- 訂單表
CREATE TABLE `t_order` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `goods_id` bigint(20) NOT NULL,
  `order_time` datetime NOT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8

1、無(wú)鎖

不做任何處理。

// 下單
private boolean order(){
    Goods goods = goodsMapper.selectById(1L);
    boolean success = false;
    if (goods.getStock() > 0) {
        goods.setStock(goods.getStock() - 1);
        // 更新庫(kù)存
        goodsMapper.updateById(goods);
        // 創(chuàng)建訂單
        orderMapper.save(goods.getId());
        success = true;
    }
    return success;
}

控制臺(tái)輸出結(jié)果：

2、悲觀鎖

查詢(xún)商品時(shí)加FOR UPDATE，給數(shù)據(jù)行加排他鎖，這樣其他線程再查詢(xún)時(shí)就會(huì)被阻塞，直到當(dāng)前線程的事務(wù)提交并釋放鎖，其他線程才能繼續(xù)下單。這種方式并發(fā)性能不高。

sql語(yǔ)句

@Select("SELECT * FROM goods WHERE id = #{id} FOR UPDATE")
Goods selectForUpdate(Long id);

控制臺(tái)輸出結(jié)果：

注意：FOR UPDATE必須在事務(wù)中才有效，查詢(xún)和更新必須在同一個(gè)事務(wù)中?。。?/p>

3、樂(lè)觀鎖

實(shí)現(xiàn)思路是：每次更新時(shí)校驗(yàn)版本號(hào)，如果版本號(hào)一致說(shuō)明期間數(shù)據(jù)沒(méi)有被其他線程改過(guò)，當(dāng)前線程可以正常提交更新，否則說(shuō)明數(shù)據(jù)已經(jīng)被其他線程改過(guò)了，當(dāng)前線程需要自旋重試，直到業(yè)務(wù)成功為止。

更新數(shù)據(jù)的同時(shí)版本號(hào)必須自增?。?！

@Update("UPDATE goods SET stock = #{stock},version = version+1 WHERE id = #{id} AND version = #{version}")
int updateByVersion(Long id, Integer stock, Integer version);

業(yè)務(wù)代碼

boolean order(){
    Goods goods = goodsMapper.selectById(1L);
    boolean success = false;
    if (goods.getStock() > 0) {
        goods.setStock(goods.getStock() - 1);
        // 更新庫(kù)存，帶上版本號(hào)
        int result = goodsMapper.updateByVersion(goods.getId(), goods.getStock(), goods.getVersion());
        if (result <= 0) {
            // 更新失敗，說(shuō)明期間數(shù)據(jù)已經(jīng)被其他線程修改，需要遞歸重試
            return order();
        }
        // 創(chuàng)建訂單
        orderMapper.save(goods.getId());
        success = true;
    }
    return success;
}

控制臺(tái)輸出結(jié)果：

總結(jié)

到此這篇關(guān)于MySQL悲觀鎖與樂(lè)觀鎖方案的文章就介紹到這了,更多相關(guān)MySQL悲觀鎖與樂(lè)觀鎖內(nèi)容請(qǐng)搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！

美國(guó)服務(wù)器租用

版權(quán)聲明：本站文章來(lái)源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請(qǐng)保持原文完整并注明來(lái)源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非www.sddonglingsh.com所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來(lái)源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來(lái)，僅供學(xué)習(xí)參考，不代表本站立場(chǎng)，如有內(nèi)容涉嫌侵權(quán)，請(qǐng)聯(lián)系alex-e#qq.com處理。