Hibernate 4 的并發控制 · JavaBeginnersTutorial 中文系列教程

# Hibernate 4 的并發控制 > 原文： [https://javabeginnerstutorial.com/hibernate/concurrency-control-with-hibernate-4/](https://javabeginnerstutorial.com/hibernate/concurrency-control-with-hibernate-4/) 在大多數情況下，僅讓數據庫執行并發控制工作是可以的，但是有時您會遇到需要接管的應用。在本文中，我將簡要介紹**樂觀**和**悲觀**并發控制。 ## 樂觀并發控制高并發應用中唯一一致的方法是帶有版本控制的樂觀并發控制。此方法使用版本號或時間戳來檢測沖突并防止更新丟失。 ### 應用版本檢查使用這種方法，應用必須手動維護實體的版本。這意味著開發人員有責任在操作它們之前從數據庫加載實際的實體狀態。當對象被 Hibernate 刷新時，版本會自動增加-因此開發人員不需要增加此屬性。如果您的應用具有低并發性并跳過版本控制，則可以使用此方法。在這種情況下，總是最后一次提交獲勝，并且根據該狀態更新對象。這就是為什么**總是**需要在操作數據庫之前先從數據庫中加載實體的實際狀態。 ### 自動版本控制要使用自動版本控制，只需在您希望在樂觀鎖定的版本控制下擁有的實體中添加一個字段或方法，然后使用 [[受電子郵件保護]](/cdn-cgi/l/email-protection) 注解對其進行注解。如文檔所述，此注解可用于以下類型：`int`，`Integer`，`short`，`Short`，`long`，`Long`，`java.sql.Timestamp`。如果在加載實體和將其刷新回數據庫之間發生一些更新，則會從 Hibernate 收到一條錯誤消息：線程“主”中的異常`org.hibernate.StaleObjectStateException`：行已由另一個事務更新或刪除（或未保存值的映射不正確）：`[hibernate_example.joined.Book#1]` ## 悲觀并發控制正如我上次已經提到的那樣，Hibernate 不會鎖定內存中的對象，它將始終使用基礎數據庫的鎖定機制。但是， `LockMode`類定義了一些可由 Hibernate 獲得的機制： * `WRITE`：在 Hibernate 更新或插入行時自動獲取 * `UPGRADE`：可以在明確的用戶請求下使用`SELECT…FOR UPDATE`在支持此語法的數據庫上獲取 * `UPGRADE_NOWAIT`：可在 Oracle 下使用`SELECT…FOR UPDATE NOWAIT`根據明確的用戶請求獲取 * `READ`：Hibernate 讀取數據時自動獲取 * `NONE`：表示沒有鎖，在事務結束時所有對象都切換到此鎖模式 * `PESSIMISTIC_FORCE_INCREMENT`：加載實體時強制增加版本。上面提到的“顯式用戶請求”可以表示為以下調用之一： * 為`LockOptions`參數指定`LockMode`的`load()` * `buildLockRequest()` * `setLockMode()` ## 設置鎖定模式的示例上面我已經提到了一些鎖定模式以及如何設置它們，現在是時候看看一些示例代碼來了解它們的作用了。 ```java getBooks(session).stream().forEach(b -> session.load(Book.class, b.getId(), new LockOptions(LockMode.PESSIMISTIC_FORCE_INCREMENT))); getBooks(session).stream().forEach(System.out::println); ``` 上面的代碼塊有兩件事：從數據庫加載實體，設置一種用于強制版本增加的鎖定模式，然后將書籍打印到控制臺。結果將如下所示： ```java Java 8 in Action by Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft (ISBN: 9781617291999), published 2015.07.29\. 0:00 [1] Java 8 in Action by Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft (ISBN: 9781617291999), published 2015.07.29\. 0:00 [1] Java 8 in Action by Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft (ISBN: 9781617291999), published 2015.07.29\. 0:00 [1] Java 8 in Action by Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft (ISBN: 9781617291999), published 2015.07.29\. 16:14 [1] ``` 每行末尾的方括號包含實體的版本號。如果我們想將鎖定移動到`getBooks()`方法中，可以執行以下操作： ```java private static List<Book> getBooks(Session session) { ?? final Query query = session.createQuery("from Book b"); ?? query.setLockMode("b", LockMode.PESSIMISTIC_FORCE_INCREMENT); ?? return query.list(); } ``` 有趣的是`setLockMode`方法的第一個字符串參數：它是實體使用此鎖定的別名，您必須在查詢的`FROM`塊中使用此別名。使用此倉庫方法加載書籍后，將書籍打印到控制臺的結果可能是這樣的： ```java Java 8 in Action by Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft (ISBN: 9781617291999), published 2015.07.29\. 0:00 [1] Java 8 in Action by Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft (ISBN: 9781617291999), published 2015.07.29\. 0:00 [1] Java 8 in Action by Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft (ISBN: 9781617291999), published 2015.07.29\. 0:00 [1] Java 8 in Action by Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft (ISBN: 9781617291999), published 2015.07.29\. 16:15 [1] ``` ### 一個有趣的事實版本號僅在當前會話中更新，直到您更新實體并將其保存到數據庫為止。如果不這樣做，您會在應用中看到版本增量，但是它們不會保存到數據庫中，即使您使用某些`*_FORCE_INCREMENT`策略。 ```java | 1 |?? Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft | 9781617291999 | 2015-07-29 | Java 8 in Action | 0 | | 2 | Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft | 9781617291999 |?? 2015-07-29 | Java 8 in Action | 0 | | 3 | Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft | 9781617291999 |?? 2015-07-29 | Java 8 in Action | 0 | | 4 | Raoul-Gabriel Urma, Mario Fusco, Alan Mycroft | 9781617291999 |?? 2015-07-29 | Java 8 in Action | 0 | ``` 如果我們不更新舊條目，則上面的塊顯示了數據庫中的實體。這些列從左到右如下：ID，作者，ISBN，出版，標題和版本。要進行一些版本更改，請取消注釋示例中的代碼塊，然后運行應用。該塊將書籍的日期更新為當前日期，并將實體保存回數據庫中。為此，您需要進行事務。要開始事務，只需調用`session.beginTransaction();`，如果完成調用`session.getTransaction().commite()`，完成并寫入數據庫或`session.getTransaction().rollback()`以還原此事務中所做的所有更改。或者，您可以存儲由`beginTransaction()`方法返回的*事務*對象，并在此*事務*實例上調用`commit()`或`rollback()`。 ## 一些事務方式如果我提到了事務，請允許我給您一些模式（甚至是反模式），以了解通常如何處理事務。 ### 每個操作的會話（反模式）這是一種反模式，因為如果使用此事務管理方法，則將為每個數據庫調用打開和關閉會話。即使您使用數據庫的*自動提交*功能（在每次調用數據庫后隱式調用*提交*），此操作也會完成。 ### 每個請求的會話這是用于事務的最常見模式。名稱中的**請求**與其中有來自客戶端/用戶（例如 Web 應用）的許多請求的系統有關。常見的工作流程是，當此類請求到達系統時，將打開 Hibernate *會話*，并保持打開狀態，直到處理該請求的信息（更新存儲的信息或檢索要顯示的內容）為止。如果使用此模式，則在大多數情況下可以減少數據丟失，因為信息會連續保存在數據庫中。 ### 每個應用的會話開發人員不同意這是模式還是反模式，因為有時應用很小，您確實可以打開一個事務并在最后調用`commit`。但是，對于大型應用而言，這是一種太糟糕的方法，在大型應用中，最終的應用故障會導致數據丟失，或者如果存在并發用戶并且數據相關，則這些用戶之間將無法處于同步狀態。 ## 總結鎖定可能會有些麻煩，但是 Hibernate 會通過各種鎖定機制為我們提供幫助和幫助。如果您想微調內置解決方案，也可以使用上述方法進行。我們稍微深入研究事務，只是為了了解如何通常使用設計模式進行處理，以了解如何將數據存儲在數據庫中并保留這些信息。您可以[從此處下載代碼](https://github.com/JBTAdmin/Hibernate)。