RocketMQ Send [3] times, still failed，connect to 0.0.1.1:10911 failed_org.apache.rocketmq.client.exception.mqclientexcep

使用RocketMQ遇到的问题：

1. 今天使用rocketmq中，本地写一个demo，半天连不上服务端，记录下这个问题。
2. 启动服务端：

nohup sh bin/mqnamesrv &
1

3. 启动客户端：

nohup sh bin/mqbroker -n localhost:9876 &
1

4. 正常连接后，使用java程序向Producer发送消息

public static void main(String[] args) throws Exception{
        DefaultMQProducer producer = new DefaultMQProducer("product_group_test"); //（1）
        // 初始化一个producer并设置Producer group name
        // 设置NameServer地址
        producer.setNamesrvAddr("127.0.0.1:9876");  //（2）
        // 启动producer
        producer.start();
        System.out.println("启动成功");
//            for (int i = 0; i < 10; i++) {
                // 创建一条消息，并指定topic、tag、body等信息，tag可以理解成标签，对消息进行再归类，RocketMQ可以在消费端对tag进行过滤
                Message msg = new Message("TopicTest", null,
                        ("Hello RocketMQ").getBytes(RemotingHelper.DEFAULT_CHARSET)
                );   //（3）
                // 利用producer进行发送，并同步等待发送结果
        System.out.println("准备发送");
        SendResult sendResult = producer.send(msg);
                //（4）
        System.out.printf("%s%n", sendResult);
//            }

    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

5. 问题出现了

Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [168]ms, Topic: TopicTest

Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to 0.0.1.1:10911 failed

1
2
3
4

6. 一直连接不上生产者，
   声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Cpp五条/article/detail/256957