RocketMQ发消息异常：RemotingTooMuchRequestException: sendDefaultImpl call timeout

分手后的思念是犯贱 2023-10-03 10:49 0阅读 0赞

#### 一、背景 ####

历尽千辛万坑、终于把RocketMQ起起来–[Broker无法启动][Broker]，本以为万事大吉了，直接跑起项目，结果忽如一夜春风来、野火把梨花烧尽了。

一看报错信息是timeout，就差RocketMQ的超时配置，然而并没有用。那么只能使用完成的google/百度大法了。然后一看、结论就是一层窗户纸，不知道就全是坑。

#### 二、完整异常 ####

Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.messaging.MessagingException: sendDefaultImpl call timeout; nested exception is org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout] with root cause
    
    org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
    	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:667) ~[rocketmq-client-4.8.0.jar:4.8.0]
    	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1343) ~[rocketmq-client-4.8.0.jar:4.8.0]
    	at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:344) ~[rocketmq-client-4.8.0.jar:4.8.0]
    	at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:555) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
    	at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:484) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
    	at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:472) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
    	at org.apache.rocketmq.spring.core.RocketMQTemplate.doSend(RocketMQTemplate.java:886) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
    	at org.apache.rocketmq.spring.core.RocketMQTemplate.doSend(RocketMQTemplate.java:57) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
    	at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.2.12.RELEASE.jar:5.2.12.RELEASE]
    	at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:151) ~[spring-messaging-5.2.12.RELEASE.jar:5.2.12.RELEASE]
    	at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:129) ~[spring-messaging-5.2.12.RELEASE.jar:5.2.12.RELEASE]
    	at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:122) ~[spring-messaging-5.2.12.RELEASE.jar:5.2.12.RELEASE]

#### 三、解决方案 ####

##### 1. nameserver #####

name server 启动时 ip修改为你服务器对应公网ip

nohup ./bin/mqnamesrv -n 你的公网IP:9876 &

不要写localhost

##### 2. broker #####

在conf/broker.conf 中 加入以下信息：

brokerIP1=你的公网IP

broker 启动

nohup sh bin/mqbroker -n 你的公网IP:9876 -c conf/broker.conf autoCreateTopicEnable=true &

#### 三、总结 ####

也没啥好总结的，坑比较多，不总结一下又对不起踩的坑。所以嘛，总结完了。