redis管道pipeline的运用

分类:技术文档 - Redis | 阅读(332) | 发布于:2018-11-05 18:04

Redis使用的是客户端-服务器(CS)模型和请求/响应协议的TCP服务器。这意味着通常情况下一个请求会遵循以下步骤:
客户端向服务端发送一个查询请求,并监听Socket返回,通常是以阻塞模式,等待服务端响应。服务端处理命令,并将结果返回给客户端。

普通模式与管道模式
普通模式:由于通信会有网络延迟,假如client和server之间的包传输时间需要0.125秒。那么上面的三个命令6个报文至少需要0.75秒才能完成。这样即使redis每秒能处理100个命令,而我们的client也只能一秒钟发出四个命令。这显然没有充分利用 redis的处理能力。
管道模式:(pipeline)可以一次性发送多条命令并在执行完后一次性将结果返回,pipeline通过减少客户端与redis的通信次数来实现降低往返延时时间,而且Pipeline 实现的原理是队列,而队列的原理是时先进先出,这样就保证数据的顺序性。 Pipeline 的默认的同步的个数为53个,也就是说arges中累加到53条数据时会把数据提交。其过程如下图所示:client可以将三个命令放到一个tcp报文一起发送,server则可以将三条命令的处理结果放到一个tcp报文返回。 需要注意到是用 pipeline方式打包命令发送,redis必须在处理完所有命令前先缓存起所有命令的处理结果。打包的命令越多,缓存消耗内存也越多。所以并不是打包的命令越多越好。具体多少合适需要根据具体情况测试。

$redis = new Redis();
$redis->connect('127.0.0.1', 5678);
$redis->select(9);
$memberId = 12345678;
$memberHandler = ServBox()->Member();
$pipeline = $redis->pipeline();
while ($memberId > 0) {
    $pipeline->del($memberHandler->getKeyMemberInfo($memberId));
    if ($memberId % 50 == 0) {
        $pipeline->exec();
        $pipeline = $redis->pipeline();
    }
    $memberId--;
}
$pipeline->exec();
$redis = new Redis();

$redis->connect('127.0.0.1', 5678);
$redis->pipeline();
for ($i=0;$i<1000;$i++)
{
    $redis->set("test_{$i}",pow($i,2));
    $redis->get("test_{$i}");
}
$redis->exec();
$redis->close();

标签: