【问题标题】:RabbitMQ - Continuous connection between producer and consumerRabbitMQ - 生产者和消费者之间的持续连接
【发布时间】:2014-05-24 01:36:09
【问题描述】:

我有一个问题 - 如何保持消费者和生产者之间的持续连接?

我的意思是当生产者发送消息时 - 如果我使用 rpc 过程并且连接将关闭,则消费者处理它并使用回调队列发送回。

现在我希望消费者和生产者之间的连接应该打开。如何做到这一点?

谢谢

【问题讨论】:

  • 有点不清楚你在问什么。消费者和生产者都连接到代理,而不是相互连接。如果您不想关闭连接并让消费者处于活动状态并等待新消息,请让他们保持活动状态。
  • 是的,我的消费者是活跃的——实际上我知道消费者和生产者都异步连接到 RabbitMQ。但我希望消费者和生产者之间的连接打开,这样如果我想向生产者发送消息,那么我可以通过我想要的那个打开的连接发送消息。

标签: php rabbitmq message-queue php-amqp


【解决方案1】:

也许this 可以帮助你,你可以为每个客户端创建一个回调队列,但是在向生产者发送消息时要小心处理correlationId

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2011-06-12
    • 2013-03-25
    • 1970-01-01
    • 2016-03-01
    • 1970-01-01
    • 2016-04-04
    • 1970-01-01
    • 2021-06-03
    相关资源
    最近更新 更多