本节内容:
php调用redis提供队列服务。
例1,入队操作文件(enqueue.php):
复制代码 代码示例:
<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
while (true)
{
$redis->lPush('list1', 'A_'.date('Y-m-d H:i:s'));
sleep(rand() % 3);
}
?>
执行:php enqueue.php &
例2,出队操作文件(dequeue.php):
复制代码 代码示例:
<?php
$redis = new Redis();
$redis->pconnect('127.0.0.1', 6379);
while(true)
{
try
{
var_dump($redis->blPop('list1', 10));
}
catch(Exception $e)
{
// do something
}
}
执行:
php dequeue.php &
相关阅读:
php-redis中文文档之五
php-redis中文文档之四
php-redis中文文档之三
php-redis中文文档之二
php-redis中文文档之一