流水线

Redis 支持流水线，这涉及向服务器发送多个命令，而无需等待回复，然后一步读取回复。当你需要连续发送多个命令时，例如将许多元素添加到同一个 List 时，流水线可以提高性能。spring-doc.cn

Spring Data Redis 提供了多种在管道中运行命令的方法。如果您不关心 pipelined 操作的结果，则可以使用标准方法，并传入参数。这些方法在管道中运行提供的 OR 并返回结果，如以下示例所示：RedisTemplateexecutetruepipelineexecutePipelinedRedisCallbackSessionCallbackspring-doc.cn

//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;
  }
});

前面的示例从管道中的队列中批量右弹出项目。包含所有弹出的项目。在返回之前使用其 value、hash key 和 hash value 序列化器反序列化所有结果，因此前面示例中返回的项是 Strings。还有其他方法允许您为流水线结果传递自定义序列化程序。resultsListRedisTemplateexecutePipelinedspring-doc.cn

请注意，从返回的值必须是，因为此值被丢弃，以便返回 pipelined 命令的结果。RedisCallbacknullspring-doc.cn

Lettuce 驱动程序支持细粒度的 flush 控制，允许在命令出现时刷新命令、缓冲或在连接关闭时发送命令。spring-doc.cn

LettuceConnectionFactory factory = // ...
factory.setPipeliningFlushPolicy(PipeliningFlushPolicy.buffered(3)); (1)

1	在本地缓冲，并在每 3 个命令后刷新。

流水线仅限于 Redis Standalone。 Redis Cluster 目前仅支持通过 Lettuce 驱动程序，但在使用跨槽键时，以下命令除外：、、完全支持相同槽位的密钥。renamerenameNXsortbLPopbRPoprPopLPushbRPopLPushinfosMovesIntersInterStoresUnionsUnionStoresDiffsDiffStore