我开发了一个 rest api，它接受一些数据并将其存储在消息队列（Redis 列表）中。现在从 redis 将这些数据推送到 MySQL 数据库中。 问题是客户端需要等到数据写入mysql。
我希望客户端应该等到数据写入消息队列（Redis 列表）并且将数据推送到 MySQL 的函数应该异步执行。 我该怎么做 ？我的整个代码库都是 PHP 的，所以我更喜欢 PHP。
我已阅读此内容，但未尝试过。
Distributed queue example in PHP using Redis
我对如何执行 slave.php（链接中提到的）感到困惑。我的意思是当队列中有新消息到达时，slave.php 将如何找到它。
我不想为此使用 cronjob。相反，当新消息到达时，slave.php 应该异步执行。怎么办？
【问题讨论】：
标签： php asynchronous redis message-queue
是的，这很可能使用 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 文件并分散负载。
【讨论】：
您的问题远不清楚您的系统当前是如何工作的。
当有新消息到达时，slave.php 应该异步执行。
这句话是矛盾的。如果消息的处理是异步发生的，那么根据定义，它与消息的创建无关。
我怀疑问题在于您没有处理消息出列的守护程序 - 但是解释如何编写这样的程序超出了这里的答案范围。
【讨论】：