消费者使用后的RabbitMQ清理

Question

我在处理以下情况时遇到问题：

我有一个发布者想要上载很多二进制信息（例如图像），所以我希望它保存图像并上载该文件的路径或某些引用。

我有多个different使用者正在从此MQ读取并执行不同的操作。为此，我只需将信息扇出即可发送到某些交换机，并为每个不同的使用者定义几个队列。

这可以很好地工作，除了破坏FS。由于没有人负责删除保存的图像。我需要一些方法来定义every]消费者完成从一条消息中获取一条消息的时间的钩子？也许设置一些回调以清除附件中的消息？

一些注意事项：

1. 所有事情都发生在本地，为简单起见，我们可以假设所有事情都在同一个FS上。

2. 我知道我可以简单地让发布者保存图像并为不同的消费者提供FS链接，但是这种解决方案是有问题的，因为我希望发布者不理会消费者。我不想每次使用一个新使用者（或可以删除​​一个新使用者）时更新发布者的代码。

3. 我正在使用python。 （pika模块）

4. 我是Message Queue的新手，所以如果您有更好的建议来完成工作，我很乐意对此进行了解。

我在处理以下情况时遇到问题：我有一个发布者想要上载很多二进制信息（如图像），所以我希望它保存图像并上载路径或...

Answer 1

一旦图像由消费者发布消息FileProcessed处理，并带有与文件有关的信息。负责清理邮件的使用者可以提取该邮件，该使用者将删除文件。