ShardedJedisPool是如何选择对应的库的?

2025-03-04 23:24:15
推荐回答(1个)
回答1:

Collection collection=shardedJedis.getAllShards();
Iterator jedis = collection.iterator();
while(jedis.hasNext()){
jedis.next().select(redisIndex);
}
ShardedJedisPipeline pipeline = shardedJedis.pipelined();
if (fields.length > 0) {
for (int i = 0; i < fields.length; i++) {
pipeline.hset(key,fields[i],values[i]);
}
pipeline.sync();
}