RocketMQ访问connect to <192.168.0.56:10909> failed错误

在将RocketMQ启动成功后,通过Java客户端程序连接时,抛出如下错误: org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [9495]ms, Topic: TopicQuickStart, BrokersSent: [localhost.localdomain, localhost.localdomain, localhost.localdomain] ...Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.0.56:10909> failed

在将RocketMQ启动成功后,通过Java客户端程序连接时,抛出如下错误:

org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [9495]ms, Topic: TopicQuickStart, BrokersSent: [localhost.localdomain, localhost.localdomain, localhost.localdomain]
See https://rocketmq.apache.org/docs/faq/ for further details.
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:544)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1069)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1023)
at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
at com.huangx.rocketmq.Producer.main(Producer.java:18)
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to  failed
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:388)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:351)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:335)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:298)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:696)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:463)
... 4 more

解决办法:

第一步:使用telnet连接一下服务器,看看服务器是否能够正常连接。如果不能,去配置防火墙。

第二步:看看你是否开启VIP通道,如下代码:

/*
** 目前这种写法Rocket默认开启了VIP通道,VIP通道端口为10911-2=10909。
** 若Rocket服务器未启动端口10909,则报connect to  failed。
** 增加一行代码
*/
producer.setVipChannelEnabled(false);

消息消费者同样需要添加这条语句。到这里,问题就解决了。

谁不会休息,谁就不会工作。 —— 列宁
0 不喜欢
说说我的看法 -
全部评论(
没有评论
关于
本网站专注于 Java、数据库(MySQL、Oracle)、Linux、软件架构及大数据等多领域技术知识分享。涵盖丰富的原创与精选技术文章,助力技术传播与交流。无论是技术新手渴望入门,还是资深开发者寻求进阶,这里都能为您提供深度见解与实用经验,让复杂编码变得轻松易懂,携手共赴技术提升新高度。如有侵权,请来信告知:hxstrive@outlook.com
其他应用
公众号