php - PHP 中的消息队列

Question

我开发了一个 rest api，它接受一些数据并将其存储在消息队列(Redis 列表)中。现在从 redis 中将这些数据推送到 MySQL 数据库中。 问题是客户端需要等到数据写入mysql。

我希望客户端应该等到数据写入消息队列(Redis 列表)并且将数据推送到 MySQL 的函数应该异步执行。 我该怎么做 ？我的整个代码库都是用 PHP 编写的，所以我更喜欢用 PHP。

我读过这个但还没有尝试过。

Distributed queue example in PHP using Redis

我对如何执行 slave.php(在链接中提到)感到困惑。我的意思是当队列中有新消息到达时，slave.php 将如何找到它。

我不想为此使用 cronjob。相反，当新消息到达时，slave.php 应该异步执行。怎么做？

Answer 1

是的，这非常有可能使用 Memqueue、Redis 等。

使用 Redis，可以这样做:

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

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

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