Redis事務
理論
Redis事務的概念:
Redis 事務的本質是一組命令的集合。事務支持一次執行多個命令,一個事務中所有命令都會被序列化。在事務執行過程,會按照順序串行化執行隊列中的命令,其他客戶端提交的命令請求不會插入到事務執行命令序列中。
總結說:redis事務就是一次性、順序性、排他性的執行一個隊列中的一系列命令。
Redis事務沒有隔離級別的概念:
批量操作在發送 EXEC 命令前被放入隊列緩存,并不會被實際執行!
Redis不保證原子性:
Redis中,單條命令是原子性執行的,但事務不保證原子性,且沒有回滾。事務中任意命令執行失敗,其余的命令仍會被執行。
Redis事務的三個階段:
- 開始事務
- 命令入隊
- 執行事務
Redis事務相關命令:
watch key1 key2 ... # 監視一或多個key,如果在事務執行之前,被監視的key被其他命令改動,則事務被打斷 ( 類似樂觀鎖 )
multi # 標記一個事務塊的開始( queued )
exec # 執行所有事務塊的命令 ( 一旦執行exec后,之前加的監控鎖都會被取消掉 )
discard # 取消事務,放棄事務塊中的所有命令
unwatch # 取消watch對所有key的監控
實踐
正常執行

放棄事務

若在事務隊列中存在命令性錯誤(類似于java編譯性錯誤),則執行EXEC命令時,所有命令都不會執行。

若在事務隊列中存在語法性錯誤(類似于java的1/0的運行時異常),則執行EXEC命令時,其他正確命令會被執行,錯誤命令拋出異常。

Watch 監控
悲觀鎖:
悲觀鎖(Pessimistic Lock),顧名思義,就是很悲觀,每次去拿數據的時候都認為別人會修改,所以每次在拿數據的時候都會上鎖,這樣別人想拿到這個數據就會block直到它拿到鎖。傳統的關系型數據庫里面就用到了很多這種鎖機制,比如行鎖,表鎖等,讀鎖,寫鎖等,都是在操作之前先上鎖。
樂觀鎖:
樂觀鎖(Optimistic Lock),顧名思義,就是很樂觀,每次去拿數據的時候都認為別人不會修改,所以不會上鎖。但是在更新的時候會判斷一下再此期間別人有沒有去更新這個數據,可以使用版本號等機制,樂觀鎖適用于多讀的應用類型,這樣可以提高吞吐量,樂觀鎖策略:提交版本必須大于記錄當前版本才能執行更新。
測試:
1、初始化信用卡可用余額和欠額
127.0.0.1:6379> set balance 100
OK
127.0.0.1:6379> set debt 0
OK
2、使用watch檢測balance,事務期間balance數據未變動,事務執行成功
127.0.0.1:6379> watch balance
OK
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> decrby balance 20
QUEUED
127.0.0.1:6379> incrby debt 20
QUEUED
127.0.0.1:6379> exec
1) (integer) 80
2) (integer) 20
3、使用watch檢測balance,事務期間balance數據變動,事務執行失敗!
# 窗口一
127.0.0.1:6379> watch balance
OK
127.0.0.1:6379> MULTI # 執行完畢后,執行窗口二代碼測試
OK
127.0.0.1:6379> decrby balance 20
QUEUED
127.0.0.1:6379> incrby debt 20
QUEUED
127.0.0.1:6379> exec # 修改失敗!
(nil)
# 窗口二
127.0.0.1:6379> get balance
"80"
127.0.0.1:6379> set balance 200
OK
# 窗口一:出現問題后放棄監視,然后重來!
127.0.0.1:6379> UNWATCH # 放棄監視
OK
127.0.0.1:6379> watch balance
OK
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> decrby balance 20
QUEUED
127.0.0.1:6379> incrby debt 20
QUEUED
127.0.0.1:6379> exec # 成功!
1) (integer) 180
2) (integer) 40
說明:
一但執行 EXEC 開啟事務的執行后,無論事務使用執行成功, WARCH 對變量的監控都將被取消。
故當事務執行失敗后,需重新執行WATCH命令對變量進行監控,并開啟新的事務進行操作。
總結:
watch指令類似于樂觀鎖,在事務提交時,如果watch監控的多個KEY中任何KEY的值已經被其他客戶端更改,則使用EXEC執行事務時,事務隊列將不會被執行,同時返回Nullmulti-bulk應答以通知調用者事務執行失敗。

浙公網安備 33010602011771號