RocketMQ连接异常sendDefaultImpl call timeout

安装并启动好RocketMQ后,在代码中远程连接RocketMQ,报以下错误:

org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException:sendDefaultImpl call timeout at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:588)at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1223)at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1173)at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)at com.flying.demo.Producer.main(Producer.java:25)


这个错误其实是启动RocketMQ的namesrv,broker没有指IP。

假如IP是:192.168.1.135

那么启动namesrv时,用以下方法:

nohup sh bin/mqnamesrv -n "192.168.1.135:9876" &

启动broker时,用以下方法:

修改conf/broker.conf,加入:brokerIP1=192.168.1.135

启动:nohup ./bin/mqbroker -n localhost:9876 -c conf/broker.conf autoCreateTopicEnable=true &

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • MQ在我们日常开发过程中有着不可替代的作用,不仅可以帮助我们做到信息在系统间的传递,还能进行系统间的解耦合,也就是...
    数齐阅读 3,623评论 2 7
  • 1 架构原理 1.1 应用场景 只支持发布订阅模式。 大数据量的消息堆积能力,最终数据是持久化到磁盘上,理论上无限...
    可笑可乐阅读 9,643评论 0 2
  • 方案 因为borker本身需要存储消息信息,所以高可用方案选择主从方式。主从方式可以通过主从同步热备或主从异步热备...
    do_young阅读 8,151评论 0 0
  • 序 本文主要研究一下rocketmq的sendOrderly sendOrderly rocketmq-sprin...
    go4it阅读 1,800评论 0 0
  • 16宿命:用概率思维提高你的胜算 以前的我是风险厌恶者,不喜欢去冒险,但是人生放弃了冒险,也就放弃了无数的可能。 ...
    yichen大刀阅读 7,939评论 0 4

友情链接更多精彩内容