百度一下資料庫事務隔離,臟讀等,我想也是一堆。有些老學究扯一堆理論,有些通篇全是代碼,都讓人看的有種說不出蛋疼的感覺。本文用圖文並茂的方式,配上行雲流水般的代碼,非要擺清楚這個問題。本文代碼已提交至碼雲(點擊這裡下載)。 事務是現代關係型資料庫的核心之一。在多個事務併發操作資料庫(多線程、網路併發等 ...
百度一下資料庫事務隔離,臟讀等,我想也是一堆。有些老學究扯一堆理論,有些通篇全是代碼,都讓人看的有種說不出蛋疼的感覺。本文用圖文並茂的方式,配上行雲流水般的代碼,非要擺清楚這個問題。本文代碼已提交至碼雲(點擊這裡下載)。
事務是現代關係型資料庫的核心之一。在多個事務併發操作資料庫(多線程、網路併發等)的時候,如果沒有有效的避免機制,就會出現以下幾種問題:
第一類丟失更新(Lost Update)
在完全未隔離事務的情況下,兩個事務更新同一條數據資源,某一事務完成,另一事務異常終止,回滾造成第一個完成的更新也同時丟失 。這個問題現代關係型資料庫已經不會發生,就不在這裡占用篇幅,有興趣的可以自行百度。
臟讀(Dirty Read)
A事務執行過程中,B事務讀取了A事務的修改。但是由於某些原因,A事務可能沒有完成提交,發生RollBack了操作,則B事務所讀取的數據就會是不正確的。這個未提交數據就是臟讀(Dirty Read)。臟讀產生的流程如下:
可以用EF Core模擬此過程:
class TestReadUncommitted :TestBase { private AutoResetEvent _autoResetEvent; [Test] public void ReadUncommitted() { using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"初始用戶狀態:【{user.Status}】"); } _autoResetEvent = new AutoResetEvent(false); ThreadPool.QueueUserWorkItem(data =>{ Write(); //啟動線程寫 }); ThreadPool.QueueUserWorkItem(data =>{ Read(); //啟動線程讀 }); Thread.Sleep(5000); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"最終用戶狀態:【{user.Status}】"); } } private void Read() { _autoResetEvent.WaitOne(); var options = new TransactionOptions { IsolationLevel = IsolationLevel.ReadUncommitted }; using (var scope = new TransactionScope(TransactionScopeOption.Required, options)) { using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務B:臟讀到的用戶狀態:【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); //如果這時執行下麵的判斷 if (user.Status == 1) { Console.WriteLine("事務B:非正常數據,會產生意想不到的BUG"); } } } } private void Write() { using (var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions {IsolationLevel = IsolationLevel.ReadCommitted})) { Console.WriteLine($"事務A:修改--{DateTime.Now.ToString("HH:mm:ss fff")}"); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); user.Status = 1-user.Status; //模擬修改 context.SaveChanges(); } _autoResetEvent.Set(); //模擬多線程切換,這時切換到Read線程,復現臟讀 Thread.Sleep(2000); //模擬長事務 Console.WriteLine($"事務A:改完,但沒提交--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } }臟讀示例
對應的執行結果:
不可重覆讀(Nonrepeatable Read)
B事務讀取了兩次數據,在這兩次的讀取過程中A事務修改了數據,B事務的這兩次讀取出來的數據不一樣。B事務這種讀取的結果,即為不可重覆讀(Nonrepeatable Read)。不可重覆讀的產生的流程如下:
模擬代碼如下:
public class TestReadCommitted : TestBase { private AutoResetEvent _toWriteEvent = new AutoResetEvent(false); private AutoResetEvent _toReadEvent = new AutoResetEvent(false); [Test] public void ReadCommitted() { ThreadPool.QueueUserWorkItem(data => { Read(); //啟動線程讀 }); ThreadPool.QueueUserWorkItem(data => { Write(); //啟動線程寫 }); Thread.Sleep(5000); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"最終用戶狀態:【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } private void Read() { using (var transactionScope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted })) { using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務B:第一次讀取:【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } _toWriteEvent.Set(); //模擬多線程切換,這時切換到寫線程,復現不可重覆讀 _toReadEvent.WaitOne(); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務B:第二次讀取:【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } } private void Write() { _toWriteEvent.WaitOne(); using (var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted })) { User user = null; using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務A:讀取為【{user?.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); user.Status = 1 - user.Status; context.SaveChanges(); } scope.Complete(); Console.WriteLine($"事務A:已被更改為【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); _toReadEvent.Set(); } } }不可重覆讀示例
對應的執行結果:
不可重覆讀有一種特殊情況,兩個事務更新同一條數據資源,後完成的事務會造成先完成的事務更新丟失。這種情況就是大名鼎鼎的第二類丟失更新。主流的資料庫已經預設屏蔽了第一類丟失更新問題(即:後做的事務撤銷,發生回滾造成已完成事務的更新丟失),但我們編程的時候仍需要特別註意第二類丟失更新。它產生的流程如下:
模擬代碼如下:
public class TestReadCommitted2 : TestBase { private AutoResetEvent _toWriteEvent = new AutoResetEvent(false); private AutoResetEvent _toReadEvent = new AutoResetEvent(false); [Test] public void ReadCommitted() { ThreadPool.QueueUserWorkItem(data => { Read(); //啟動線程讀 }); ThreadPool.QueueUserWorkItem(data => { Write(); //啟動線程寫 }); Thread.Sleep(5000); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"最終用戶狀態:【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } private void Read() { using (var transactionScope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted })) { User user = null; using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務B:第一次讀取:【{user?.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } _toWriteEvent.Set(); //模擬多線程切換,這時切換到寫線程,復現不可重覆讀 _toReadEvent.WaitOne(); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務B:第二次讀取:【{user?.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); user.Status = 1 - user.Status; context.SaveChanges(); } transactionScope.Complete(); Console.WriteLine($"事務B:已被更改為【{user?.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } private void Write() { _toWriteEvent.WaitOne(); using (var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted })) { User user = null; using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務A:讀取為【{user?.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); user.Status = 1 - user.Status; context.SaveChanges(); } scope.Complete(); Console.WriteLine($"事務A:已被更改為【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); _toReadEvent.Set(); } } }第二類更新丟失示例
對應的執行結果如下圖:
可以明顯看出事務A的更新被事務B所覆蓋,更新丟失。
幻讀(Phantom Read)
B事務讀取了兩次數據,在這兩次的讀取過程中A事務添加了數據,B事務的這兩次讀取出來的集合不一樣。幻讀產生的流程如下:
這個流程看起來和不可重覆讀差不多,但幻讀強調的集合的增減,而不是單獨一條數據的修改。
模擬代碼如下:
public class TestRepeat : TestBase { private AutoResetEvent _toWriteEvent = new AutoResetEvent(false); private AutoResetEvent _toReadEvent = new AutoResetEvent(false); [Test] public void Repeat() { ThreadPool.QueueUserWorkItem(data => { Read(); //啟動線程讀 }); ThreadPool.QueueUserWorkItem(data => { Write(); //啟動線程寫 }); Thread.Sleep(6000); } private void Read() { using (var transactionScope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.RepeatableRead })) { using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { Console.WriteLine($"事務B:第一次讀取:【{context.Users.Count()}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } _toWriteEvent.Set(); //模擬多線程切換,這時切換到寫線程,復現幻讀 _toReadEvent.WaitOne(); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { Console.WriteLine($"事務B:第二次讀取:【{context.Users.Count()}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } } private void Write() { _toWriteEvent.WaitOne(); using (var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted })) { Console.WriteLine($"事務A:新增一條--{DateTime.Now.ToString("HH:mm:ss fff")}"); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var id = GenerateId.ShortStr(); context.Users.Add(new User { Id = id, Account = id, Status = 0, Name = id, CreateTime = DateTime.Now}); context.SaveChanges(); } scope.Complete(); Console.WriteLine($"事務A:完成新增--{DateTime.Now.ToString("HH:mm:ss fff")}"); _toReadEvent.Set(); } } }幻讀示例
執行結果:
資料庫隔離級別
為瞭解決上面提及的併發問題,主流關係型資料庫都會提供四種事務隔離級別。
讀未提交(Read Uncommitted)
在該隔離級別,所有事務都可以看到其他未提交事務的執行結果。本隔離級別是最低的隔離級別,雖然擁有超高的併發處理能力及很低的系統開銷,但很少用於實際應用。因為採用這種隔離級別隻能防止第一類更新丟失問題,不能解決臟讀,不可重覆讀及幻讀問題。
讀已提交(Read Committed)
這是大多數資料庫系統的預設隔離級別(但不是MySQL預設的)。它滿足了隔離的簡單定義:一個事務只能看見已經提交事務所做的改變。這種隔離級別可以防止臟讀問題,但會出現不可重覆讀及幻讀問題。
可重覆讀(Repeatable Read)
這是MySQL的預設事務隔離級別,它確保同一事務的多個實例在併發讀取數據時,會看到同樣的數據行。這種隔離級別可以防止除幻讀外的其他問題。
可串列化(Serializable)
這是最高的隔離級別,它通過強制事務排序,使之不可能相互衝突,從而解決幻讀、第二類更新丟失問題。在這個級別,可以解決上面提到的所有併發問題,但可能導致大量的超時現象和鎖競爭,通常資料庫不會用這個隔離級別,我們需要其他的機制來解決這些問題:樂觀鎖和悲觀鎖。
這四種隔離級別會產生的問題如下(網上到處都有,懶得畫了):
如何使用資料庫的隔離級別
很多文章博客在介紹完這些隔離級別以後,就沒有以後了。讀的人一般會覺得,嗯,是這麼回事,我知道了!
學習一個知識點,是需要實踐的。比如下麵這個常見而又異常嚴重的情況:
圖中是典型的第二類丟失更新問題,後果異常嚴重。我們這裡就以讀已提交(Read Committed)及以下隔離級別中會出現不可重覆讀現象為例。從上面的表格可以看出,當事務隔離級別為可重覆讀(Repeatable Read)時可以避免。把TestReadCommitted中的Read線程事務級別調整一下:
//////////////////////////////////////////////////////////////////////////////////////////////////// // file: Test\TestReadCommitted.cs // // summary: 讀已提交會出現“不可重覆讀”現象 // 把讀線程(事務B)的隔離級別調整到RepeatableRead,即可杜絕 //////////////////////////////////////////////////////////////////////////////////////////////////// using System; using System.Linq; using System.Threading; using System.Transactions; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection; using NUnit.Framework; using TestTransaction.Domain; namespace TestTransaction.Test { public class TestReadCommitted : TestBase { private AutoResetEvent _toWriteEvent = new AutoResetEvent(false); private AutoResetEvent _toReadEvent = new AutoResetEvent(false); [Test] public void ReadCommitted() { ThreadPool.QueueUserWorkItem(data => { Read(); //啟動線程讀 }); ThreadPool.QueueUserWorkItem(data => { Write(); //啟動線程寫 }); Thread.Sleep(60000); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"最終用戶狀態:【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } private void Read() { //讀線程(事務B)的隔離級別調整到RepeatableRead using (var transactionScope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.RepeatableRead, Timeout = TimeSpan.FromSeconds(40) })) { using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務B:第一次讀取:【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } _toWriteEvent.Set(); //模擬多線程切換,這時切換到寫線程,復現不可重覆讀 _toReadEvent.WaitOne(); using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { var user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務B:第二次讀取:【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } } private void Write() { _toWriteEvent.WaitOne(); using (var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted, Timeout = TimeSpan.FromSeconds(5) })) { User user = null; using (var context = _autofacServiceProvider.GetService<OpenAuthDBContext>()) { user = context.Users.SingleOrDefault(u => u.Account == "admin"); Console.WriteLine($"事務A:讀取為【{user?.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); user.Status = 1 - user.Status; try { context.SaveChanges(); scope.Complete(); Console.WriteLine($"事務A:已被更改為【{user.Status}】--{DateTime.Now.ToString("HH:mm:ss fff")}"); } catch (DbUpdateException e) { Console.WriteLine($"事務A:異常,為了保證可重覆讀,你的修改提交失敗,請稍後重試--{DateTime.Now.ToString("HH:mm:ss fff")}"); } } _toReadEvent.Set(); } } } }
這時執行效果如下:
實際項目中,通過提示客戶端重做的方式,完美解決了不可重覆讀的問題。其他併發問題,也可以通過類似的方式解決。
最後,文中提到可串列化解決幻讀的問題,會在下篇文章詳細介紹,包含各種酷炫的樂觀鎖操作,敬請期待!本文唯一訪問地址:https://www.cnblogs.com/yubaolee/p/10398633.html