H5W3
当前位置:H5W3 > go > 正文

【go】如何实现rabbitmq的单位时间取一批数据,统一ack

前景:
项目使用rabbitmq, 生产者push数据给我, 生产速率蛮高,我想实现1s取一批数据,然后统一ack

我想到的思路(golang语言):

timer := time.NewTimer(1 * time.second)
for {
<-timer.C
// bench ack,批量入库
timer.Reset(time.Seconed)
}

问题, 我本身对mq的api不熟悉, 有没有现成的解决api,或者更好的思路?

回答

本文地址:H5W3 » 【go】如何实现rabbitmq的单位时间取一批数据,统一ack

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址