文章目录
【README】
本文总结自《redis开发与运维》，作者付磊，张益军，墙裂推荐；
- 本文使用的redis版本是 7.0.15 ;
- 本文主要介绍redis流水线概念及jedis操作流水线代码实践；
- 代码参见： https://github.com/TomJourney/redisDiscover/tree/master
【1】redis流水线Pipeline
1）redis客户端执行一条命令分为4个步骤：
- 发送命令；
- 命令排队；
- 命令执行；
- 返回结果；
2）RTT往返时间：发送命令与返回结果的执行耗时（RTT-Round Trip Time） ；
3）问题与解决方法：
问题：redis的批量操作命令能够有效节约RTT，如mget，mset。但问题是大部分命令不支持批量操作，如hgetall，即批量业务场景只能执行单条命令，网络IO高，导致RTT高。
- 【例】： redis客户端在北京，服务器在上海，两地直线距离为1300公里，1次RTT时间=1300*2/(300000 * 2/3) = 13ms（光在真空中的速度为每秒30w公里，假设光纤传播速度为光速的2/3，即每秒20w公里）
- 若批量业务场景需要执行10次hgetall，则需要130ms，单单操作redis的网络io就有130ms，还不算正常的业务逻辑耗时，显然操作redis的耗时是不合理的（补充： 一般一次请求响应的网络耗时不超过200ms ）；
解决方法：使用redis流水线技术；
4）其他补充： redis命令真正执行的耗时是微秒级别（1s=1000000 microsecond）；所以才会有redis性能瓶颈在网络开销的说法 ；
【1.1】redis流水线概念
1）redis流水线：能够将一组redis命令进行组装， 通过一次RTT传输给redis，再将这组执行结果一次性返回给客户端；即使用pipeline执行n次命令，耗时1个RTT；
【1.2】redis流水线性能测试
【1.2.1】使用流水线与未使用流水线的性能对比
1）在不同网络环境下， 10000条set未使用流水线命令 与 使用流水线命令执行耗时如下。
2）redis流水线性能对比结论：
- 流水线执行速度一般比逐条执行要快；
- 客户端与服务器的网络延时越大，，则流水线的效果越明显；
【1.2.2】使用流水线与redis原生批量命令的性能对比
1）流水线与原生批量命令区别：
- 流水线执行命令不是原子的，而原生批量命令是原子的；
- 流水线支持多个命令，而原生批量命令是一个命令操作多个key，如mset；
- 流水线需要客户端与服务器同时提供支持，而原生批量命令是redis服务器提供支持；
【1.2.3】流水线缺点
1）每次流水线封装的命令不能太多，流水线组装的命令过多可能导致阻塞；
- 一方面：一次流水线可能增加客户端的等待时间；
- 另一方面：造成一定的网络阻塞；
2）解决方法： 可以将包含大量命令的流水线拆分为多个小流水线；
【1.3】Jedis客户端执行流水线
【1.3.1】Jedis客户端执行流水线实现批量删除代码实践
【PooledJedisBatchDelViaPipeline】池化jedis操作流水线
public class PooledJedisBatchDelViaPipeline {
public static void main(String[] args) {
BusiJedisFactoryUsingPool busiJedisFactoryUsingPool = BusiJedisFactoryUsingPool.build();
// 从jedis连接池获取jedis对象
Jedis jedis = busiJedisFactoryUsingPool.getJedis();
try {
System.out.println(jedis.get("user01"));
System.out.println(jedis.get("user02"));
batchDelete(jedis, Arrays.asList("user01", "user02"));
} catch (Exception e) {
throw new IllegalStateException(e.getMessage(), e);
} finally {
if (Objects.nonNull(jedis)) {
jedis.close();
}
}
// 删除键之后获取键
// 从jedis连接池获取jedis对象
System.out.println("========== 删除键之后获取键 ========== ");
jedis = busiJedisFactoryUsingPool.getJedis();
try {
System.out.println(jedis.get("user01"));
System.out.println(jedis.get("user02"));
} catch (Exception e) {
throw new IllegalStateException(e.getMessage(), e);
} finally {
if (Objects.nonNull(jedis)) {
jedis.close();
}
}
}
private static void batchDelete(Jedis jedis, List<String> keys) {
// 生成pipeline对象
Pipeline pipeline = jedis.pipelined();
for (String key : keys) {
pipeline.del(key);
}
// 提交命令到redis
pipeline.sync();
}
}
【日志】
zhagnsan01
zhagnsan02
========== 删除键之后获取键 ==========
null
null
【代码解说】
- jedis.pipelined() ：创建流水线对象；
- pipeline.del(String key) 与 jedis.del(String key) 的写法是一致的，只不过pipeline.del(String key) 不会立即执行命令；
- pipeline.sync() 执行流水线组装的多个命令（发送组装多个命令的流水线到redis服务器）
【1.3.2】Jedis客户端执行流水线并获取执行结果代码实践
1）syncAndReturnAll()： 执行流水线命令并获取执行结果
【PooledJedisSetAndGetResultViaPipeline】
public class PooledJedisSetAndGetResultViaPipeline {
public static void main(String[] args) {
BusiJedisFactoryUsingPool busiJedisFactoryUsingPool = BusiJedisFactoryUsingPool.build();
// 从jedis连接池获取jedis对象
Jedis jedis = busiJedisFactoryUsingPool.getJedis();
try {
setAndGetReulst(jedis);
} catch (Exception e) {
throw new IllegalStateException(e.getMessage(), e);
} finally {
if (Objects.nonNull(jedis)) {
jedis.close();
}
}
}
private static void setAndGetReulst(Jedis jedis) {
// 生成pipeline对象
Pipeline pipeline = jedis.pipelined();
pipeline.set("user03", "zhangsan03");
pipeline.incr("age");
// syncAndReturnAll 执行流水线命令并返回结果
List<Object> resultList = pipeline.syncAndReturnAll();
for (Object result : resultList) {
System.out.println(result);
}
}
}
【日志】
OK
2