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 252 分享 版权
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-learning.com/

还有其他疑问?
咨询AI助理