- 查看zookeeper服务器的防火墙
systemctl status firewalld # 如果状态处于running ,执行下面的指令 systemctl stop firewalld # 关闭防火墙
重新运行程序,看问题是否解决 ,没有解决执行第二步
- 修改 sessionTimeout时间
zooKeeper = new ZooKeeper("192.168.1.19 ", 20000000, new Watcher() {
@Override
public void process(WatchedEvent watchedEvent) {
System.out.println("watcher");
}
});
分析:
new ZooKeeper()的第二个参数表示sessionTimeout,指的是会话超时时间,设置的太小会导致会话提前关闭,进而程序报错。可以根据自己电脑的性能,适度调节sessionTimeout的大小
-
最终结果
测试通过,数据插入成功



