Java RedisTemplate Pipeline批量查询返回空值的原因是什么?

java通过redistemplate使用pipeline批量查询返回空值的原因

使用redistemplate的pipeline进行批量查询时,返回的结果为null通常是由结果处理不当造成的。

在第一个方法中,问题是尝试在管道操作内部处理命令结果,这违反了使用管道的原则。正确的做法是在调用executepipelined方法后处理结果。

此外,在doinredis方法中,对每个键进行获取和反序列化操作违背了管道设计的初衷,因为这样做没有减少网络往返次数。

第二个方法也存在类似问题。正确的方法是在executepipelined之后处理结果,而不是在管道操作内部。

改进后的批量查询方法:

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命令作为一个批量操作发送,并在操作完成后一次性处理所有结果。假设所有键对应的值都可以使用相同的反序列化器反序列化。如果应用场景中有不同类型的值,需要对结果进行进一步处理才能正确反序列化。

关于我们

奈瑶·映南科技互联网学院是多元化综合资讯平台,提供网络资讯、运营推广经验、营销引流方法、网站技术、文学艺术范文及好站推荐等内容,覆盖多重需求,助力用户学习提升、便捷查阅,打造实用优质的内容服务平台。

搜索Search

搜索一下,你就知道。