簡(jiǎn)介

樂(lè)觀鎖是數(shù)據(jù)庫(kù)和應(yīng)用程序中使用的一種并發(fā)控制策略，用于在多個(gè)事務(wù)嘗試更新單個(gè)記錄時(shí)確保數(shù)據(jù)完整性。Java Persistence API (JPA) 提供了一種借助@Version注解在 Java 應(yīng)用程序中實(shí)現(xiàn)樂(lè)觀鎖的機(jī)制。在基于 Spring 的應(yīng)用程序的上下文中，與擴(kuò)展的 Spring Data JPA 庫(kù)結(jié)合使用時(shí)，他就發(fā)揮了作用。

了解樂(lè)觀鎖

在數(shù)據(jù)庫(kù)和應(yīng)用程序開(kāi)發(fā)領(lǐng)域，維護(hù)數(shù)據(jù)的完整性和一致性至關(guān)重要。這種情況下遇到的主要挑戰(zhàn)之一是處理對(duì)共享數(shù)據(jù)資源的并發(fā)訪問(wèn)，尤其是在涉及更新時(shí)。在分布式系統(tǒng)中，這個(gè)問(wèn)題就變得更加嚴(yán)重，其中多個(gè)用戶(hù)或服務(wù)可能會(huì)嘗試同時(shí)修改同一條數(shù)據(jù)。樂(lè)觀鎖是一種旨在管理并發(fā)訪問(wèn)而無(wú)需進(jìn)行嚴(yán)格鎖定的策略。

什么是樂(lè)觀鎖？

從本質(zhì)上講，樂(lè)觀鎖是在首次讀取或訪問(wèn)數(shù)據(jù)記錄進(jìn)行潛在更新，但實(shí)際上并未鎖定數(shù)據(jù)記錄。使系統(tǒng)在樂(lè)觀的假設(shè)下運(yùn)行，即沖突很少且不會(huì)經(jīng)常發(fā)生。僅當(dāng)即將提交實(shí)際更新時(shí)，系統(tǒng)才會(huì)檢查沖突。如果數(shù)據(jù)同時(shí)被另一個(gè)事務(wù)更改，則當(dāng)前更新失敗。

悲觀鎖與樂(lè)觀鎖

悲觀鎖： 在很多方面與樂(lè)觀鎖相反，一旦事務(wù)開(kāi)始就鎖定數(shù)據(jù)，從而防止任何其他事務(wù)在第一個(gè)事務(wù)完成之前訪問(wèn)相同的數(shù)據(jù)。雖然這保證了數(shù)據(jù)完整性，但這樣做的代價(jià)是潛在的瓶頸、吞吐量降低和死鎖的風(fēng)險(xiǎn)。

樂(lè)觀鎖： 樂(lè)觀鎖，如前所述，允許多個(gè)事務(wù)并發(fā)訪問(wèn)數(shù)據(jù)，只在最后一刻檢查沖突。這使得它適合讀操作遠(yuǎn)多于寫(xiě)操作并且數(shù)據(jù)沖突很少的場(chǎng)景。

底層機(jī)制

樂(lè)觀鎖的機(jī)制通常涉及系統(tǒng)的版本控制。數(shù)據(jù)庫(kù)中的每個(gè)記錄或?qū)嶓w都有一個(gè)關(guān)聯(lián)的版本號(hào)或時(shí)間戳。當(dāng)事務(wù)讀取記錄時(shí)，它還會(huì)記下其版本。在事務(wù)提交更新之前，它會(huì)檢查數(shù)據(jù)庫(kù)中的當(dāng)前版本是否與其之前記錄的版本匹配。如果它們匹配，則更新完成，并且版本號(hào)遞增。如果不是，則檢測(cè)到?jīng)_突，并且更新失敗。

樂(lè)觀鎖的好處

• 增強(qiáng)吞吐量： 由于在事務(wù)持續(xù)時(shí)間的大部分時(shí)間內(nèi)沒(méi)有持有鎖，因此等待時(shí)間最少。這導(dǎo)致同時(shí)處理更多的交易。
• 最小化死鎖： 死鎖是一種事務(wù)無(wú)限期地等待其他人鎖定的資源的情況，這種情況的可能性要小得多，因?yàn)閿?shù)據(jù)不會(huì)長(zhǎng)時(shí)間鎖定。
• 更好的可擴(kuò)展性： 隨著分布式系統(tǒng)和微服務(wù)架構(gòu)的興起，樂(lè)觀鎖定在確保系統(tǒng)能夠有效擴(kuò)展而無(wú)需管理復(fù)雜鎖機(jī)制的開(kāi)銷(xiāo)方面發(fā)揮著關(guān)鍵作用。

缺點(diǎn)

• 沖突管理開(kāi)銷(xiāo)： 在沖突頻繁的場(chǎng)景中，管理和解決沖突可能會(huì)占用大量資源。
• 復(fù)雜性： 實(shí)現(xiàn)樂(lè)觀鎖需要經(jīng)過(guò)深思熟慮的設(shè)計(jì)，特別是在處理失敗的事務(wù)時(shí)。
• 過(guò)時(shí)數(shù)據(jù)的可能性： 由于數(shù)據(jù)在讀取時(shí)未鎖定，因此事務(wù)可能會(huì)使用過(guò)時(shí)或過(guò)時(shí)的數(shù)據(jù)，如果管理不正確，可能會(huì)導(dǎo)致邏輯錯(cuò)誤或不一致。

Spring @Version注解

Spring JPA（Java Persistence API）為開(kāi)發(fā)人員提供了一組強(qiáng)大的工具來(lái)管理應(yīng)用程序中的關(guān)系型數(shù)據(jù)。其最強(qiáng)大的功能之一是處理并發(fā)性并確保多用戶(hù)環(huán)境中的數(shù)據(jù)完整性。這就是@Version注解發(fā)揮作用的地方，它提供了一種在 Spring JPA 中實(shí)現(xiàn)樂(lè)觀鎖的優(yōu)雅方法。

@Version的作用

該@Version注解用于啟用實(shí)體上的樂(lè)觀鎖，確保數(shù)據(jù)庫(kù)中的數(shù)據(jù)更新不會(huì)出現(xiàn)并發(fā)修改問(wèn)題。當(dāng)實(shí)體中的某個(gè)字段標(biāo)記為@Version時(shí)，JPA 將使用該字段來(lái)跟蹤更改并確保一次只有一個(gè)事務(wù)可以更新特定行。

它是如何工作的？

每個(gè)用注解標(biāo)記的實(shí)體都@Version將由 JPA 跟蹤其版本。這是基本機(jī)制：

• 初始化： 當(dāng)實(shí)體第一次被持久化（保存到數(shù)據(jù)庫(kù)）時(shí)，版本字段（通常是整數(shù)或時(shí)間戳）被設(shè)置為其初始值，通常為零。
• 讀?。?/strong> 稍后獲取實(shí)體時(shí)，JPA 會(huì)從數(shù)據(jù)庫(kù)中檢索當(dāng)前版本。
• 更新： 在嘗試更新或刪除實(shí)體時(shí)，JPA 會(huì)根據(jù)實(shí)體的版本檢查數(shù)據(jù)庫(kù)中的當(dāng)前版本。如果它們匹配，則操作繼續(xù)，并且數(shù)據(jù)庫(kù)中的版本增加（用于更新）。
• 沖突： 如果版本不匹配，則表明另一個(gè)事務(wù)同時(shí)更新了實(shí)體，導(dǎo)致 JPA 拋出OptimisticLockException.

@Entity
public class Book {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String title;
    private String author;

    @Version
    private int version;
}

@Entity
public class Product {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String name;
    private double price;

    @Version
    private int version;

}

public interface ProductRepository extends JpaRepository<Product, Long> {

}

@Autowired
ProductRepository productRepository;

public Product getProduct(Long id) {
    return productRepository.findById(id).orElse(null);
}

public void updateProductName(Long id, String newName) {
    Product product = productRepository.findById(id).orElseThrow(() -> new RuntimeException("Product not found"));
    product.setName(newName);
    productRepository.save(product);
}

@Transactional
public void updateProductNameWithConflictHandling(Long id, String newName) {
    try {
        Product product = productRepository.findById(id).orElseThrow(() -> new RuntimeException("Product not found"));
        product.setName(newName);
        productRepository.save(product);
    } catch (OptimisticLockException e) {
//處理異常，重試或者通知用戶(hù)
    }
}

try {

} catch (OptimisticLockException e) {
    // 通知用戶(hù)
    throw new ResponseStatusException(HttpStatus.CONFLICT, "數(shù)據(jù)被另一個(gè)事務(wù)更改");
}

int maxRetries = 3;
for (int i = 0; i < maxRetries; i++) {
    try {
        //執(zhí)行更新
        break; //如果成功跳出循環(huán)
    } catch (OptimisticLockException e) {
        if (i == maxRetries - 1) {
            throw new ResponseStatusException(HttpStatus.CONFLICT, "正在重試");
        }
    }
}

try {
    // 執(zhí)行更新
} catch (OptimisticLockException e) {
    // 獲取最新的版本
    Product latestProduct = productRepository.findById(productId).orElseThrow();

// 合并更改。此步驟將根據(jù)您的應(yīng)用程序邏輯而有所不同。
// 例如，您可能決定合并不沖突的字段或應(yīng)用其他業(yè)務(wù)規(guī)則。
    // 保存最新的
    productRepository.save(latestProduct);
}