在Java中更新Redis键值并保留其TTL的实现策略

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.params.SetParams;

public class RedisKeyUpdater {

    private static JedisPool jedisPool; // 假设JedisPool已正确初始化

    /**
     * 初始化Jedis连接池。在实际应用中，JedisPool通常作为单例或通过依赖注入管理。
     * @param host Redis服务器地址
     * @param port Redis服务器端口
     */
    public static void initializeJedisPool(String host, int port) {
        if (jedisPool == null) {
            jedisPool = new JedisPool(host, port);
            System.out.println("JedisPool initialized for " + host + ":" + port);
        }
    }

    /**
     * 更新指定键的值，并保留其原有的TTL。
     * 如果键不存在，则创建新键且无TTL。
     *
     * @param key 要更新的键
     * @param newValue 要设置的新值
     */
    public static void updateKeyValueKeepTTL(String key, String newValue) {
        if (jedisPool == null) {
            System.err.println("JedisPool has not been initialized. Please call initializeJedisPool() first.");
            return;
        }
        try (Jedis redisClient = jedisPool.getResource()) {
            // 使用SetParams.keepTtl()来指示Redis保留键的TTL
            redisClient.set(key, newValue, new SetParams().keepTtl());
            System.out.println("键 '" + key + "' 已成功更新，TTL已保留。");
        } catch (Exception e) {
            System.err.println("更新键 '" + key + "' 失败: " + e.getMessage());
            // 在生产环境中应进行更详细的异常处理和日志记录
        }
    }

    public static void main(String[] args) {
        // 1. 初始化JedisPool
        initializeJedisPool("localhost", 6379); // 假设Redis运行在本地默认端口

        String testKey = "user:session:123";
        String initialValue = "{\"userId\":1, \"status\":\"active\"}";
        String updatedValue = "{\"userId\":1, \"status\":\"updated\"}";

        try (Jedis jedis = jedisPool.getResource()) {
            // 2. 设置一个带TTL的初始键值
            long initialTTLSeconds = 60; // 60秒TTL
            jedis.setex(testKey, initialTTLSeconds, initialValue);
            System.out.println("初始设置键 '" + testKey + "': " + jedis.get(testKey) + ", 剩余TTL: " + jedis.ttl(testKey) + "秒");

            // 3. 稍等片刻，模拟时间流逝
            Thread.sleep(5000); // 等待5秒
            System.out.println("等待5秒后，键 '" + testKey + "' 的剩余TTL: " + jedis.ttl(testKey) + "秒");

            // 4. 更新键值并保留TTL
            updateKeyValueKeepTTL(testKey, updatedValue);
            System.out.println("更新后，键 '" + testKey + "': " + jedis.get(testKey) + ", 剩余TTL: " + jedis.ttl(testKey) + "秒");

            // 5. 再次验证TTL是否保持不变（或接近）
            Thread.sleep(5000); // 再次等待5秒
            System.out.println("再次等待5秒后，键 '" + testKey + "' 的剩余TTL: " + jedis.ttl(testKey) + "秒");

            // 清理测试数据
            jedis.del(testKey);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("主线程中断: " + e.getMessage());
        } finally {
            // 6. 关闭JedisPool
            if (jedisPool != null) {
                jedisPool.close();
                System.out.println("JedisPool closed.");
            }
        }
    }
}

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import redis.clients.jedis.Jedis; // For Jedis native client
import redis.clients.jedis.params.SetParams; // For Jedis params

import io.lettuce.core.api.sync.RedisCommands; // For Lettuce native client
import io.lettuce.core.SetArgs; // For Lettuce args

import java.nio.charset.StandardCharsets;

public class SpringRedisTemplateUpdater {

    private final RedisTemplate<String, String> redisTemplate;

    // 构造函数，通过Spring进行依赖注入
    public SpringRedisTemplateUpdater(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
        // 确保Key和Value的序列化器已配置
        if (redisTemplate.getKeySerializer() == null) {
            redisTemplate.setKeySerializer(new StringRedisSerializer());
        }
        if (redisTemplate.getValueSerializer() == null) {
            redisTemplate.setValueSerializer(new StringRedisSerializer());
        }
    }

    /**
     * 使用RedisTemplate更新键值并保留TTL（Jedis底层实现）。
     * @param key 要更新的键
     * @param newValue 要设置的新值
     */
    public void updateKeyValueKeepTTLWithJedis(String key, String newValue) {
        redisTemplate.execute((RedisConnection connection) -> {
            // 获取底层的Jedis连接
            Object nativeConnection = connection.getNativeConnection();
            if (nativeConnection instanceof Jedis) {
                Jedis jedis = (Jedis) nativeConnection;
                // 使用Jedis的set方法和KEEPTTL参数
                jedis.set(key, newValue, new SetParams().keepTtl());
                System.out.println("通过RedisTemplate (Jedis) 更新键 '" + key + "' 成功，TTL已保留。");
            } else {
                throw new UnsupportedOperationException("当前RedisTemplate连接非Jedis，无法使用Jedis原生KEEPTTL方法。");
            }
            return null;
        });
    }