1. 什么是redis的RTT

RTT是网络往返时间的简称
每一次执行redis都会向redis-server发送执行的命令(send),比如set a 1, redis-server接收到请求并执行后,会返回一个数据或结果(recv) , send时间和recv中间的时间就是RTT, 也就是说假如发送了三次redis命令,就会产生三个RTT

redis操作流程:

发送命令
命令排队
命令执行
返回结果

Pipeline 主要是一种网络的优化! 本质上意味着客户端在缓冲区缓冲一堆命令,并一次性将他们发送到服务器 , 这些命令不能保证在事务中执行 , 从而达到了节省每一个命令的网络往返时间

需要注意的是集群模式对于pipline不太友好，因为pipline要操作的key可能在不同的哈希槽上，此时就需要进行请求的转发，但是这是与pipline的思想相违背的，所以集群模式下不太支持使用pipline的操作。

如果pipeline中的命令过多，可能会导致阻塞redis

示例对比

echo "请求redis开始".PHP_EOL;
$t = microtime();
$redis = new Redis();
$redis->connect("127.0.0.1",6379);
$t = microtime();
$redis->set("test:id:a1" ,1);
$redis->set("test:id:a2" ,2);
$redis->set("test:id:a3" ,3);
echo "RTT时间为:".(microtime()-$t).PHP_EOL;// 管道
$pt = microtime();
$res = $redis -> pipeline(function ($pipe){$pipe->set("test:id:p1" ,1);$pipe->set("test:id:p2" ,2);$pipe->set("test:id:p3" ,3);
});
echo "管道RTT时间为:".(microtime()-$pt).PHP_EOL;

结果:

PHP使用redis管道

基础使用:

$res = $redis -> pipeline(function ($pipe){$pipe -> lPush('list',[time()]);$pipe -> llen('list');$pipe->lRange('list',0,-1);});print_r($res);//如果你想要使用外部的变量，也可以使用use关键字将外部变量导入到函数内部，$name = 'msy-redis-test';$res = $redis -> pipeline(function ($pipe) use($name){$pipe -> set('name',$name);});print_r($res);

循环

$users = [1, 2, 3, 4];
$predis = app('redis')->connection()->client();
$user_values = $predis->pipeline(function ($pipe) use ($users) {
foreach ($users as $val) {
$pipe->get('test' . $val);
}
});
dump($user_values);