定时消息(或延时消息)
1、介绍
“定时消息”,是在 “普通消息” 的基础上,要求服务端在指定时间派发给消费者。
- 生产者发布消息,会要求服务端给确认(confirm),否则异常提醒
- 服务端收到消息,并转到队列后,会答复一个接收确认
- 服务端在指定时间开始派发消息,会要求消费者给回执(ack)
- 如果派发失败,会不断延时重试,直到派发成功为止
- 消费者消费后,会答复一个消费回执
2、代码演示
let scheduled = new Date(System.currentTimeMillis() + 5000;
//同步
client.publish("demo.topic", new MqMessage("hello").scheduled(scheduled));
//异步
client.publishAsync("demo.topic", new MqMessage("hello").scheduled(scheduled));