开发者社区 > 云原生 > 云消息队列 > 正文

RocketMQ发送消息返回错误,想问问rejectRequest 还有其他地方影响吗?

RocketMQ发送消息返回错误:[REJECTREQUEST]system busy, start flow control for a while,1> broker中putMessages in lock cost time 没有大于500ms的,2> PutMessageDistributeTime统计中 500ms-1s的为0,3>TransientStorePool only remain
未出现此日志 想问问rejectRequest 还有其他地方影响吗?

展开
收起
2401。 2023-08-27 16:53:33 164 0
1 条回答
写回答
取消 提交回答
  • RocketMQ 发送消息返回错误,如果设置了 rejectRequest,那么会把该消息放回消息队列中,供下一次消费。

    如果没有设置 rejectRequest,那么该消息会被默认丢弃。

    具体来说,当你调用 send() 方法发送消息时,如果消息发送成功,那么 send() 方法会返回 null。如果消息发送失败,那么 send() 方法会返回一个 SendResult 对象。

    这个 SendResult 对象有一个 sendStatus 字段,表示消息发送的状态。如果 sendStatus 为 SEND_OK,那么消息发送成功。如果 sendStatus 为 SEND_FAIL,那么消息发送失败。

    2023-09-13 14:58:02
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载