RocketMQ生产端消息重试机制的使用方法

本篇内容介绍了"RocketMQ生产端消息重试机制的使用方法"的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

1.可以通过 producer.setRetryTimesWhenSendFailed(count) 来设置生产者发送消息时候失败重试的次数，默认值是2，即失败一次后，会重试两次，总共发送三次消息

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

2.生产者发送消息重试机制

贴上源码，客户端版本号是：3.2.6

# com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl#sendDefaultImplint 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生产端消息重试机制的使用方法"的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站，小编将为大家输出更多高质量的实用文章！