PHP中文网2017-04-10 15:21:27
// 给$id设置需要的信息,譬如邮件地址、内容
$this->_redis->hMset($id, $struct);
// push到名为'queue'的队列
$this->_redis->lPush('queue', $id);
while (true) {
// 读取一个队列任务
$task = $redis->brPop('queue', 10);
// 获取队列任务的信息
if ($task) {
list ($name, $id) = $task;
}
// 调用邮件服务代码
}
你可能需要php redis文档https://github.com/phpredis/phpredis