PHP中的Message Queue

是的,这很可能使用Memqueue,Redis等.

使用Redis,这就是人们可以做到的:

这个PHP文件在获取它时将消息推送到队列中:

/*
    Code logic
*/
$redis->lPush("message_queue", "message 1");

A slave.php使用以下方式执行"阻止弹出" brPop:

$redis = new Redis();
$redis->pconnect();

while (true) {
    list($queue, $message) = $redis->brPop(["message_queue"], 0);
    /*
    Logic to insert $message to MySQL
    */
}

现在每当有新消息到达时,它slave.php都会抓住它并将其推送到MySQL.

不要混淆while(true)- 上面的代码没有在无限循环中运行.在brPop异步等待直到出现在队列中的新消息.

我正在使用PHP 5.4并连接到Redis 2.6及以上版本工作正常.更好的是,您可以拥有多个slave.php文件并分配负载.

有关更多详细信息,请访问:http://redis.io/commands/blpop