RocketMQ 生产者发送消息结果

落日映苍穹つ 2023-07-14 10:46 50阅读 0赞
前言：
  1. 当我们使用 同步或者异步发送消息时，成功后，我们得到一个对象 SendResult 对象，其中包含消息发送队列的相关信息。
  2. 其中 枚举 SendStatus 即是本次消息发送的结果。
SendStatus 枚举如下：
  1. public enum SendStatus {
  3.     // 消息发送成功
  4.     SEND_OK,
  6.     // 消息发送成功，但是服务器刷盘超时，消息已经进入服务器队列，只有此时服务器宕机，消息才会丢失
  7.     FLUSH_DISK_TIMEOUT,
  9.     // 消息发送成功，但是服务器同步到 Slave 时超时，消息已经进入服务器队列，只有此时服务器宕机，消息才会丢失 
  10.     FLUSH_SLAVE_TIMEOUT,
  12.     // 消息发送成功，但是此时 slave 不可用，消息已经进入服务器队列，只有此时服务器宕机，消息才会丢
  13.     SLAVE_NOT_AVAILABLE,
  14. }

END!!!

发表评论

表情：
评论列表 （有 0 条评论，50人围观）

还没有评论，来说两句吧...

相关阅读

    相关 RocketMq发送延迟消息

    什么是延迟消息？ 对于消息中间件来说，producer将消息发送到mq的服务器，但并不期望这条消息马上被消费，而是推迟到当前时间点之后的某个时间点后再投递到queue中让

    柔情只为你懂柔情只为你懂/ 0 赞/ 144 阅读

    相关 RocketMQ消息发送篇

    RocketMQ支持3种消息发送方式：同步（sync）、异步（async）、单向（oneway）。 同步：发送者向MQ执行发送消息API时，同步等待，直到消息服务器返回

    朱雀朱雀/ 0 赞/ 312 阅读

    相关 kafka生产者发送消息

    本文简单介绍kafka发送消息一些基础，先上代码，复制粘贴然后根据自己情况改一下ip地址，可直接发消息！！！贼强！！！ package producer;

    短命女短命女/ 0 赞/ 502 阅读