<!-- Spring Boot 整合 Redis（默認(rèn)內(nèi)置 Lettuce） -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

<!-- Redisson 核心依賴（適配 Spring Boot） -->
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.23.0</version> <!-- 選穩(wěn)定版本 -->
</dependency>

redis.lettuce.client.enable=true # 啟用Lettuce客戶端
# 連接池配置（核心）
redis.lettuce.client.pool.minIdle=6 # 最小空閑連接（?；睿?
redis.lettuce.client.pool.maxIdle=21 # 最大空閑連接
redis.lettuce.client.pool.maxTotal=100 # 最大連接數(shù)
redis.lettuce.client.pool.maxWaitMillis=4000 # 最大等待時(shí)間
redis.lettuce.client.sentinel.mastername=master # 監(jiān)控的主節(jié)點(diǎn)名稱
redis.lettuce.client.sentinel.password=***
redis.lettuce.client.sentinel.database=0
redis.lettuce.client.sentinel.nodeInfo[0]=10.193.114.0:26379 # 哨兵節(jié)點(diǎn)列表
redis.lettuce.client.sentinel.nodeInfo[0]=10.193.114.2:26379 # 哨兵節(jié)點(diǎn)列表
redis.lettuce.client.sentinel.nodeInfo[0]=10.193.114.3:26379 # 哨兵節(jié)點(diǎn)列表

@Component
public class CacheService {
    // 注入 Spring 封裝的 RedisTemplate（底層是 Lettuce）
    @Resource
    private RedisTemplate<String, Object> redisTemplate;

    // 存儲(chǔ)合約基礎(chǔ)信息（String 類型）
    public void setTestInfo(String testKey, Object testInfo) {
        // 底層通過 Lettuce 發(fā)送 SET 命令到 Redis 哨兵集群
        redisTemplate.opsForValue().set(
            testKey, 
            testInfo, 
            1, // 過期時(shí)間 1 小時(shí)
            TimeUnit.HOURS
        );
    }

    public Object getTestInfo(String testKey) {
        // 底層通過 Lettuce 發(fā)送 GET 命令
        return redisTemplate.opsForValue().get(testKey);
    }

    // 異步操作（Lettuce 核心優(yōu)勢(shì)，高并發(fā)場(chǎng)景用）
    public void setTestInfoAsync(String testKey, Object testInfo) {
        // 異步設(shè)置，不阻塞主線程（高并發(fā)場(chǎng)景推薦）
        redisTemplate.opsForValue().setAsync(testKey, testInfo);
    }
}

@Component
public class TestMapService {
    // 注入 RedissonClient（底層復(fù)用 Lettuce 連接）
    @Resource
    private RedissonClient redissonClient;

    // 批量存儲(chǔ)合約信息到分布式 Map
    public void batchSaveTestInfo(List<TestInfoPO> testList) {
        // 獲取 Redis 中的分布式 Map（INFO:TEST_KEY）
        RMap<String, TestInfoPO> testMap = 
            redissonClient.getMap("INFO:TEST_KEY");
        
        // 批量存入：INFO:TEST_KEY
        testList.forEach(d -> {
            String key = ...
            testMap.put(key, d); // 原子操作，線程安全
        });
    }

    // 獲取單個(gè)test信息
    public TestInfoPO getTestInfo(String testId) {
        RMap<String, TestInfoPO> testMap = redissonClient.getMap("INFO:TEST_KEY");
        String key = ...;
        return testMap.get(key);
    }
}

@Component
public class UpdateService {
    @Resource
    private RedissonClient redissonClient;

    // 修改（加分布式鎖）
    public void updateTestInfo(String testtId, TestInfoPO newInfo) {
        // 1. 定義鎖的唯一標(biāo)識(shí)
        String lockKey = "lock:test:update:" + testId;
        RLock lock = redissonClient.getLock(lockKey);

        try {
            // 2. 獲取鎖：最多等5秒，持有鎖10秒（自動(dòng)釋放，防止死鎖）
            boolean locked = lock.tryLock(5, 10, TimeUnit.SECONDS);
            if (!locked) {
                throw new RuntimeException("正在修改中，請(qǐng)稍后重試");
            }

            // 3. 執(zhí)行業(yè)務(wù)邏輯
            // ... 你的更新數(shù)據(jù)庫(kù)/緩存邏輯 ...

        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new RuntimeException("獲取鎖失敗", e);
        } finally {
            // 4. 釋放鎖（必須在 finally 中，防止鎖泄露）
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }
    }
}

@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);
        // 設(shè)置 JSON 序列化器
        Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
        template.setValueSerializer(serializer);
        template.setKeySerializer(new StringRedisSerializer());
        template.afterPropertiesSet();
        return template;
    }
}