RocketMQ生產端消息重試機制的使用方法

本篇內容介紹了“RocketMQ生產端消息重試機制的使用方法”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

1.可以通過 producer.setRetryTimesWhenSendFailed(count) 來設置生產者發送消息時候失敗重試的次數，默認值是2，即失敗一次后，會重試兩次，總共發送三次消息

# com.alibaba.rocketmq.client.producer.DefaultMQProducer
private int retryTimesWhenSendFailed = 2;

2.生產者發送消息重試機制

貼上源碼，客戶端版本號是：3.2.6

# com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl#sendDefaultImpl
int timesTotal = 1 + this.defaultMQProducer.getRetryTimesWhenSendFailed();
int times = 0;
String[] brokersSent = new String[timesTotal];
for (; times < timesTotal && (endTimestamp - beginTimestamp) < maxTimeout; times++) {
    String lastBrokerName = null == mq ? null : mq.getBrokerName();
    MessageQueue tmpmq = topicPublishInfo.selectOneMessageQueue(lastBrokerName);
    if (tmpmq != null) {
        mq = tmpmq;
        brokersSent[times] = mq.getBrokerName();
        try {
            sendResult = this.sendKernelImpl(msg, mq, communicationMode, sendCallback, timeout);
            endTimestamp = System.currentTimeMillis();
            switch (communicationMode) {
            case ASYNC:
                return null;
            case ONEWAY:
                return null;
            case SYNC:
                if (sendResult.getSendStatus() != SendStatus.SEND_OK) {
                    if (this.defaultMQProducer.isRetryAnotherBrokerWhenNotStoreOK()) {
                        continue;
                    }
                }

                return sendResult;
            default:
                break;
            }
        }
        catch (Exception e) {
            endTimestamp = System.currentTimeMillis();
            continue;
        }
    }
    else {
        break;
    }
} // end of

“RocketMQ生產端消息重試機制的使用方法”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！