Redis 管道技能可以在做事端未相应时，客户端可以连续向做事端发送要求，并终极一次性读取所有做事真个相应。
实例
查看 redis 管道，只须要启动 redis 实例并输入以下命令：
$(echo -en "PING\r\n SET runoobkey redis\r\nGET runoobkey\r\nINCR visitor\r\nINCR visitor\r\nINCR visitor\r\n"; sleep 10) | nc localhost 6379+PONG+OKredis:1:2:3
以上实例中我们通过利用 PING 命令查看redis做事是否可用， 之后我们设置了 runoobkey 的值为 redis，然后我们获取 runoobkey 的值并使得 visitor 自增 3 次。
在返回的结果中我们可以看到这些命令一次性向 redis 做事提交，并终极一次性读取所有做事真个相应
管道技能的上风
管道技能最显著的上风是提高了 redis 做事的性能。
一些案例和测试数据
案例一：基本利用
$redis = new Redis();//开启管道模式$pipe = $redis->multi(Redis::PIPELINE);//循环遍历数据，实行操作foreach ($users as $user_id => $username){// 用户被访问的次数+1 $pipe->incr('accessed:' . $user_id);// 获取用户数据记录 $pipe->get('user:' . $user_id);}// 开始实行管道里所有命令$users = $pipe->exec();// 打印数据print_r($users);
案例二：将100万条数据写入redis//产生100万条数据到指定文件declare(strict_types=1);//开启强类型模式function random($length, $numeric = false){ $seed = base_convert(md5(microtime() . $_SERVER['DOCUMENT_ROOT']), 16, $numeric ? 10 : 35); $seed = $numeric ? (str_replace('0', '', $seed) . '012340567890') : ($seed . 'zZ' . strtoupper($seed));if ($numeric) { $hash = '';} else { $hash = chr(rand(1, 26) + rand(0, 1) 32 + 64); $length--;}$max = strlen($seed) - 1;for ($i = 0; $i < $length; $i++) { $hash .= $seed{mt_rand(0, $max)};}return $hash;}$filePath = './data.txt';for ($i = 0; $i <= 1000000; $i++) { $str = random(10, true); file_put_contents($filePath, $str . PHP_EOL, FILE_APPEND);}//读取数据通过管道办法写入到redis$lines = file_get_contents($filePath);//获取文件内容ini_set('memory_limit', '-1');//不要限定Mem大小，否则会报错$arr = explode(PHP_EOL, $lines);//转换成数组//echo $arr['1000000'] ?? 'null';try { $redis = new \Redis(); $redis->connect('192.168.1.9', 6379); $redis->auth('');//密码验证 $redis->select(0);//选择库 $redis->pipeline();//开启管道foreach ($arr as $key => $value) { $redis->hsetNx('helloworld', (string)$key, $value);} $redis->exec(); echo $redis->hGet('helloworld', '1000000') . PHP_EOL; echo $redis->hGet('helloworld', '1000001') . PHP_EOL;} catch (\Exception $e) { echo $e->getMessage();}案例三：通过管道批量设置与读取//批量设置try { $redis = new \Redis(); $redis->connect('192.168.1.9', 6379); $redis->auth(''); $redis->select(0); $redis->pipeline();//开启管道 $redis->set('str1', 'h'); $redis->set('str2', 'e'); $redis->set('str3', 'l'); $redis->set('str4', 'l'); $redis->set('str5', 'o'); $redis->set('str6', 'w'); $redis->set('str7', 'o'); $redis->set('str8', 'r'); $redis->set('str9', 'l'); $redis->set('str10', 'd'); $result = $redis->exec(); print_r($result);} catch (\Exception $e) { echo $e->getMessage();}结果：Array([0] => 1[1] => 1[2] => 1[3] => 1[4] => 1[5] => 1[6] => 1[7] => 1[8] => 1[9] => 1)//批量读取try { $redis = new \Redis(); $redis->connect('192.168.1.9', 6379); $redis->auth(''); $redis->select(0); $redis->pipeline();//开启管道 $redis->get('str1'); $redis->get('str2'); $redis->get('str3'); $redis->get('str4'); $redis->get('str5'); $redis->get('str6'); $redis->get('str7'); $redis->get('str8'); $redis->get('str9'); $redis->get('str10'); $result = $redis->exec(); print_r($result);} catch (\Exception $e) { echo $e->getMessage();}结果：Array([0] => h[1] => e[2] => l[3] => l[4] => o[5] => w[6] => o[7] => r[8] => l[9] => d)
