RocketMQ生產(chǎn)端消息重試機(jī)制的使用方法

本篇內(nèi)容介紹了“RocketMQ生產(chǎn)端消息重試機(jī)制的使用方法”的有關(guān)知識，在實(shí)際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

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

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

2.生產(chǎn)者發(fā)送消息重試機(jī)制

貼上源碼，客戶端版本號是：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生產(chǎn)端消息重試機(jī)制的使用方法”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！