1. 程式人生 > 實用技巧 >redis-cluster pipeline測試

redis-cluster pipeline測試

測試用例如下:

 @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本身實現的原因,上面這個方案是不是真的行得通?