管道符

<?php

/**
 * Class AutofelixRedis.
 * pipeline管道命令
 * 正常的命令是一条命令经过一次网络传输,传输一次就会有一次延迟,大量的命令多的话就会消耗大量的时间,延迟变高
 * 管道命令是将命令存储在redis客户端,由管道统一执行,统一返回结果.减少客户端与服务端的通信次数,减少IO调用次数
 * 管道要求一次性返回全部结果,所以在服务端将结果缓存起来,当数据量多得时候,会对redis服务器内存产生影响,造成较大压力.不支持原子性(没有规定必须全部成功,或全部失败)
 */
class AutofelixRedis {
    private $redis;

    public function __construct()
    {
        $this->redis = new Redis();
        $this->redis->connect('127.0.0.1', '6379');
        $this->redis->auth('123456');
    }

    public function base_test()
    {
        $startTime = microtime(true);
        for($i = 0; $i < 10000; $i++) {
            $this->redis->set("test".$i, "value".$i);
        }
        $endTime = microtime(true);

        echo $endTime-$startTime;
    }

    public function pipe_test()
    {
        $startTime = microtime(true);
        $pipeline = $this->redis->pipeline();
        for($i = 0; $i < 10000; $i++) {
            $pipeline->set("test{$i}", "value{$i}");
        }

        $endTime = microtime(true);

        echo $endTime-$startTime;
    }
}

$a = new AutofelixRedis();
$a->base_test();  // 0.3 秒左右
$a->pipe_test();   //  0.003 秒左右