FolkMQ v1.7.8

普通消息

1、介绍

"普通消息",是指生产者发布后,服务端立即进行派发给消费者,并直到最终消费成功为止。

  • 生产者发布消息,会要求服务端给确认(confirm),否则异常提醒
  • 服务端收到消息,并转到队列后,会答复一个接收确认
  • 服务端派发消息,会要求消费者给回执(ack)
    • 如果派发失败,会不断延时重试,直到派发成功为止
  • 消费者消费后,会答复一个消费回执

2、代码演示

发布“普通消息”

//同步
client.publish("demo.topic", new MqMessage("hello"));
//异步
client.publishAsync("demo.topic", new MqMessage("hello"));

发布“二进制”消息

//同步
client.publish("demo.topic", new MqMessage("hello".getBytes()));
//异步
client.publishAsync("demo.topic", new MqMessage("hello".getBytes()));