用于动态消息更新的RabbitMQ PHP
提问于 2014-10-02 20:06:38
我正在学习RabbitMQ，并考虑使用它给用户提供“动态消息”更新，就像facebook提供来自朋友的动态提要一样。
我的想法是:
- 每当创建用户时，我都会创建一个具有名称的队列是用户的userId，因此队列名可以是"
100_message_queue“(userId_message_queue)。 - 生产者将推送此队列中的所有更新。
- 从客户端(javascript)，它将调用像"
GET http://example.com/getliveupdates/100“这样的REST，然后我将从100_message_queue获取所有新的更新，并将其作为响应发送。
我读过RabbitMQ php教程，但不知道这是怎么可能的？此外，消费者永远运行，所以它似乎我不能提出任何休息请求。它让我超时了。
知道如何实现这种结构吗？
谢谢
回答 1
Stack Overflow用户
发布于 2014-10-03 01:02:13
当您计划将这些消息传递给web客户端时，我建议您使用MQTT和踩踏上的网踩 RabbitMQ插件。对您来说，使用他们的能力超过WebSocket应该是一个完美的解决方案。它为您提供实时消息，这始终是一个专业，可能是您想要的。
至于如何处理永远运行的消费者：
如果您正在使用php-amqp扩展，您可以将read_timeout选项设置为一些小值，例如1(秒)，因此当使用者从队列中获取所有消息时，它将等待1秒。更多关于新消息的内容，然后抛出一个异常(我猜是AMQPConnectionException，丑陋的解决方案，但现在是这样做的)。
或者，您可以从队列中AMQPQueue::get消息，直到没有消息为止。
对于php-amqplib，事情应该是一样的，至少想法还是一样的:限制使用者按时间等待新消息，或者以迭代的方式从队列中获取消息。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/26173151
复制
腾讯云开发者
