流水线 (Pipelining) _ Spring Data Redis 3.2.7 中文文档(官方文档中文翻译) —

对于最新的稳定版本，请使用 Spring Data Redis 3.3.1！Spring中文文档

Redis 支持流水线，这涉及向服务器发送多个命令，而无需等待回复，然后在单个步骤中读取回复。当您需要连续发送多个命令（例如将多个元素添加到同一列表）时，流水线可以提高性能。Spring中文文档

Spring Data Redis 提供了多种在管道中运行命令的方法。如果不关心流水线操作的结果，则可以使用标准方法，传递参数。这些方法在管道中运行提供的 or 并返回结果，如以下示例所示：RedisTemplateexecutetruepipelineexecutePipelinedRedisCallbackSessionCallbackSpring中文文档

//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中文文档

请注意，从返回的值必须为，因为此值将被丢弃，以便返回流水线命令的结果。RedisCallbacknullSpring中文文档

Lettuce 驱动程序支持细粒度刷新控制，允许在命令出现时刷新命令、缓冲命令或在连接关闭时发送命令。Spring中文文档

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

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

Lettuce 驱动程序支持细粒度刷新控制，允许在命令出现时刷新命令、缓冲命令或在连接关闭时发送命令。Spring中文文档

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

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

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