ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

Zookeeper异常org.apache.zookeeper.KeeperException$ConnectionLossException

2021-02-04 11:01:04  阅读:218  来源: 互联网

标签:Zookeeper java ConnectionLossException zookeeper KeeperException 参数 apache org


环境:

VMware + CentOS 7
Zookeeper3.5.5

本地IDEA代码:

package com.veeja;

import org.apache.zookeeper.*;

import java.io.IOException;

/**
 * @Author veeja
 * 2021/2/4 9:49
 */
public class SendContent {
    public static void main(String[] args) {

        try {
            /*
             * 创建Zookeeper对象:
             * 参数1 :Zookeeper ip+端口号
             * 参数2 :访问超时设置
             * 参数3 :通过观察者模式发出访问回复:当连接成功后,编写成功信息
             */
            ZooKeeper zookeeper = new ZooKeeper("192.168.152.128:2181", 100 * 1000, new Watcher() {
                @Override
                public void process(WatchedEvent watchedEvent) {
                    System.out.println("获取连接");
                }
            });

            /**
             * 发送内容 向Zookeeper服务器中
             *      参数1:发送的文件
             *      参数2:发送的内容
             *      参数3:权限
             *      参数4:内容的模式
             */
            String content = zookeeper.create(
                    "/demo/rmi-address",
                    "rmi:localhost:8080/demoService".getBytes(),
                    ZooDefs.Ids.OPEN_ACL_UNSAFE,
                    CreateMode.PERSISTENT_SEQUENTIAL);

            System.out.println("content = " + content);

        } catch (IOException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (KeeperException e) {
            e.printStackTrace();
        }
    }
}

报错信息:

org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /demo/rmi-address
	at org.apache.zookeeper.KeeperException.create(KeeperException.java:102)
	at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
	at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:1538)
	at com.veeja.SendContent.main(SendContent.java:35)

解决方案:

关闭防火墙。

# 查看防火墙的状态:
baisystemctl status firewalld.service

# 关闭防火墙
systemctl stop firewalld.service

# 永久关闭防火墙
systemctl disable firewalld.service

标签:Zookeeper,java,ConnectionLossException,zookeeper,KeeperException,参数,apache,org
来源: https://blog.csdn.net/u014565127/article/details/113629576

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有