[Java] 请教一个阿里云消息队列延时消息的问题,设置延时消息无效。

设置了消息延时发送,但是被消费者服务立即消费了。
请问论坛中有没有人遇到过相同的问题,是如何解决的,或者有什么解决的思路?
延时发送的代码:

long sendTime = System.currentTimeMillis() + delayTime;
msg.setStartDeliverTime(sendTime);
SendResult sendResult = producer.send(msg);

生产者发送日志如图:
生产者发送日志

消息轨迹如图:
消息轨迹

日志里的时间和消息轨迹里的生产时间不同是因为 debug ;
之前的项目里这样处理是没有问题的,新的项目需要使用这个业务的时候发现了这个 bug 。


目前已排除的影响因素:

  1. ONS 的 MAVEN 版本,1.8.0 VS 1.8.8.1 都无法延时推送消息;
  2. 服务多实例,但是将其它实例停掉,还是无法延时推送;

发表评论

您的电子邮箱地址不会被公开。