jedis pipline exec 一次默认执行多少条命令？

Question

我正在使用 jedis 管道将一批数据插入到 redis 中。现在我面临一个困惑的问题。我想批量处理一个特定的大小，然后调用sync()，但似乎管道大约每200条记录会自动调用一次同步。这是我的代码，谁能告诉我是否存在任何配置？public class RedisClusterTest {public static void main(String args[]) throws IOException, InterruptedException {    String host = args[0];    int port = Integer.valueOf(args[1]);    int cnt = Integer.valueOf(args[2]);    Jedis jedis = new Jedis(host, port);    Pipeline pip = jedis.pipelined();    for(int i = 0 ; i < 2000; i++) {        pip.hset("Server", String.valueOf(i), String.valueOf(i));        Thread.sleep(10);    }    // When it end loop, about 1900 records has already been insert into redis, and the last sync only made last remaining data been sync.    pip.sync()

Answer 1

Pipeline 不会等待您的确认将批处理发送到 Redis。文档说：

有时你需要发送一堆不同的命令。一个非常酷的方法是使用流水线，并且比天真的方法具有更好的性能。这样，您无需等待响应即可发送命令，并且您实际上在最后读取了响应，这样更快。

总而言之，它说使用管道而不等待响应，并且像流一样发送。

我查看了他们的源代码，确认了他们的文档。

public Pipeline pipelined() {

  pipeline = new Pipeline();

  pipeline.setClient(client);

  return pipeline;

}

这将返回您的 Pipeline 实例。然后你打电话给一堆 HSET

public Long hset(final byte[] key, final byte[] field, final byte[] value) {

  checkIsInMultiOrPipeline();

  client.hset(key, field, value);

  return client.getIntegerReply();

}

马上得到答复。

然后你调用同步它：

通过读取所有响应来同步管道。此操作关闭管道。为了从流水线命令中获取返回值，请捕获您执行的命令的不同 Response<?>。

换句话说，它处理您的管道实例。

总而言之，如果您希望它仅在调用同步时发送批处理，则不应使用“流水线”。这不是它的工作方式。