【发布时间】:2014-05-24 01:36:09
【问题描述】:
我有一个问题 - 如何保持消费者和生产者之间的持续连接?
我的意思是当生产者发送消息时 - 如果我使用 rpc 过程并且连接将关闭,则消费者处理它并使用回调队列发送回。
现在我希望消费者和生产者之间的连接应该打开。如何做到这一点?
谢谢
【问题讨论】:
-
有点不清楚你在问什么。消费者和生产者都连接到代理,而不是相互连接。如果您不想关闭连接并让消费者处于活动状态并等待新消息,请让他们保持活动状态。
-
是的,我的消费者是活跃的——实际上我知道消费者和生产者都异步连接到 RabbitMQ。但我希望消费者和生产者之间的连接打开,这样如果我想向生产者发送消息,那么我可以通过我想要的那个打开的连接发送消息。
标签: php rabbitmq message-queue php-amqp