您的位置:首页 > 大数据 > 人工智能

RocketMq Exception "connect to <:10909> failed"问题

2017-02-10 17:06 1756 查看
之前使用RocketMQ,遇到过“connect to <:10909> failed”问题。最近使用的时候又遇到了。这里总结一下。

1、代码描述



2、异常描述

com.alibaba.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [6542]ms, Topic: TopicTest, BrokersSent: [localhost-241, localhost-241, localhost-241]
...
Caused by: com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <xxx.xxx.xxx.xxx:10909> failed


3、消息发送失败原因以及解决办法

原因分析:我第一次使用的是rocketmq-client-3.4.6,第二次使用的是rocketmq-client-3.5.7,都出现了这个问题。但是原来使用rocketmq-client-3.2.5却不会出现这个问题。

     (1)目前这种写法Rocket默认开启了VIP通道,VIP通道端口为10911-2=10909。若Rocket服务器未启动端口10909,则报connect to <:10909> failed。

     (2)解决方式:增加一行代码

producer.setVipChannelEnabled(false);


4、消费者接收不到消息

     (1)同理,如果消费者能够启动成功,但是没有接收到消息,原因可能同上。

     (2)解决方式:增加一行代码

consumer.setVipChannelEnabled(false);


参考: https://my.oschina.net/bingoding/blog/685079?p=1
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  java rocketmq 异常
相关文章推荐