因此,我基本上是在RabbitMQ中尝试使用python客户端(Pika Library(从生产者向消费者发送一些消息,但默认情况下,接收器即使在读取消息后也会继续运行,因为它在等待更多消息,但根据我的要求,接收器应该在从队列中读取所有消息后停止一次队列是空的,或者至少它应该一个接一个地读取消息,当我再次打开它或在定义的时间段后,它应该再次读取消息,但主要关注的是停止接收器。那么我该如何在python的pika库中做到这一点呢。
接收器在从队列中读取所有消息后,基本上在队列为空时,应该停止一次
由于队列总是可以发布到,所以它们真的"吗;空的";?你需要提出一个条件来定义";"空";,类似于";在过去5秒内没有消息";或";消费者看到特定的CCD_ 1消息";。
我最近回答了一个类似的问题:
关闭在rabbitmq-pika 中处理长时间运行任务的空闲消费者
请参阅此代码,它演示了一个消费者在不活动5秒后停止:
https://github.com/lukebakken/so-pika-idle-consumer-72792217/blob/master/consumer.py
注意:RabbitMQ团队监控rabbitmq-users
邮件列表,有时只回答StackOverflow上的问题