快捷導(dǎo)航

SpringBoot使用Redis同時執(zhí)行多條命令的實現(xiàn)方法

更新時間：2025年09月22日 09:56:58 作者：IT橘子皮

在 Spring Boot 項目中高效、合理地使用 Redis 同時執(zhí)行多條命令,可以顯著提升應(yīng)用性能,下面我將為你介紹幾種主要方式、它們的典型應(yīng)用場景,以及如何在 Spring Boot 中實現(xiàn),需要的朋友可以參考下

方式	原子性	主要優(yōu)勢	Spring Boot 中的典型應(yīng)用場景
?Pipeline (管道)??	否	大幅提升批量操作效率，減少網(wǎng)絡(luò)往返次數(shù)	緩存預(yù)熱、批量數(shù)據(jù)導(dǎo)入導(dǎo)出、無依賴關(guān)系的批量查詢
?事務(wù) (Transaction)??	部分	命令隊列化，保證連續(xù)執(zhí)行（但不支持回滾）	簡單的原子操作序列，如庫存扣減、更新多個相關(guān)鍵
?Lua 腳本?	是	復(fù)雜邏輯原子執(zhí)行，避免中間狀態(tài)，性能高	分布式鎖、秒殺、需要原子性的復(fù)雜業(yè)務(wù)邏輯

1. Pipeline (管道)

Pipeline 允許客戶端將多個命令打包后一次性發(fā)送給 Redis 服務(wù)器，服務(wù)器依次執(zhí)行后再次將所有結(jié)果一次性返回給客戶端。這能顯著減少網(wǎng)絡(luò)往返次數(shù)（RTT）?，從而大幅提升吞吐量，尤其在高延遲網(wǎng)絡(luò)環(huán)境下效果明顯。

?Spring Boot 實現(xiàn)示例：??

import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class RedisPipelineService {

    private final StringRedisTemplate stringRedisTemplate;

    // 構(gòu)造器注入
    public RedisPipelineService(StringRedisTemplate stringRedisTemplate) {
        this.stringRedisTemplate = stringRedisTemplate;
    }

    public void batchSetKeys(List<String> keys, List<String> values) {
        // 使用 executePipelined 方法執(zhí)行管道操作
        List<Object> results = stringRedisTemplate.executePipelined((RedisCallback<Object>) connection -> {
            for (int i = 0; i < keys.size(); i++) {
                connection.set(keys.get(i).getBytes(), values.get(i).getBytes());
            }
            return null; // 回調(diào)中返回 null
        });
        // results 包含每個命令的執(zhí)行結(jié)果
    }
}

?使用場景：??

?緩存預(yù)熱?：應(yīng)用啟動時批量加載熱點數(shù)據(jù)到 Redis。
?批量數(shù)據(jù)導(dǎo)入/導(dǎo)出?：例如從數(shù)據(jù)庫批量導(dǎo)入數(shù)據(jù)到 Redis，或從 Redis 批量獲取數(shù)據(jù)進(jìn)行處理。
?批量查詢無關(guān)聯(lián)數(shù)據(jù)?：一次性獲取多個不相關(guān)鍵的值，減少網(wǎng)絡(luò)開銷。

?注意事項：??

Pipeline 中的命令不具備原子性。
建議單次 Pipeline 命令數(shù)控制在合理范圍內(nèi)（如幾千條），避免服務(wù)器內(nèi)存壓力或客戶端長時間阻塞。
?錯誤處理?：某個命令失敗不會影響 Pipeline 中其他命令的執(zhí)行，需要在客戶端解析結(jié)果列表時逐一檢查。

2. 事務(wù) (Transaction)

Redis 事務(wù)通過 MULTI, EXEC, DISCARD, WATCH等命令實現(xiàn)。它允許將多個命令放入一個隊列，然后通過 EXEC命令原子性地順序執(zhí)行這些命令。

?Spring Boot 實現(xiàn)示例：??

Spring Data Redis 提供了 SessionCallback接口來支持在同一個連接中執(zhí)行多個操作，這對于事務(wù)至關(guān)重要。

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.SessionCallback;
import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class RedisTransactionService {

    private final RedisTemplate<String, Object> redisTemplate;

    public RedisTransactionService(RedisTemplate<String, Object> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    public List<Object> executeInTransaction() {
        // 使用 execute 方法并傳遞 SessionCallback 來執(zhí)行事務(wù)
        SessionCallback<List<Object>> sessionCallback = new SessionCallback<>() {
            @Override
            public List<Object> execute(org.springframework.data.redis.core.RedisOperations operations) {
                operations.multi(); // 開啟事務(wù)
                operations.opsForValue().set("key1", "value1");
                operations.opsForValue().increment("counter");
                operations.opsForSet().add("setKey", "member1");
                return operations.exec(); // 執(zhí)行事務(wù)并返回結(jié)果
            }
        };
        return redisTemplate.execute(sessionCallback);
    }
}

?使用場景：??

?簡單的原子操作序列?：需要確保一系列命令連續(xù)執(zhí)行，不被其他命令打斷，但不要求所有命令必須全部成功?（例如，扣減庫存后增加銷量）。
?結(jié)合 WATCH實現(xiàn)樂觀鎖?：監(jiān)控特定鍵，如秒殺場景中監(jiān)控庫存鍵，防止超賣。

// 結(jié)合 WATCH 的樂觀鎖示例
public boolean watchAndExecute(String key, String expectedValue, String newValue) {
    return redisTemplate.execute(new SessionCallback<Boolean>() {
        @Override
        public Boolean execute(RedisOperations operations) {
            operations.watch(key); // 監(jiān)視 key
            String currentValue = (String) operations.opsForValue().get(key);
            if (expectedValue.equals(currentValue)) {
                operations.multi();
                operations.opsForValue().set(key, newValue);
                List<Object> execResult = operations.exec(); // 如果 execResult 為空，表示事務(wù)執(zhí)行失敗（鍵被修改）
                return execResult != null && !execResult.isEmpty();
            }
            operations.unwatch();
            return false;
        }
    });
}

?注意事項：??

Redis 事務(wù)不支持回滾 (Rollback)?。如果在執(zhí)行過程中某個命令失敗，已執(zhí)行的命令不會回滾，后續(xù)命令仍會繼續(xù)執(zhí)行。
?錯誤類型?：
- ?入隊錯誤?（如命令語法錯誤）：在執(zhí)行 EXEC前，Redis 可能會檢查出錯誤并放棄整個事務(wù)。
- ?運行時錯誤?（如數(shù)據(jù)類型操作錯誤）：在 EXEC后執(zhí)行中發(fā)生的錯誤，Redis 會記錄錯誤信息但不會中斷事務(wù)執(zhí)行。

3. Lua 腳本

Redis 支持執(zhí)行 ?Lua 腳本。腳本中的所有命令會作為一個整體原子性地執(zhí)行，期間不會被其他命令打斷，是原子性最強的方案，同時還能減少網(wǎng)絡(luò)往返。

?Spring Boot 實現(xiàn)示例：??

RedisTemplate提供了 execute方法用于執(zhí)行 Lua 腳本。

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Service;
import java.util.Arrays;

@Service
public class RedisLuaService {

    private final RedisTemplate<String, Object> redisTemplate;

    public RedisLuaService(RedisTemplate<String, Object> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    public String useLuaScript() {
        // 定義 Lua 腳本字符串
        String luaScript = """
                local key1 = KEYS[1]
                local value1 = ARGV[1]
                redis.call('set', key1, value1)
                local value = redis.call('get', key1)
                redis.call('incr', 'counter')
                return value
                """;
        
        DefaultRedisScript<String> script = new DefaultRedisScript<>();
        script.setScriptText(luaScript);
        script.setResultType(String.class); // 設(shè)置返回值類型

        // 執(zhí)行腳本，傳入 keys 和 args 數(shù)組
        String result = redisTemplate.execute(script, Arrays.asList("myKey"), "myValue");
        return result; // 返回腳本執(zhí)行結(jié)果
    }
}

?使用場景：??

?釋放分布式鎖?：確保判斷鎖標(biāo)識和刪除鎖是一個原子操作。

-- KEYS[1] 是鎖的key，ARGV[1]是當(dāng)前持有者的標(biāo)識
if redis.call("get", KEYS[1]) == ARGV[1] then
    return redis.call("del", KEYS[1])
else
    return 0
end

?秒殺/搶購?：判斷庫存和扣減庫存需要原子性。

?復(fù)雜業(yè)務(wù)邏輯?：需要多個命令的中間結(jié)果進(jìn)行邏輯判斷。

?注意事項：??

?腳本應(yīng)盡量簡單快速?：執(zhí)行 Lua 腳本會阻塞 Redis，長時間運行的腳本會影響性能。
?注意腳本的復(fù)用?：Redis 會緩存編譯過的腳本，可以使用 EVALSHA通過腳本摘要來執(zhí)行，減少帶寬。DefaultRedisScript對象通常會被配置為單例，Spring 會智能地處理 EVAL和 EVALSHA。