AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Dubbo新版本zk注册中心连接问题

2023-02-22 589
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
注册配置 MSE Nacos/ZooKeeper，118元/月
云原生网关 MSE Higress，422元/月
服务治理 MSE Sentinel/OpenSergo，Agent数量 不受限
简介： 目录一、使用zkclient作为zk连接客户端问题1、Maven依赖如下2、服务提供者配置文件3、启动服务提供者4、原因分析5、解决办法(1)降低dubbo版本(2)添加ZookeeperTransporter拓展实现二、使用curator作为zk连接客户端版本问题1、Maven依赖如下2、服务提供者配置文件3、启动服务提供者4、curator作为zk连接客户端可行依赖三、总结

目录

一、使用zkclient作为zk连接客户端问题

1、Maven依赖如下

2、服务提供者配置文件

3、启动服务提供者

4、原因分析

5、解决办法

(1)降低dubbo版本

(2)添加ZookeeperTransporter拓展实现

二、使用curator作为zk连接客户端版本问题

1、Maven依赖如下

2、服务提供者配置文件

3、启动服务提供者

4、curator作为zk连接客户端可行依赖

三、总结

一、使用zkclient作为zk连接客户端问题


1、Maven依赖如下

    <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.8</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.11</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                </exclusion>
            </exclusions>
        </dependency>


我部署的zookeeper版本为3.4.14，因此客户端版本也是选用的3.4.14，dubbo选用的是目前新版本。

2、服务提供者配置文件

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    <dubbo:application name="dubbo-demo-provider"/>
    <!--使用zk作为注册中心时，默认使用curator作为客户端-->
    <dubbo:registry address="zookeeper://localhost:2181" client="zkclient"/>
    <dubbo:protocol name="dubbo" port="20890"/>
    <dubbo:service interface="com.netease.dubbo.service.DubboDemoService" ref="dubboDemoService"/>
    <bean id="dubboDemoService" class="com.netease.dubbo.service.impl.DubboDemoServiceImpl"/>
</beans>

3、启动服务提供者

public class XmlDubboProvider {
  public static void main(String[] args) throws IOException {
    ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:dubbo/dubbo-provider.xml");
    context.start();
    System.in.read();
  }
}


启动服务提供者后报错了，堆栈信息如下：

Exception in thread "main" java.lang.IllegalStateException: No such extension org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter by name zkclient
  at org.apache.dubbo.common.extension.ExtensionLoader.findException(ExtensionLoader.java:623)
  at org.apache.dubbo.common.extension.ExtensionLoader.createExtension(ExtensionLoader.java:630)
  at org.apache.dubbo.common.extension.ExtensionLoader.getExtension(ExtensionLoader.java:429)
  at org.apache.dubbo.common.extension.ExtensionLoader.getExtension(ExtensionLoader.java:413)
  at org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter$Adaptive.connect(ZookeeperTransporter$Adaptive.java)
  at org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration.<init>(ZookeeperDynamicConfiguration.java:56)
  at org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfigurationFactory.createDynamicConfiguration(ZookeeperDynamicConfigurationFactory.java:37)
  at org.apache.dubbo.common.config.configcenter.AbstractDynamicConfigurationFactory.lambda$getDynamicConfiguration$0(AbstractDynamicConfigurationFactory.java:39)
  at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
  at org.apache.dubbo.common.config.configcenter.AbstractDynamicConfigurationFactory.getDynamicConfiguration(AbstractDynamicConfigurationFactory.java:39)
  at org.apache.dubbo.common.config.configcenter.DynamicConfiguration.getDynamicConfiguration(DynamicConfiguration.java:224)
  at org.apache.dubbo.config.bootstrap.DubboBootstrap.prepareEnvironment(DubboBootstrap.java:1034)
  at org.apache.dubbo.config.bootstrap.DubboBootstrap.startConfigCenter(DubboBootstrap.java:623)
  at org.apache.dubbo.config.bootstrap.DubboBootstrap.initialize(DubboBootstrap.java:521)
  at org.apache.dubbo.config.bootstrap.DubboBootstrap.start(DubboBootstrap.java:896)
  at org.apache.dubbo.config.spring.context.DubboBootstrapApplicationListener.onContextRefreshedEvent(DubboBootstrapApplicationListener.java:59)
  at org.apache.dubbo.config.spring.context.DubboBootstrapApplicationListener.onApplicationContextEvent(DubboBootstrapApplicationListener.java:52)
  at org.apache.dubbo.config.spring.context.OneTimeExecutionApplicationContextEventListener.onApplicationEvent(OneTimeExecutionApplicationContextEventListener.java:40)
  at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
  at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
  at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
  at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:404)
  at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:361)
  at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:898)
  at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:554)
  at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:144)
  at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:85)
  at com.netease.dubbo.provider.XmlDubboProvider.main(XmlDubboProvider.java:14)

Exception in thread "main" java.lang.IllegalStateException: No such extension org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter by name zkclient


看异常信息第一行，提示的是没有名为zkclient的拓展信息，dubbo官方文档有关于拓展点加载和SPI实现的说明，如下：

WechatIMG115533.jpeg

而根据第一行异常提示，ZookeeperTransporter也是属于拓展点，只是在官方文档上并没有说明。


既然是拓展点，那么根据dubbo官方文档说明在引入的dubbo依赖下的META-INF/dubbo目录肯定会有相关拓展实现类信息，打开duboo依赖目录可以看到很多拓展点信息，internel目录下的都为dubbo自带的，如下：

WechatIMG115534.jpegWechatIMG115535.jpeg

继续往下拉，看到了我们想要的东西：WechatIMG115536.jpeg

从该文件中看出，目前最新的dubbo 2.7.8版本ZookeeperTransporter的实现只有curator，也就是说目前我们使用zkclient作为zk连接客户端是行不通的。


5、解决办法

(1)降低dubbo版本

如果我们硬是要用zkclient作为zk连接客户端，也是可以的，最简单的办法把dubbo版本降到2.7.0，因为2.7.0版本内置了zkclient的拓展实现，如下：

WechatIMG115537.jpegWechatIMG115538.jpeg

降低dubbo依赖，重新启动程序，成功连接到zk。

    <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
        </dependency>
    <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.11</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                </exclusion>
            </exclusions>
        </dependency>


(2)添加ZookeeperTransporter拓展实现

从上面解决方案截图中可以看看到，在apache dubbo 2.7.0中是有zkclient实现源码的。如果我们要在dubbo最新版本中使用zkclient，可以把代码搬过去，依葫芦画瓢，在类路径下新建META-INF/dubbo目录。然后新建一个文件，文件名为ZookeeperTransporter的全限定类名，最后添加客户端名称和实现类映射，如下：

WechatIMG115539.jpeg

二、使用curator作为zk连接客户端版本问题


1、Maven依赖如下

    <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.8</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
        </dependency>
      <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>5.1.0</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                </exclusion>
            </exclusions>
        </dependency>


curator版本为当前最新版5.1.0，dubbo也是当前最新版本2.7.8。

2、服务提供者配置文件

dubbo新版本默认使用curator作为zk连接客户端，配置文件内容如下：

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    <dubbo:application name="dubbo-demo-provider"/>
    <!--使用zk作为注册中心时，默认使用curator作为客户端，若要使用zkclient需自行拓展-->
    <dubbo:registry address="zookeeper://localhost:2181" client="curator"/>
    <dubbo:protocol name="dubbo" port="20890"/>
    <dubbo:service interface="com.netease.dubbo.service.DubboDemoService" ref="dubboDemoService"/>
    <bean id="dubboDemoService" class="com.netease.dubbo.service.impl.DubboDemoServiceImpl"/>
</beans>


3、启动服务提供者

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/zookeeper/admin/ZooKeeperAdmin
  at org.apache.curator.framework.CuratorFrameworkFactory.<clinit>(CuratorFrameworkFactory.java:65)
  at org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient.<init>(CuratorZookeeperClient.java:66)
  at org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperTransporter.createZookeeperClient(CuratorZookeeperTransporter.java:26)
  at org.apache.dubbo.remoting.zookeeper.support.AbstractZookeeperTransporter.connect(AbstractZookeeperTransporter.java:70)

WechatIMG115540.jpeg

一瞧就发现问题点了，原来高版本的curator不兼容zk 3.4.x的版本，如果要兼容需将curator版本降低至4.2.0，改完依赖后继续启动。

Exception in thread "main" java.lang.IllegalStateException: zookeeper not connected
  at org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient.<init>(CuratorZookeeperClient.java:83)
  at org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperTransporter.createZookeeperClient(CuratorZookeeperTransporter.java:26)
  at org.apache.dubbo.remoting.zookeeper.support.AbstractZookeeperTransporter.connect(AbstractZookeeperTransporter.java:70)


2020-10-23 23:05:52.959 INFO  [main-SendThread(localhsot:2181)] [org.apache.zookeeper.ClientCnxn] - Opening socket connection to server localhsot/localhsot:2181. Will not attempt to authenticate using SASL (unknown error)
2020-10-23 23:05:52.961 INFO  [main] [org.apache.curator.framework.imps.CuratorFrameworkImpl] - Default schema
2020-10-23 23:05:52.992 INFO  [main-SendThread(localhsot:2181)] [org.apache.zookeeper.ClientCnxn] - Socket connection established to localhsot/localhsot:2181, initiating session
2020-10-23 23:05:53.084 INFO  [main-SendThread(localhsot:2181)] [org.apache.zookeeper.ClientCnxn] - Session establishment complete on server localhsot/localhsot:2181, sessionid = 0x10634c6160d017d, negotiated timeout = 40000
2020-10-23 23:05:53.093 INFO  [main-EventThread] [org.apache.curator.framework.state.ConnectionStateManager] - State change: CONNECTED

4、curator作为zk连接客户端可行依赖

    <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.8</version>
        </dependency>
    <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.12</version>
        </dependency>
        <!--dubbo目前版本默认使用curator作为客户端，curator4.2.0版本刚好兼容zk 3.4.12及以下版本-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                </exclusion>
            </exclusions>
        </dependency>


三、总结


新版本dubbo已经不使用zkclient最为zk连接客户端，默认使用curator，这点在dubbo官方文档上没有写清楚，可能是文档没更新的原因，官方文档如下：WechatIMG115541.jpeg

当使用curator时，一定要注意引入的curator版本，服务器上部署的zk版本及引入的zk客户端版本需一致，不然会出现缺类或者zk连不上的问题。



文章标签：
微服务引擎
Java
应用服务中间件
Dubbo
Apache
Maven
关键词：
Dubbo版本
Dubbo注册
Dubbo zk
Dubbo连接
Dubbo zk注册中心
相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作，您将了解并实现在线业务的微服务全链路灰度能力。
Nick说说前后端
目录
相关文章
阿里云云原生
|
2月前
|
Dubbo 安全 应用服务中间件
Apache Dubbo 正式发布 HTTP/3 版本 RPC 协议，弱网效率提升 6 倍
在 Apache Dubbo 3.3.0 版本之后，官方推出了全新升级的 Triple X 协议，全面支持 HTTP/1、HTTP/2 和 HTTP/3 协议。本文将围绕 Triple 协议对 HTTP/3 的支持进行详细阐述，包括其设计目标、实际应用案例、性能测试结果以及源码架构分析等内容。
阿里云云原生
195 7
mzlogin
|
3月前
|
Dubbo 应用服务中间件 Apache
Dubbo 应用切换 ZooKeeper 注册中心实例，流量无损迁移
如果 Dubbo 应用使用 ZooKeeper 作为注册中心，现在需要切换到新的 ZooKeeper 实例，如何做到流量无损？
mzlogin
39 4
java冯坚持
|
3月前
|
监控 Dubbo Java
dubbo学习三：springboot整合dubbo+zookeeper，并使用dubbo管理界面监控服务是否注册到zookeeper上。
这篇文章详细介绍了如何将Spring Boot与Dubbo和Zookeeper整合，并通过Dubbo管理界面监控服务注册情况。
java冯坚持
196 0
dubbo学习三：springboot整合dubbo+zookeeper，并使用dubbo管理界面监控服务是否注册到zookeeper上。
java冯坚持
|
3月前
|
Dubbo IDE Java
dubbo学习二：下载Dubbo-Admin管理控制台，并分析在2.6.1及2.6.1以后版本的变化
这篇文章是关于如何下载和部署Dubbo管理控制台（dubbo-admin）的教程，并分析了2.6.1版本及以后版本的变化。
java冯坚持
117 0
dubbo学习二：下载Dubbo-Admin管理控制台，并分析在2.6.1及2.6.1以后版本的变化
服务端技术栈
|
5月前
|
Dubbo 网络协议 Java
深入掌握Dubbo服务提供者发布与注册原理
该文章主要介绍了Dubbo服务提供者发布与注册的原理，包括服务发布的流程、多协议发布、构建Invoker、注册到注册中心等过程。
服务端技术栈
60 0
深入掌握Dubbo服务提供者发布与注册原理
好奇的菜鸟
|
7月前
|
前端开发 Java Maven
dubbo-admin安装(分离版本)
dubbo-admin安装(分离版本)
好奇的菜鸟
64 0
程序员半支烟
|
8月前
|
Dubbo Java 应用服务中间件
深度剖析：Dubbo使用Nacos注册中心的坑
2020年笔者在做微服务部件升级时，Dubbo的注册中心从Zookeeper切换到Nacos碰到个问题，最近刷Github又有网友提到类似的问题，就在这篇文章里做个梳理和总结。
程序员半支烟
340 0
深度剖析：Dubbo使用Nacos注册中心的坑
洛神灬殇
|
8月前
|
Dubbo Cloud Native 应用服务中间件
【Dubbo3 终极特性】「云原生三中心架构」带你探索 Dubbo3 体系下的配置中心和元数据中心、注册中心的原理及开发实战（中）
【Dubbo3 终极特性】「云原生三中心架构」带你探索 Dubbo3 体系下的配置中心和元数据中心、注册中心的原理及开发实战（中）
洛神灬殇
272 1
vohelon
|
8月前
|
负载均衡 Dubbo Java
Dubbo 挂载到 Spring Cloud 注册中心
【2月更文挑战第12天】Dubbo 挂载到 Spring Cloud 注册中心
vohelon
99 7
洛神灬殇
|
8月前
|
XML Dubbo Java
【Dubbo3高级特性】「框架与服务」 Nacos作为注册中心-服务分组及服务分组聚合实现
【Dubbo3高级特性】「框架与服务」 Nacos作为注册中心-服务分组及服务分组聚合实现
洛神灬殇
293 0

热门文章

最新文章

  • 1
    【SpringCloud Alibaba系列】Dubbo高级特性篇
  • 2
    【SpringCloud Alibaba系列】Dubbo基础入门篇
  • 3
    【SpringCloud Alibaba系列】Dubbo dubbo-admin安装教程篇
  • 4
    Dubbo的Zookeeper单机配置和Zookeeper集群配置
  • 5
    Dubbo入门
  • 6
    高并发架构系列：如何从0到1设计一个类Dubbo的RPC框架
  • 7
    Dubbo与Zookeeper、SpringMVC整合和使用（负载均衡、容错）（转）
  • 8
    动态加载 dubbo spring
  • 9
    微服务工程消费dubbo服务的配置
  • 10
    Dubbo服务治理之灰度发布方案（版本发布控制影响范围）
  • 1
    SpringCloudAlibaba:3.1dubbo
    147
  • 2
    SpringCloudAlibaba:3.2dubbo的高级特性
    80
  • 3
    Spring Cloud Dubbo: 微服务通信的高效解决方案
    203
  • 4
    秒懂Dubbo接口（原理篇）
    279
  • 5
    SpringCloud和Dubbo有哪些区别
    159
  • 6
    微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
    967
  • 7
    Java从入门到精通：3.2.2分布式与并发编程——了解分布式系统的基本概念，学习使用Dubbo、Spring Cloud等分布式框架
    571
  • 8
    Dubbo管理控制台
    58
  • 9
    原来Dubbo中的缓存玩的这么花
    163
  • 10
    超越接口：探索Dubbo的泛化调用机制
    455

    • 相关课程

    更多
  • Dubbo + ZooKeeper 的服务发现最佳实践
  • Dubbo 3.0 服务治理最佳实践
  • Dubbo开源、自研、商业化三位一体战略解读
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • Dubbo分布式服务治理实战
  • 微服务实战-服务注册中心 - Nacos

    • 相关电子书

    更多
  • Dubbo开源现状与2.7规划
  • Dubbo分布式服务治理实战
  • 《Dubbo 3.0 前瞻》

    • 相关实验场景

    更多
  • 基于MSE-Nacos实现服务的动态发现和配置动态管理
  • 快速玩转Dubbo生态之一致性事务篇（Seata）
  • 快速玩转Dubbo生态之限流降级篇（Sentinel）
  • 快速上手使用Dubbo进行远程调用
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月