spring data redis集群管道支持

Question

是否有计划在连接到 redis 集群版本时支持 spring data redis 库的“流水线”操作。流水线操作和非流水线操作之间存在相当大的性能差异。如果没有这样的计划，还有哪些其他可行的选择？

Answer 1

Spring Data Redis 提供了几种 RedisTemplate 方法用于在管道中执行命令。如果您不关心流水线操作的结果，您可以使用标准的执行方法，为流水线参数传递 true。 executePipelined 方法将在管道中执行提供的 RedisCallback 或 SessionCallback 并返回结果。例如:

//pop a specified number of items from a queue
List<Object> results = stringRedisTemplate.executePipelined(
  new RedisCallback<Object>() {
    public Object doInRedis(RedisConnection connection) throws DataAccessException {
      StringRedisConnection stringRedisConn = (StringRedisConnection)connection;
      for(int i=0; i< batchSize; i++) {
        stringRedisConn.rPop("myqueue");
      }
    return null;
  }
});

上面的示例从管道中的队列中执行批量右弹出项目。结果列表包含所有弹出的项目。 RedisTemplate 使用其值、哈希键和哈希值序列化器在返回之前反序列化所有结果，因此上述示例中的返回项将是字符串。还有其他 executePipelined 方法允许您为流水线结果传递自定义序列化程序。

请注意，从 RedisCallback 返回的值必须为空，因为该值被丢弃以支持返回管道命令的结果。

引用:http://docs.spring.io/spring-data/redis/docs/current/reference/html/#pipeline