try (Jedis jedis = new Jedis(host, port)) {
Pipeline pipeline = jedis.pipelined();
while (iter.hasNext()) {
String[] keyValue = iter.next().split("t");
pipeline.sadd(keyValue[0], keyValue[1]);
// you can call pipeline.sync() and start new pipeline here if you think there're so much operations in one pipeline
}
pipeline.sync();
}
1条答案
按热度按时间ktecyv1j1#
如果您有写入到Redis协议格式的输入,为什么不直接使用redis-cli或nc的管道模式呢?从http://redis.io/topics/mass-insert开始解释。
如果您有质量(键、值)输入,那么您可以使用Jedis通过流水线执行SAD,以获得更高的性能。
下面的例子假设ITER(迭代器)有元素,每一项都是关键的“\t”值形式。