对一批数据做异步分批处理,用 MQ 做的话,消费者每次从 redis/数据库中拿一批数据处理,如果还有数据没处理完,发布下一个分批处理的消息。
感觉 MQ 更适合做那种一次性的任务,这种消费者 /生产者循环的使用,适合嘛。