17370845950

新闻动态
RedisTemplate Pipeline批量获取值为空：原因及解决方法是什么？

使用redistemplate通过pipeline批量获取值时，结果为空的原因和解决办法

在使用spring data redis的redistemplate时，采用pipeline技术可以批量执行命令，提升性能。然而，有时使用pipeline批量查询后，获取到的值可能是空的。

原因分析

  1. 执行结果处理不当： pipeline操作完成后才返回结果列表，需要在外部进行处理。
  2. 管道内直接处理结果： 在pipeline中循环处理每个键，违背了减少网络往返的初衷。
  3. 返回值未处理： doinredis方法的返回值应包含所有命令的结果。

解决办法

方式 1

public  list batchgetlist(collection keys) {
    if (collectionutil.isempty(keys)) {
        return new arraylist<>();
    }

    list results = redistemplate.executepipelined((redisconnection connection) -> {
        redisserializer keyserializer = (redisserializer) redistemplate.getkeyserializer();
        for (string key : keys) {
            connection.get(keyserializer.serialize(key));
        }
        return null;
    });

    // 在管道执行外部处理结果
    return results.stream()
            .map(result -> (t) redistemplate.getvalueserializer().deserialize((byte[]) result))
            .collect(collectors.tolist());
}
该方法批量发送get命令，并在pipeline操作完成后一次性处理所有结果，将字节数组反序列化为对象。


方式 2


使用sessioncallback进行管道操作，并在外部循环中直接获取值。
public  List batchGetList1(Collection keys) {
    if (CollectionUtil.isEmpty(keys)) {
        return new ArrayList<>();
    }

    List list = new ArrayList<>();
    redisTemplate.executePipelined(new SessionCallback() {
        @Override
        public Object execute(RedisOperations operations) throws DataAccessException {
            keys.forEach(key -> {
                Object o = operations.opsForValue().get(key);
                list.add((T) o);
            });
            return null;
        }
    });
    return list;
}
需要注意的是，以上方法假设所有键对应的值都使用相同的反序列化器。若不同，则需要进一步处理结果。
 
	









            
            

              
              
            

          
        
      
      


  
赣ICP备2024031479号