我正在通过nodejs中的ampq使用RabbitMQ,并且希望设置一个工作队列来保存一些数据(消息),这些数据(消息)将需要在以后激发一些操作。
我理解RabbitMQ将队列中的所有可用消息分派给可用的使用者,但在我的情况下,我希望某些消息在预定时间到达。
谢谢你的帮助。
我不确定这在RabbitMQ的范围内是否可行,但是您可以使用节点cron在特定时间安排特定队列上的侦听器。例如,我有一个调度程序,它在午夜开始监听队列,并从当天拉出所有消息,然后完全处理这些消息,并清空队列,然后进入静默状态,等待下一次计划的运行。