phpredis管道是否与使用协议进行大量插入相同？

将phpredis放入Redis :: PIPELINE模式时会发生什么,而不是在调用命令时发送命令,而是将其放入“待发送”命令列表中.然后,一旦调用exec(),就会创建一个包含所有命令的大命令缓冲区并发送给Redis.

在命令全部发送之后,phpredis读取每个回复并按照每个命令规范打包结果(例如,HMGET调用作为关联数组返回等).

phpredis中流水线的性能实际上非常好,几乎每个用例都应该足够了.话虽这么说,你仍在通过PHP处理每个命令,这意味着你将通过为每个命令调用phpredis扩展本身来支付函数调用开销.此外,phpredis将花时间处理和格式化每个回复.

如果您的用例需要将大量数据导入Redis,特别是如果您不需要处理每个回复(而只是想知道所有命令都已处理),则可以使用批量导入方法.

我实际上创建了一个项目来执行此操作：
https://github.com/michael-grunder/redismi

这个扩展背后的想法是你用命令调用它然后将缓冲区保存到磁盘,磁盘将采用原始Redis协议并与cat buffer.txt兼容. redis-cli – 管道样式插入.

需要注意的一点是,目前你不能简单地用RedisMI对象调用替换任何给定的phpredis调用,因为命令被处理为变量参数调用(如hiredis),它适用于大多数但不是所有phpredis命令.

这是一个如何使用它的简单示例：

<?php
$obj_mi = new RedisMI();

// Some context we can pass around in RedisMI for whatever we want
$obj_context = new StdClass();
$obj_context->session_id = "some-session-id";

// Attach this context to the RedisMI object
$obj_mi->SetInfo($obj_context);

// Set a callback when a buffer is saved
$obj_mi->SaveCallback(
    function($obj_mi,$str_filename,$i_cmd_count) {
        // Output our context info we attached
        $obj_context = $obj_mi->GetInfo();
        echo "session id: " . $obj_context->session_id . "n";

        // Output the filename and how many commands were sent
        echo "buffer file: " . $str_filename . "n";
        echo "commands   : " . $i_cmd_count . "n";
    }
);

// A thousand SADD commands,adding three members each time
for($i=0;$i<1000;$i++) {
    $obj_mi->sadd('some-set',"$i-one","$i-two","$i-three");
}

// A thousand ZADD commands
for($i=0;$i<1000;$i++) {
    $obj_mi->zadd('some-zset',$i,"member-$i");
}

// Save the buffer
$obj_mi->SaveBuffer('test.buf');
?>

然后你可以做这样的事情：

?  tredismi  php mi.php
session id: some-session-id
buffer file: test.buf
commands   : 2000
?  tredismi  cat test.buf|redis-cli --pipe
All data transferred. Waiting for the last reply...
Last reply received from server.
errors: 0,replies: 2000

干杯!