From 3472226abc5dfa94612f4abe125c4662dc62d174 Mon Sep 17 00:00:00 2001 From: quan7u Date: Tue, 14 Jun 2022 10:16:13 +0800 Subject: [PATCH] fix mistake MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 故障策略应该是对队列进行退避选择 --- docs/rocketmq/rocketmq-send-message.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/rocketmq/rocketmq-send-message.md b/docs/rocketmq/rocketmq-send-message.md index a97b890..db50816 100644 --- a/docs/rocketmq/rocketmq-send-message.md +++ b/docs/rocketmq/rocketmq-send-message.md @@ -120,7 +120,7 @@ if (changed) { `MessageQueue mqSelected = this.selectOneMessageQueue(topicPublishInfo, lastBrokerName);` -首先判断是否启用故障延迟机制 ,默认不启用,第一次查询 lastBrokerName 为空,`sendWhichQueue`自增然后对队列个数取模获取队列,如果消息发送失败,下一次`sendWhichQueue`仍然自增然后对队列个数取模,可以规避掉上次失败的 broker +首先判断是否启用故障延迟机制 ,默认不启用,第一次查询 lastBrokerName 为空,`sendWhichQueue`自增然后对队列个数取模获取队列,如果消息发送失败,下一次`sendWhichQueue`仍然自增然后对队列个数取模,可以规避掉上次失败的队列(MessageQueue) ```java public MessageQueue selectOneMessageQueue(final String lastBrokerName) {