安科网

Spring Boot 连接 ZooKeeper 注册中心发生异常的排查经历

XuNeely

XuNeely

2020-04-22

关注 关注

排错

使用 Spring Boot 整合 Dubbo + ZooKeeper 的时候，启动 Provider 时发生异常：

Error starting ApplicationContext. To display the conditions report re-run your application with ‘debug‘ enabled.
2020-04-22 10:29:47.822 ERROR 11072 --- [           main] o.s.boot.SpringApplication               : Application run failed

java.lang.IllegalStateException: zookeeper not connected
	at org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient.<init>(CuratorZookeeperClient.java:83) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperTransporter.createZookeeperClient(CuratorZookeeperTransporter.java:26) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.remoting.zookeeper.support.AbstractZookeeperTransporter.connect(AbstractZookeeperTransporter.java:70) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter$Adaptive.connect(ZookeeperTransporter$Adaptive.java) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration.<init>(ZookeeperDynamicConfiguration.java:70) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfigurationFactory.createDynamicConfiguration(ZookeeperDynamicConfigurationFactory.java:37) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.common.config.configcenter.AbstractDynamicConfigurationFactory.lambda$getDynamicConfiguration$0(AbstractDynamicConfigurationFactory.java:39) ~[dubbo-2.7.6.jar:2.7.6]
	at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660) ~[na:1.8.0_251]
	at org.apache.dubbo.common.config.configcenter.AbstractDynamicConfigurationFactory.getDynamicConfiguration(AbstractDynamicConfigurationFactory.java:39) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.common.config.configcenter.DynamicConfiguration.getDynamicConfiguration(DynamicConfiguration.java:223) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.config.bootstrap.DubboBootstrap.prepareEnvironment(DubboBootstrap.java:857) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.config.bootstrap.DubboBootstrap.startConfigCenter(DubboBootstrap.java:603) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.config.bootstrap.DubboBootstrap.useRegistryAsConfigCenterIfNecessary(DubboBootstrap.java:671) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.config.bootstrap.DubboBootstrap.initialize(DubboBootstrap.java:509) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.config.bootstrap.DubboBootstrap.start(DubboBootstrap.java:740) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.config.spring.context.DubboBootstrapApplicationListener.onContextRefreshedEvent(DubboBootstrapApplicationListener.java:59) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.config.spring.context.DubboBootstrapApplicationListener.onApplicationContextEvent(DubboBootstrapApplicationListener.java:52) ~[dubbo-2.7.6.jar:2.7.6]
	at org.apache.dubbo.config.spring.context.OneTimeExecutionApplicationContextEventListener.onApplicationEvent(OneTimeExecutionApplicationContextEventListener.java:40) ~[dubbo-2.7.6.jar:2.7.6]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172) ~[spring-context-5.1.14.RELEASE.jar:5.1.14.RELEASE]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165) ~[spring-context-5.1.14.RELEASE.jar:5.1.14.RELEASE]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139) ~[spring-context-5.1.14.RELEASE.jar:5.1.14.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:402) ~[spring-context-5.1.14.RELEASE.jar:5.1.14.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:359) ~[spring-context-5.1.14.RELEASE.jar:5.1.14.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:896) ~[spring-context-5.1.14.RELEASE.jar:5.1.14.RELEASE]
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.finishRefresh(ServletWebServerApplicationContext.java:162) ~[spring-boot-2.1.13.RELEASE.jar:2.1.13.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:552) ~[spring-context-5.1.14.RELEASE.jar:5.1.14.RELEASE]
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141) ~[spring-boot-2.1.13.RELEASE.jar:2.1.13.RELEASE]
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:744) [spring-boot-2.1.13.RELEASE.jar:2.1.13.RELEASE]
	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:391) [spring-boot-2.1.13.RELEASE.jar:2.1.13.RELEASE]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:312) [spring-boot-2.1.13.RELEASE.jar:2.1.13.RELEASE]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1215) [spring-boot-2.1.13.RELEASE.jar:2.1.13.RELEASE]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1204) [spring-boot-2.1.13.RELEASE.jar:2.1.13.RELEASE]
	at com.touyel.lesson.dubbo.provider.DubboProviderSampleApplication.main(DubboProviderSampleApplication.java:10) [classes/:na]
Caused by: java.lang.IllegalStateException: zookeeper not connected
	at org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient.<init>(CuratorZookeeperClient.java:80) ~[dubbo-2.7.6.jar:2.7.6]
	... 32 common frames omitted

我是使用 docker 搭建的 ZooKeeper 注册中心：

version: ‘3.1‘

services:
  zookeeper:
    image: zookeeper
    container_name: zookeeper
    restart: always
    ports:
      - 2181:2181
  dubbo-admin:
    image: apache/dubbo-admin
    container_name: dubbo-admin
    depends_on:
      - zookeeper
    ports:
      - 9050:8080
    environment:
      - admin.registry.address=zookeeper://zookeeper:2181
      - admin.config-center=zookeeper://zookeeper:2181
      - admin.metadata-report.address=zookeeper://zookeeper:2181

ZooKeeper 是没有什么问题的，那就从代码中寻找问题了。

先看一下抛异常的源码：

java.lang.IllegalStateException: zookeeper not connected
	at org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient.<init>(CuratorZookeeperClient.java:83) ~[dubbo-2.7.6.jar:2.7.6]

[没有下载源码的，最好把源码下载好（下载方式见底部）。](## IDEA 下载源码的方式)

public CuratorZookeeperClient(URL url) {
        super(url);
        try {
            int timeout = url.getParameter(TIMEOUT_KEY, DEFAULT_CONNECTION_TIMEOUT_MS);
            int sessionExpireMs = url.getParameter(ZK_SESSION_EXPIRE_KEY, DEFAULT_SESSION_TIMEOUT_MS);
            CuratorFrameworkFactory.Builder builder = CuratorFrameworkFactory.builder()
                    .connectString(url.getBackupAddress())
                    .retryPolicy(new RetryNTimes(1, 1000))
                    .connectionTimeoutMs(timeout)
                    .sessionTimeoutMs(sessionExpireMs);
            String authority = url.getAuthority();
            if (authority != null && authority.length() > 0) {
                builder = builder.authorization("digest", authority.getBytes());
            }
            client = builder.build();
            client.getConnectionStateListenable().addListener(new CuratorConnectionStateListener(url));
            client.start();
            boolean connected = client.blockUntilConnected(timeout, TimeUnit.MILLISECONDS);
            if (!connected) {
                throw new IllegalStateException("zookeeper not connected");
            }
        } catch (Exception e) {
            throw new IllegalStateException(e.getMessage(), e);
        }
    }

可以发现两行关键代码：

int timeout = url.getParameter(TIMEOUT_KEY, DEFAULT_CONNECTION_TIMEOUT_MS);

boolean connected = client.blockUntilConnected(timeout, TimeUnit.MILLISECONDS);

这里的 TIMEOUT_KEY 就是一个 key：String TIMEOUT_KEY = "timeout";

根据这个 timeout ，推断可能是 timeout 超时时间设置太短，没有时间连接上 ZooKeeper 。

点进去看一下 this.DEFAULT_CONNECTION_TIMEOUT_MS 默认设置的时间：

protected int DEFAULT_CONNECTION_TIMEOUT_MS = 5 * 1000;

根据 client.blockUntilConnected(timeout, TimeUnit.MILLISECONDS); 得出这里的单位为毫秒。那么这里的 timeout 默认设置为 5 秒。

官方文档 schema 配置参考手册/dubbo:registry

到 application.properties 中看一下 timeout 属性：

Spring Boot 连接 ZooKeeper 注册中心发生异常的排查经历

更改 timeout 的默认值为 10秒（仍然连接不上的可以增大时间）：

dubbo.registry.timeout=10000

application.properties

server.port=9001

dubbo.application.name=provider-sample
dubbo.registry.protocol=zookeeper
dubbo.registry.address=zookeeper://192.168.59.130:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
dubbo.registry.timeout=10000
dubbo.scan.base-packages=com.touyel.lesson.dubbo.provider.service

启动项目 ... 启动成功！

Spring Boot 连接 ZooKeeper 注册中心发生异常的排查经历

到 dubbo-admin 看一下：

Spring Boot 连接 ZooKeeper 注册中心发生异常的排查经历

已注册到 ZooKeeper 。

IDEA 下载源码的方式

IDEA 下载源码的方式非常简单，点进源码的时候点击右上角的 Downoad Sources 即可：

Spring Boot 连接 ZooKeeper 注册中心发生异常的排查经历

dubbo display

XuNeely

XuNeely

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

Dubbo中的时间轮(Time Wheel)算法应用

Netty、Quartz、Kafka 以及 Linux 都有定时任务功能。在任务量大、性能要求高的场景，为了将任务存取及取消操作时间复杂度降为 O，会采用时间轮算法。指针周期性跳动，跳动到一个槽位，就执行该槽位的定时任务。需要高效的定时器算法以减少总体中断

ATenhong 2020-10-15

女朋友问我：Dubbo的服务引用过程

本文转载自微信公众号「三太子敖丙」，作者三太子敖丙 。这篇文章我就带着大家再来看看 Dubbo 服务引入全流程，这篇服务引入写完下一篇就要来个全链路打通了，看看大家看完会不会有种任督二脉都被打通的感觉。在写文章的过程中丙还发现官网的一点小问题，下文中会提

supperme 2020-09-08

Java 200+ 面试题补充③ Dubbo 模块

今天 Java 面试粉丝群里，一个一年开发经验的小伙伴只用了三天时间，找了一个 13 薪 1.5 万的工作，真是替他感到开心。高兴之余，让我们来看，今天的内容。本文是 Java 最常见的 200+ 面试题 的第三个补充模块。Dubbo 是一款高性能、轻量级

doctorvian 2020-08-02

上线前一个小时，dubbo这个问题可把我折腾惨了

前因那是一个月黑风高的夜晚，不管有没有圆圆的月亮，都无法解救要加班的我。这就是苦涩的人生啊！那天正好是春节回家的日子，定了晚上的票，然后还是上线的日子。测试在做回归测试的时候，发现一个老功能报错了，什么鬼，都没改过那块代码怎么会出问题？案件疑点重重呀。。。

aNian 2020-08-01

Dubbo不用注册中心实现远程调用的简单用法demo

return "Hello ,liaoyang make you see " + msg;

gaoyongstone 2020-07-05

微服务架构框架？这里为你汇总了15种

2019年有一个统计说，两千家企业里，45%在使用微服务，16%在实验开发和测试微服务架构，24%在学习微服务准备转型，只有剩下的15%的企业没有使用微服务。对于中大型架构系统来说，微服务更加便捷，微服务成为很多企业架构重构的方向，同时也对架构师提出更高的

kongjunlongaa 2020-06-29

Dubbo telnet 命令能做什么？

dubbo 服务发布之后，我们可以利用 telnet 命令进行调试、管理。telnet localhost 20880 //键入回车进入 Dubbo 命令模式。ls -l XxxService：显示服务的方法详细信息列表。

Fightingxr 2020-06-26

spring cloud 知识点

spring cloud 是一系列框架的有序集合。它利用 spring boot 的开发便利性巧妙地简化了分布式系统基础设施的开发，如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等，都可以用 spring boot 的开发风格做到一键启动和

whileinsist 2020-06-24

Dubbo-扩展机制-SPI

从上面可以看出Java中的SPI最大的缺点是会加载一些不必要的组件。ExtensionLoader类是扩展加载器，这是dubbo实现SPI扩展机制等核心，几乎所有实现的逻辑都被封装在ExtensionLoader中

doctorvian 2020-06-16

Dubbo-URL、数据包结构

在 dubbo 中，也使用了类似的 URL，主要用于在各个扩展点之间传递数据，组成此 URL 对象的具体参数如下:. 基于扩展点自适应机制，通过 URL 的 registry:// 协议头识别，就会调用 RegistryProtocol 的 export(

XuNeely 2020-06-16

Dubbo-服务提供者初始化

事件发布，执行onApplicationEvent，开始执行ServiceBean暴露export操作。当Spring容器处理完<dubbo:service>标签后，会在Spring容器中生成一个ServiceBean ，服务的发布也会在Ser

wangyangsoftware 2020-06-16

Dubbo-服务暴露流程

zk节点上生成providers节点的过程。// FIXME When the provider subscribes, it will affect the scene : a certain JVM exposes the service and ca

大步流星 2020-06-16

Dubbo-服务消费者远程调用

* 这里输入编号 3，让 Arthas 关联到启动类为 com.....Consumer 的 Java 进程上。* 3. 由于 Demo 项目中只有一个服务接口，因此此接口的代理类类名为 proxy0，此时使用 sc 命令搜索这个类名。public cla

aNian 2020-06-16

涂鸦智能 dubbo-go 亿级流量的实践与探索

潘天颖，Github ID @pantianying，开源爱好者，就职于涂鸦智能。dubbo 是一个基于 Java 开发的高性能的轻量级 RPC 框架，dubbo 提供了丰富的服务治理功能和优秀的扩展能力。而 dubbo-go 在 java 与 golan

gaoyongstone 2020-06-16

9.实战交付一套dubbo微服务到k8s集群(2)之Jenkins部署

[200 ~]# ssh-keygen -t rsa -b 2048 -C "" -N "" -f /root/.ssh/id_rsa

MartellJenkins 2020-06-11

Dubbo学习

前言为什么要学Dubbo什么是RPCDubbo的产生背景单一应用架构垂直应用架构分布式服务架构流动计算架构Dubbo面临的需求Dubbo的架构Demo time新建一个maven项目提供服务的API提供服务的provider消费服务的consumer参考。

范群松 2020-06-11

Dubbo 迈出云原生重要一步 - 应用级服务发现解析

社区版本 Dubbo 从 2.7.5 版本开始，新引入了一种基于实例（应用）粒度的服务发现机制，这是我们为 Dubbo 适配云原生基础设施的一步重要探索。在最开始的社区版本，我们给这个机制取了一个神秘的名字 - 服务自省，下文将进一步解释这个名字的由来，并

Fightingxr 2020-06-08

线程隔离浅析

随着微服务的流行，单体应用被拆分成一个个独立的微进程，可能一个简单的请求，需要多个微服务共同处理，这样其实是增加了出错的概率，所以如何保证在单个微服务出现问题的时候，对整个系统的负面影响降到最低，这就需要用到我们今天要介绍的线程隔离。connection在

XuNeely 2020-06-07

SPI

SPI 全称为 Service Provider Interface，是一种服务发现机制。SPI 的本质是将接口实现类的全限定名配置在文件中，并由服务加载器读取配置文件，加载实现类。正因此特性，我们可以很容易的通过 SPI 机制为我们的程序提供拓展功能。D

大步流星 2020-06-05

[dubbo学习] 简单的dubbo功能

生产者-消费者模型，生产者和消费者都需要在注册中心进行注册，生产者生产接口，通过api暴露给消费者使用。服务消费者在启动时，在注册中心订阅自己所需的服务。注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。服务消费

gaoyongstone 2020-06-05
XuNeely

XuNeely

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号