天天看點

3 -【 Redis 】- 6 Redis 事務1 Redis 事務2 執行個體3 Redis 事務指令4 Redis 叢集事物5 SpringBoot 操作 Redis 事務

1 Redis 事務

Redis 事務可以一次執行多個指令, 并且帶有以下三個重要的保證:

  • 批量操作在發送 EXEC 指令前被放入隊列緩存。
  • 收到 EXEC 指令後進入事務執行,事務中任意指令執行失敗,其餘的指令依然被執行。
  • 在事務執行過程,其他用戶端送出的指令請求不會插入到事務執行指令序列中。

一個事務從開始到執行會經曆以下三個階段:

  • 開始事務。
  • 指令入隊。
  • 執行事務。

2 執行個體

以下是一個事務的例子, 它先以

MULTI

開始一個事務, 然後将多個指令入隊到事務中, 最後由

EXEC

指令觸發事務, 一并執行事務中的所有指令:

redis 127.0.0.1:6379> MULTI
OK

redis 127.0.0.1:6379> SET book-name "Mastering C++ in 21 days"
QUEUED

redis 127.0.0.1:6379> GET book-name
QUEUED

redis 127.0.0.1:6379> SADD tag "C++" "Programming" "Mastering Series"
QUEUED

redis 127.0.0.1:6379> SMEMBERS tag
QUEUED

redis 127.0.0.1:6379> EXEC
1) OK
2) "Mastering C++ in 21 days"
3) (integer) 3
4) 1) "Mastering Series"
   2) "C++"
   3) "Programming"
           

單個 Redis 指令的執行是原子性的,但 Redis 沒有在事務上增加任何維持原子性的機制,是以 Redis 事務的執行并不是原子性的。

事務可以了解為一個打包的批量執行腳本,但批量指令并非原子化的操作,中間某條指令的失敗不會導緻前面已做指令的復原,也不會造成後續的指令不做。

這是官網上的說明

From redis docs on transactions: It's important to note that even when a command fails, all the other commands in the queue are processed – Redis will not stop the processing of commands.

比如:

redis 127.0.0.1:7000> multi
OK
redis 127.0.0.1:7000> set a aaa
QUEUED
redis 127.0.0.1:7000> set b bbb
QUEUED
redis 127.0.0.1:7000> set c ccc
QUEUED
redis 127.0.0.1:7000> exec
1) OK
2) OK
3) OK
           

如果在 set b bbb 處失敗,set a 已成功不會復原,set c 還會繼續執行。

3 Redis 事務指令

  • DISCARD

    :取消事務,放棄執行事務塊内的所有指令。
  • EXEC

    :執行所有事務塊内的指令。
  • MULTI

    :标記一個事務塊的開始。
  • UNWATCH

    :取消 WATCH 指令對所有 key 的監視。
  • WATCH key [key ...]

    :監視一個(或多個) key ,如果在事務執行之前這個(或這些) key 被其他指令所改動,那麼事務将被打斷。

4 Redis 叢集事物

redis 叢集對象 JedisCluster 不支援事務,但是,叢集裡邊的每個節點支援事務。

5 SpringBoot 操作 Redis 事務

public void setString(String key, Object object) {
    stringRedisTemplate.setEnableTransactionSupport(true);
    // 開啟事務
    stringRedisTemplate.multi();
    try {
        // 如果是String 類型
        String value = (String) object;
        stringRedisTemplate.opsForValue().set(key, value);
	} catch (Exception e) {
		// 復原
		stringRedisTemplate.discard();
	} finally {
		// 送出
		stringRedisTemplate.exec();
	}
}