The use of message retry Mechanism on RocketMQ production side
This article introduces the relevant knowledge of "how to use the message retry mechanism on the production side of RocketMQ". In the operation of actual cases, many people will encounter this dilemma, so let the editor lead you to learn how to deal with these situations. I hope you can read it carefully and be able to achieve something!
1. You can use producer.setRetryTimesWhenSendFailed (count) to set the number of failed retries when the producer sends a message. The default value is 2, that is, after a failure, it will retry twice, sending a total of three messages # com.alibaba.rocketmq.client.producer.DefaultMQProducerprivate int retryTimesWhenSendFailed = 2 * 2. Producer send message retry mechanism
Affix the source code, the client version number is: 3.2.6
# com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl#sendDefaultImplint timesTotal = 1 + this.defaultMQProducer.getRetryTimesWhenSendFailed (); int times = 0 endTimestamp 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 "how to use the message retry mechanism on the production side of RocketMQ", thank you for reading. If you want to know more about the industry, you can follow the website, the editor will output more high-quality practical articles for you!
