FolkMQ v1.7.8

定时消息(或延时消息)

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));