RedisTemplate、StringRedisTemplate管道Pipeline用法

1.简介

Redis是采用基于C/S模式的请求/响应协议的TCP服务器。redis客户端通过socket连接发起请求，每个请求在命令触发后会阻塞等待redis服务器进行处理，处理完毕后将结果返回给client。每个请求都存在往返时间，即使redis性能高，当数据量大时也会极大影响性能，还可能引起其他意外情况。

在很多场景下，我们要完成一个业务，可能会对redis做连续多个操作。譬如库存减一，订单加一等等，有很多步骤需要连续依次执行。这种场景下，网络传输的耗时将是限制redis处理量的主要瓶颈。

使用Pipeline可以解决以上问题：Pipeline把所有命令一次性发过去，避免频繁的发送、接收带来的网络开销。redis在打包接收到一堆命令后，依次执行，然后把执行结果再打包返回给客户端。

2.用法

//获取指定key的所有hashKey
Set<String> studentIdSet = redisTemplate.opsForHash().keys("key:" + "_" + classId);
if (CollectionUtils.isEmpty(studentIdSet)) {return false;
}

//根据hashKey依次获取所有value
List<Object> executeResult = redisTemplate.executePipelined(new RedisCallback<Object>() {@Overridepublic Object doInRedis(RedisConnection connection) throws DataAccessException {//业务操作if (!CollectionUtils.isEmpty(studentIdSet)) {for (String studentId : studentIdSet) {connection.get(("key:" + classId + "_" + studentId).toString().getBytes());}}return null;}
});
if (!CollectionUtils.isEmpty(executeResult)) {for (Object studentObj : executeResult){System.out.println("classId:"+classId+"的学生："+JSON.parseObject(studentObj,Student.class));}
}