我有几个关于芹菜的问题。
1 芹菜包含生产者和消费者。
Is the task in celery equals to producer?
What is the consumer?
2 我调用一个任务来发送消息。如何在其他地方消费消息？
现在我已经阅读了 celery 和 rabbitmq 的文档。我想用 django 开发一个消息中心。 消息中心是用户可以接收来自其他用户和系统的消息的地方我该如何设计？
【问题讨论】：
这不是正确的方法。
Celery 用于对被消费的消息进行排队/分发。一旦消息被消费，它就永远消失了。
这方面的一个例子是将文档发送到一组打印机。文件被放在队列中。当可以打印时，每台打印机都会从队列中消耗。打印后，它会“确认”将其从队列中永久删除的文档。如果打印机由于某种原因无法打印（墨水用完），它会告诉 celery 它无法处理文档。然后该文档可供其他打印机处理。
将芹菜视为一个队列/流系统。如果您有多个服务器并且需要将消息路由到适当的服务器，则将其用于消息可能是有意义的。
在您的情况下，您需要一个包含fromId、toId、message、date 等的消息数据库表...
这样，用户可以多次看到该消息。
【讨论】：