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