我正在学习RabbitMQ，并想过用它向用户提供"动态消息"更新，就像facebook从朋友那里提供动态提要一样。
我的想法是：
-
每当创建用户时，我都会创建一个队列，其名称为用户的userId，因此队列名称可以是"
100_message_queue"（userId_message_queue）。 -
Producer将推送此队列中的所有更新。
-
从客户端（javascript），它将调用像"
GET http://example.com/getliveupdates/100"这样的REST API，然后我将从100_message_queue获取所有新更新并将其作为响应发送。
我读了RabbitMQ php教程，但不明白这是怎么可能的？此外，consumer永远运行，所以我似乎无法发出任何REST请求。它让我暂停了。
知道如何实现这种结构吗？
感谢
当您计划将消息传递到web客户端时，我建议您使用web STOMP RabbitMQ插件查看MQTT和STOMP。对您来说，在WebSocket上使用它们的功能应该是一个完美的解决方案。它还为您提供实时消息，这始终是一个专业，可能也是您想要的。
关于处理永远运行的消费者：
如果您使用的是php-amqp扩展，您可以将read_timeout选项设置为一些小值，比如1（秒），所以当消费者从队列中获取所有消息时，它将再等待1秒，等待新消息，然后抛出异常（我想是AMQPConnectionException，很难看的解决方案，但目前是这样做的）。
或者，您可以从队列中AMQPQueue::get消息，直到消息不剩为止。
对于php-amqplib，事情应该是一样的，至少想法仍然是一样的：限制消费者按时间等待新消息，或者以迭代的方式从队列中获取消息。