Java 使用 RedisTemplate 保持多个服务操作同一 Key 数据一致性

在多个服务同时操作 Redis 中同一个 key 的情况下，为了保持数据一致性，可以采取以下几种方式：

1. 使用 Redis 的事务机制：在 Java 中使用 RedisTemplate 进行操作时，可以通过调用其execute方法来执行事务。在事务中，可以先插入新数据，然后再删除过期数据，这样可以保证操作的原子性。

redisTemplate.execute(new SessionCallback<Object>() {
    @Override
    public Object execute(RedisOperations operations) throws DataAccessException {
        operations.multi();  // 开启事务

        // 插入新数据
        operations.opsForList().rightPush('key', 'value');

        // 删除过期数据
        operations.opsForList().trim('key', 0, -10);

        operations.exec();   // 提交事务
        return null;
    }
});

2. 使用 Redis 的分布式锁：在每个服务执行操作之前，先获取一个分布式锁，确保只有一个服务能够对 key 进行操作，其他服务需要等待。可以使用 Redisson 等框架来实现分布式锁。

RLock lock = redisson.getLock('keyLock');
try {
    lock.lock();

    // 插入新数据
    redisTemplate.opsForList().rightPush('key', 'value');

    // 删除过期数据
    redisTemplate.opsForList().trim('key', 0, -10);
} finally {
    lock.unlock();
}

3. 使用 Redis 的发布订阅机制：一个服务负责往 key 中插入数据，另一个服务通过订阅相应的频道来接收插入的数据，并在接收到数据后进行删除操作。

// 发布数据
redisTemplate.convertAndSend('channel', 'value');

// 订阅频道
MessageListenerAdapter listenerAdapter = new MessageListenerAdapter(new MessageListener() {
    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 接收到数据后进行删除操作
        redisTemplate.opsForList().trim('key', 0, -10);
    }
});
redisTemplate.getConnectionFactory().getConnection().subscribe(listenerAdapter, 'channel'.getBytes());

以上是几种常用的保持 Redis 数据一致性的方法，根据实际场景选择适合的方式。