redis-cluster pipeline測試
阿新 • • 發佈:2020-12-01
測試用例如下:
@Test void redisPiplineTest(){ //測試redis-cluster pipline List<Object> res=redisTemplate.executePipelined(new SessionCallback<Integer>() { @Override public <K, V> Integer execute(RedisOperations<K, V> operations) throws DataAccessException { operations.opsForValue().get("lcc"); operations.opsForValue().get("clc"); operations.opsForValue().get("ccl"); return 0; } }); for (Object ob:res){ System.out.println(ob); } }
執行結果:
檢視丟擲異常的方法:
org.springframework.data.redis.connection.jedis.JedisClusterConnection#openPipeline
emm,可以看到JedisClusterConnection的openpipeline總是會丟擲異常,而下面的方法可以看到與ConnectionFactory有關,而之前的帖子中我們提到可以根據slot分組之後pipeline,但是如果是
clusterConnection本身實現的原因,上面這個方案是不是真的行得通?