php - 安排许多作业按时间戳执行

Question

我有一个生产者，它从 Twitter 流中读取数据并使用 rabbitmq 作为消息代理将任务放在队列中。

作业通常需要大约 3-5 秒才能执行，在作业结束时我会在完成时通知用户。但是，我也想在他们完成工作后的 10 分钟/30 分钟/60 分钟内通过向用户发送更多消息来提醒他们。

我想不出安排这些额外消息的最佳方式。我想创建 cron 作业以在那些特定的时间戳运行消息脚本，但是对于每小时数千个作业来说这似乎是错误的。另一个想法是运行一个守护进程，该守护进程将轮询数据库或从队列中读取并在发送之前检查计划的时间戳和当前时间。

理想情况下，如果这可以通过延迟消息在消息代理端完成，它会使它更干净，但我读到 RabbitMQ 不支持类似的东西。

安排许多需要按时间戳执行的作业的最佳方法是什么？

Answer 1

只需创建一个每分钟运行一次的 cron 作业并检查另一个队列，该队列具有消息发送时间的时间戳。当时间戳过去时，发送消息并从队列中删除项目。