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

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

一、背景

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

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

二、完整异常

  1. 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
  3. org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
  4.     at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:667) ~[rocketmq-client-4.8.0.jar:4.8.0]
  5.     at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1343) ~[rocketmq-client-4.8.0.jar:4.8.0]
  6.     at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:344) ~[rocketmq-client-4.8.0.jar:4.8.0]
  7.     at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:555) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
  8.     at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:484) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
  9.     at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:472) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
  10.     at org.apache.rocketmq.spring.core.RocketMQTemplate.doSend(RocketMQTemplate.java:886) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
  11.     at org.apache.rocketmq.spring.core.RocketMQTemplate.doSend(RocketMQTemplate.java:57) ~[rocketmq-spring-boot-2.2.0.jar:2.2.0]
  12.     at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.2.12.RELEASE.jar:5.2.12.RELEASE]
  13.     at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:151) ~[spring-messaging-5.2.12.RELEASE.jar:5.2.12.RELEASE]
  14.     at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:129) ~[spring-messaging-5.2.12.RELEASE.jar:5.2.12.RELEASE]
  15.     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

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

不要写localhost

2. broker

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

  1. brokerIP1=你的公网IP

broker 启动

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

三、总结

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

发表评论

表情：
评论列表 （有 0 条评论，116人围观）

还没有评论，来说两句吧...

相关阅读