环境:mac

在使用rocketmq的demo发送消息时,一直报如下错误

Exception in thread "main" org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:640)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1310)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1256)
    at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:339)
    at com.daiyanping.cms.rocketmq.nativeapi.ordermessage.all.ProducerAllOrder.main(ProducerAllOrder.java:23)

 

已经加了brokerIP1=127.0.0.1 的配置项,但是就是不行

 

然后把发送消息的代码加了个超时时间就可以了

SendResult sendResult = producer.send(msg, 100000);

org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout

结果:

org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout

相关文章:

  • 2021-05-28
  • 2022-12-23
  • 2022-02-22
  • 2021-06-23
  • 2022-12-23
  • 2021-09-30
  • 2022-03-08
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2021-11-10
  • 2021-05-27
  • 2021-08-28
  • 2022-01-28
  • 2021-11-27
相关资源
相似解决方案