PHP 使用 Redis 提供队列服务

入队操作文件(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 &

出队操作文件(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 &

未经允许不得转载:SuperMan's blog » PHP 使用 Redis 提供队列服务

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址