前景:项目使用rabbitmq, 生产者push数据给我, 生产速率蛮高,我想实现1s取一批数据,然后统一ack
我想到的思路(golang语言):
timer := time.NewTimer(1 * time.second) for { <-timer.C // bench ack,批量入库 timer.Reset(time.Seconed) }
问题, 我本身对mq的api不熟悉, 有没有现成的解决api,或者更好的思路?
2.1m questions
2.1m answers
63 comments
56.7k users