99网
您的当前位置:首页RedisTemplate的Pipelined方式怎么使用?

RedisTemplate的Pipelined方式怎么使用?

来源:99网

调用redisTemplate的executePipelined方法,传入RedisCallback实现,要跟redis沟通的命令都写在这实现里,代表一次pipeline。
注意:此时的RedisCallback返回值必须为null,可以看源码,很简单

StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        redisTemplate.executePipelined((RedisCallback<Object>) connection -> {
            for (int j = 0; j < 1000; j++) {
                byte[] rawKey = stringRedisSerializer.serialize("books");
                byte[] rawValue = stringRedisSerializer.serialize(j + "");

                connection.zIncrBy(rawKey, 10000L, rawValue);
            }
            return null;
        });

因篇幅问题不能全部显示,请点此查看更多更全内容