Redis事務(wù)機(jī)制與Springboot項(xiàng)目中的使用方式
Redis 的事務(wù)機(jī)制允許將多個(gè)命令打包在一起，作為一個(gè)原子操作來(lái)執(zhí)行。雖然 Redis 的事務(wù)與關(guān)系型數(shù)據(jù)庫(kù)的事務(wù)有所不同，但它仍然提供了一種確保多個(gè)命令順序執(zhí)行的方式。
以下是 Redis 事務(wù)機(jī)制的詳細(xì)解析：
1. Redis 事務(wù)的基本概念
Redis 事務(wù)通過(guò)以下四個(gè)命令實(shí)現(xiàn)：
MULTI：開(kāi)啟一個(gè)事務(wù)。EXEC：執(zhí)行事務(wù)中的所有命令。DISCARD：取消事務(wù)，放棄所有已入隊(duì)的命令。WATCH：監(jiān)視一個(gè)或多個(gè)鍵，如果在事務(wù)執(zhí)行前這些鍵被修改，則事務(wù)不會(huì)執(zhí)行。
Redis 事務(wù)的核心思想是將多個(gè)命令放入一個(gè)隊(duì)列中，然后一次性、按順序執(zhí)行這些命令。
2. Redis 事務(wù)的工作流程
2.1 開(kāi)啟事務(wù)
使用 MULTI 命令開(kāi)啟一個(gè)事務(wù)。
開(kāi)啟事務(wù)后，所有后續(xù)的命令都會(huì)被放入一個(gè)隊(duì)列中，而不是立即執(zhí)行。
127.0.0.1:6379> MULTI OK
2.2 命令入隊(duì)
在事務(wù)開(kāi)啟后，所有命令都會(huì)被放入隊(duì)列中，等待執(zhí)行。
例如：
127.0.0.1:6379> SET key1 value1 QUEUED 127.0.0.1:6379> SET key2 value2 QUEUED
2.3 執(zhí)行事務(wù)
使用 EXEC 命令執(zhí)行事務(wù)中的所有命令。
Redis 會(huì)按順序執(zhí)行隊(duì)列中的命令，并返回每個(gè)命令的執(zhí)行結(jié)果。
127.0.0.1:6379> EXEC 1) OK 2) OK
2.4 取消事務(wù)
如果在事務(wù)執(zhí)行前需要取消事務(wù)，可以使用 DISCARD 命令。
這會(huì)清空事務(wù)隊(duì)列并退出事務(wù)。
127.0.0.1:6379> DISCARD OK
3. Redis 事務(wù)的特性
3.1 原子性
Redis 事務(wù)是原子的，這意味著事務(wù)中的所有命令要么全部執(zhí)行，要么全部不執(zhí)行。但是，Redis 事務(wù)不支持回滾（rollback）。如果在事務(wù)執(zhí)行過(guò)程中某個(gè)命令失敗，后續(xù)命令仍然會(huì)繼續(xù)執(zhí)行。
3.2 隔離性
Redis 事務(wù)是隔離的，事務(wù)中的命令在 EXEC 執(zhí)行之前不會(huì)被其他客戶端看到。其他客戶端只有在事務(wù)提交后（即 EXEC 執(zhí)行后）才能看到事務(wù)的結(jié)果。
3.3 無(wú)回滾機(jī)制
Redis 事務(wù)不支持回滾。如果在事務(wù)執(zhí)行過(guò)程中某個(gè)命令失?。ɡ缯Z(yǔ)法錯(cuò)誤），Redis 不會(huì)自動(dòng)回滾已經(jīng)執(zhí)行的命令。這與關(guān)系型數(shù)據(jù)庫(kù)的事務(wù)機(jī)制不同。
3.4 命令入隊(duì)
在事務(wù)開(kāi)啟后，所有命令都會(huì)被放入隊(duì)列中，而不是立即執(zhí)行。只有在 EXEC 命令被調(diào)用時(shí)，隊(duì)列中的命令才會(huì)被執(zhí)行。
4. WATCH 命令
WATCH 命令用于監(jiān)視一個(gè)或多個(gè)鍵。如果在事務(wù)執(zhí)行前這些鍵被其他客戶端修改，則事務(wù)不會(huì)執(zhí)行。
WATCH 提供了一種樂(lè)觀鎖機(jī)制，用于解決并發(fā)問(wèn)題。
4.1 使用 WATCH
127.0.0.1:6379> WATCH key1 OK 127.0.0.1:6379> MULTI OK 127.0.0.1:6379> SET key1 value1 QUEUED 127.0.0.1:6379> EXEC (nil) # 如果 key1 被其他客戶端修改，事務(wù)不會(huì)執(zhí)行
4.2 取消 WATCH
使用 UNWATCH 命令可以取消對(duì)所有鍵的監(jiān)視。
127.0.0.1:6379> UNWATCH OK
5. Redis 事務(wù)的局限性
5.1 不支持回滾
Redis 事務(wù)不支持回滾。如果在事務(wù)執(zhí)行過(guò)程中某個(gè)命令失敗，Redis 不會(huì)自動(dòng)回滾已經(jīng)執(zhí)行的命令。
5.2 命令錯(cuò)誤與運(yùn)行時(shí)錯(cuò)誤
- 命令錯(cuò)誤：如果事務(wù)中的某個(gè)命令存在語(yǔ)法錯(cuò)誤（例如命令不存在），則整個(gè)事務(wù)都不會(huì)執(zhí)行。
- 運(yùn)行時(shí)錯(cuò)誤：如果事務(wù)中的某個(gè)命令在執(zhí)行時(shí)出錯(cuò)（例如對(duì)字符串執(zhí)行
INCR操作），則只有該命令會(huì)失敗，其他命令仍然會(huì)執(zhí)行。
5.3 性能問(wèn)題
Redis 事務(wù)會(huì)將所有命令放入隊(duì)列中，直到 EXEC 執(zhí)行時(shí)才一次性執(zhí)行。如果事務(wù)中包含大量命令，可能會(huì)導(dǎo)致內(nèi)存占用過(guò)高。
6. Redis 事務(wù)的應(yīng)用場(chǎng)景
6.1 批量操作
當(dāng)需要一次性執(zhí)行多個(gè)命令時(shí)，可以使用事務(wù)來(lái)確保這些命令按順序執(zhí)行。
6.2 樂(lè)觀鎖
通過(guò) WATCH 命令可以實(shí)現(xiàn)樂(lè)觀鎖機(jī)制，確保在事務(wù)執(zhí)行前監(jiān)視的鍵沒(méi)有被修改。
6.3 原子性操作
雖然 Redis 事務(wù)不支持回滾，但它仍然可以確保多個(gè)命令的原子性執(zhí)行。
7. Redis 事務(wù)與 Lua 腳本的對(duì)比
Redis 事務(wù)和 Lua 腳本都可以用于實(shí)現(xiàn)原子性操作，但兩者有以下區(qū)別：
- 事務(wù)：適合簡(jiǎn)單的批量操作，但不支持復(fù)雜的邏輯。
- Lua 腳本：適合復(fù)雜的業(yè)務(wù)邏輯，支持條件判斷、循環(huán)等操作，且腳本在服務(wù)器端原子執(zhí)行。
8. Redis 事務(wù)的示例
以下是一個(gè)完整的 Redis 事務(wù)示例：
# 監(jiān)視 key1 127.0.0.1:6379> WATCH key1 OK # 開(kāi)啟事務(wù) 127.0.0.1:6379> MULTI OK # 命令入隊(duì) 127.0.0.1:6379> SET key1 value1 QUEUED 127.0.0.1:6379> SET key2 value2 QUEUED # 提交事務(wù) 127.0.0.1:6379> EXEC 1) OK 2) OK
在 Spring Boot 中使用 Redis 事務(wù)機(jī)制時(shí)，可以通過(guò) RedisTemplate 或 StringRedisTemplate 來(lái)操作 Redis 事務(wù)。
Spring Data Redis 提供了對(duì) Redis 事務(wù)的支持，允許你在 Spring 應(yīng)用中方便地使用 Redis 事務(wù)。
9. 在 Spring Boot 中使用 Redis 事務(wù)
9.1 配置 RedisTemplate
首先，確保在 Spring Boot 項(xiàng)目中配置了 RedisTemplate 或 StringRedisTemplate。
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<String, Object> template = new RedisTemplate<>();
template.setConnectionFactory(redisConnectionFactory);
template.setKeySerializer(new StringRedisSerializer());
template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
return template;
}
}9.2 使用 Redis 事務(wù)
在 Spring Boot 中，可以通過(guò) RedisTemplate 的 execute 方法來(lái)執(zhí)行事務(wù)操作。execute 方法接受一個(gè) SessionCallback 或 RedisCallback 參數(shù)，用于在事務(wù)中執(zhí)行多個(gè)命令。
@Service
public class RedisTransactionService {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
public void executeTransaction() {
redisTemplate.execute(new SessionCallback<Object>() {
@Override
public Object execute(RedisOperations operations) throws DataAccessException {
// 開(kāi)啟事務(wù)
operations.multi();
// 執(zhí)行多個(gè)命令
operations.opsForValue().set("key1", "value1");
operations.opsForValue().set("key2", "value2");
// 提交事務(wù)
return operations.exec();
}
});
}
}9.3 使用 WATCH 命令
WATCH 命令用于監(jiān)視一個(gè)或多個(gè)鍵，如果在事務(wù)執(zhí)行前這些鍵被修改，則事務(wù)不會(huì)執(zhí)行?？梢酝ㄟ^(guò) RedisTemplate 的 watch 方法來(lái)實(shí)現(xiàn)。
@Service
public class RedisTransactionService {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
public void executeTransactionWithWatch() {
redisTemplate.execute(new SessionCallback<Object>() {
@Override
public Object execute(RedisOperations operations) throws DataAccessException {
// 監(jiān)視 key1
operations.watch("key1");
// 開(kāi)啟事務(wù)
operations.multi();
// 執(zhí)行多個(gè)命令
operations.opsForValue().set("key1", "value1");
operations.opsForValue().set("key2", "value2");
// 提交事務(wù)
return operations.exec();
}
});
}
}9.4. 事務(wù)的異常處理
在 Redis 事務(wù)中，如果某個(gè)命令執(zhí)行失敗，事務(wù)不會(huì)回滾，而是繼續(xù)執(zhí)行后續(xù)命令。因此，需要在代碼中處理可能的異常情況。
@Service
public class RedisTransactionService {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
public void executeTransactionWithExceptionHandling() {
redisTemplate.execute(new SessionCallback<Object>() {
@Override
public Object execute(RedisOperations operations) throws DataAccessException {
try {
// 開(kāi)啟事務(wù)
operations.multi();
// 執(zhí)行多個(gè)命令
operations.opsForValue().set("key1", "value1");
operations.opsForValue().set("key2", "value2");
// 提交事務(wù)
return operations.exec();
} catch (Exception e) {
// 處理異常
operations.discard();
throw e;
}
}
});
}
}9.5. 使用注解驅(qū)動(dòng)的事務(wù)管理
Spring Data Redis 支持通過(guò) @Transactional 注解來(lái)管理 Redis 事務(wù)。需要在配置類(lèi)中啟用事務(wù)管理。
@Configuration
@EnableTransactionManagement
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<String, Object> template = new RedisTemplate<>();
template.setConnectionFactory(redisConnectionFactory);
template.setKeySerializer(new StringRedisSerializer());
template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
template.setEnableTransactionSupport(true); // 啟用事務(wù)支持
return template;
}
@Bean
public PlatformTransactionManager transactionManager(RedisConnectionFactory redisConnectionFactory) {
return new DataSourceTransactionManager();
}
}然后在 Service 類(lèi)中使用 @Transactional 注解來(lái)標(biāo)記事務(wù)方法。
@Service
public class RedisTransactionService {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@Transactional
public void executeTransactionWithAnnotation() {
redisTemplate.opsForValue().set("key1", "value1");
redisTemplate.opsForValue().set("key2", "value2");
}
}總結(jié)
在 Spring Boot 中使用 Redis 事務(wù)機(jī)制時(shí)，可以通過(guò) RedisTemplate 的 execute 方法手動(dòng)管理事務(wù)，也可以通過(guò) @Transactional 注解實(shí)現(xiàn)聲明式事務(wù)管理。
使用 WATCH 命令可以確保事務(wù)的原子性，避免競(jìng)態(tài)條件。在實(shí)際應(yīng)用中，需要根據(jù)業(yè)務(wù)需求選擇合適的事務(wù)管理方式，并注意異常處理和性能優(yōu)化。
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
淺談redis的過(guò)期時(shí)間設(shè)置和過(guò)期刪除機(jī)制
本文主要介紹了redis的過(guò)期時(shí)間設(shè)置和過(guò)期刪除機(jī)制，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-03-03
Redis為了保證服務(wù)高可用，其中一種實(shí)現(xiàn)就是主從模式，本篇文章將對(duì)主從模式中為了保證主節(jié)點(diǎn)和從節(jié)點(diǎn)數(shù)據(jù)一致而實(shí)現(xiàn)的主從同步機(jī)制進(jìn)行學(xué)習(xí)，感興趣的同學(xué)可以參考閱讀下2023-07-07
RedisInsight是Redis官方提供的圖形化客戶端工具,下載步驟包括訪問(wèn)Redis官網(wǎng)、選擇RedisInsight、下載鏈接、注冊(cè)信息、安裝并測(cè)試連接2025-03-03
Redis數(shù)據(jù)一致性問(wèn)題的三種解決方案
Redis（Remote?Dictionary?Server?),是一個(gè)高性能的基于Key-Value結(jié)構(gòu)存儲(chǔ)的NoSQL開(kāi)源數(shù)據(jù)庫(kù),大部分公司采用Redis來(lái)實(shí)現(xiàn)分布式緩存,用來(lái)提高數(shù)據(jù)查詢效率,本文就給大家介紹三種Redis數(shù)據(jù)一致性問(wèn)題的解決方案,需要的朋友可以參考下2023-07-07
緩存穿透是指查詢一個(gè)根本不存在的數(shù)據(jù),由于緩存不命中,請(qǐng)求會(huì)穿透緩存層直接訪問(wèn)數(shù)據(jù)庫(kù),本文整理了6個(gè)Redis預(yù)防緩存穿透的方法,希望對(duì)大家有一定的幫助2025-04-04
Redis的哈希Hash類(lèi)型常用命令的使用小結(jié)
Redis哈希類(lèi)型類(lèi)似于一個(gè)鍵值對(duì)集合,通常用于存儲(chǔ)對(duì)象,每個(gè)哈希包含多個(gè)字段,每個(gè)字段都有一個(gè)值,哈希類(lèi)型支持一系列常用命令,下面就來(lái)詳細(xì)的介紹一下這些命令的使用,感興趣的可以了解一下2025-08-08
詳解redis desktop manager安裝及連接方式
這篇文章主要介紹了redis desktop manager安裝及連接方式，本文圖文并茂給大家介紹的非常詳細(xì)，具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2019-09-09
redis keys與scan命令的區(qū)別說(shuō)明
這篇文章主要介紹了redis keys與scan命令的區(qū)別說(shuō)明，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-03-03
Redis是一個(gè)開(kāi)源的（BSD協(xié)議），內(nèi)存中的數(shù)據(jù)結(jié)構(gòu)存儲(chǔ)，它可以用作數(shù)據(jù)庫(kù)，緩存，消息代理。這篇文章主要介紹了Redis不僅僅是緩存，還是……,需要的朋友可以參考下2020-12-12
這篇文章主要介紹了Redis:Redisson分布式鎖的使用方式(推薦使用),具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-04-04