使用redistemplate通过pipeline批量获取值时，结果为空的原因和解决办法
在使用spring data redis的redistemplate时，采用pipeline技术可以批量执行命令，提升性能。然而，有时使用pipeline批量查询后，获取到的值可能是空的。
原因分析
- 执行结果处理不当： pipeline操作完成后才返回结果列表，需要在外部进行处理。
- 管道内直接处理结果： 在pipeline中循环处理每个键，违背了减少网络往返的初衷。
- 返回值未处理： doinredis方法的返回值应包含所有命令的结果。
解决办法
方式 1
public <t> list<t> batchgetlist(collection<string> keys) { if (collectionutil.isempty(keys)) { return new arraylist<>(); } list<object> results = redistemplate.executepipelined((redisconnection connection) -> { redisserializer<string> keyserializer = (redisserializer<string>) 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 <T> List<T> batchGetList1(Collection<String> keys) { if (CollectionUtil.isEmpty(keys)) { return new ArrayList<>(); } List<T> list = new ArrayList<>(); redisTemplate.executePipelined(new SessionCallback<Object>() { @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; }
需要注意的是，以上方法假设所有键对应的值都使用相同的反序列化器。若不同，则需要进一步处理结果。
