1

我对 RabbitMQ 非常陌生，使用 RabbitMQ 3.5.3、Erlang R14B04 和 Alvaro Videla 的库（https://github.com/videlalvaro/php-amqplib）在 RabbitMQ 中排队。我需要让我的消费者连接一直保持活力，而不是生产者。 这背后的简单逻辑是，我通过 cron 运行我的生产者。在生成队列后，无需保持生产者连接。但是工人或消费者将被启动一次。这种联系不应该消失。

如果这也是由 cron 完成的，我总是会在一天结束时得到一长串消费者连接，这很烦人，而且不可取。

所以这里的重点是：

1.产生队列，每次通过cron关闭连接。

2.消费者开始一次，永远持续下去。任何排队的东西都会立即被消耗掉。

可以在我的系统中构建此架构吗？我需要在这里进行哪些必要的更改。

4

1 回答 1

0

阅读您的描述很难说更多，或者我只是不太了解您的问题。但是我会构建应用程序，如果有东西到达，则每 1 秒或 3 秒检查一次兔子

消费者

createConnectionToRabbit
while (true) {
  checkConnectionStillAlive
  fetchDataFromQueue
  doProcessData
  sleep(3)
}
closeConnection

制片人

createConnectionToRabbit
sendDataToRabbit
closeConnection
于 2015-07-08T09:32:33.647 回答