rabbitmq 延时消息 计时不准确 是什么原因?

狗贱
  • 133

这是go 写的一个延时处理的考试收卷延时消息
rabbitmq已安装了延时消息插件
examRecord.MyExamination.AnswerTime = 120 分钟

`delayInt := function.GenerateRangeNum(10, 100) //这是一个随机数 71
ExpireTime := strconv.FormatInt(examRecord.MyExamination.AnswerTime601000+int64(delayInt)*1000, 10)
logger.Log(logger.InfoLevel,delayInt)// 值为71
logger.Log(logger.InfoLevel,ExpireTime)// 值为 7271000
body, _ := proto.Marshal(resp.ExamRecord)
if err := h.Broker.Publish(AutomaticHandingInTopic, &broker.Message{
// "delay": ExpireTime 兼容阿里云AMQP
Header: map[string]string{"x-delay": ExpireTime, "delay": ExpireTime},
Body: body,
}, rabbitmq.DeliveryMode(2)); err != nil {
resp.Error = &pb.Error{Description: err.Error()}
}`

以上代码执行后 rabbitmq 会提前几十秒钟执行了,正常应该是7271秒后才执行呀,是因为rabbitmq计时不准确吗?还是什么原因,感觉时间越长,误差就越大,几分钟的时候没有这个情况。

回复
阅读 477
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
你知道吗?

宣传栏