Spring Boot如何集成Zookeeper（Spring Cloud Zookeeper方案）

前面的文章介绍了Zookeeper: windows下Zookeeper的介绍、下载、安装这篇文章介绍一下Spring Boot如何集成Zookeeper。注意Zookeeper本身没有调用能力只负责服务发现和服务注册本教程借用了RestTemplate实现HTTP调用来验证Zookeeper的服务调用能力 1. 集成方案常见的Spring Boot集成Zookeeper有两种方案方案说明适用场景Spring CloudSpring Cloud 生态的子项目封装了服务发现、配置管理等能力微服务架构需要快速实现服务注册与发现原生 Apache CuratorZooKeeper 官方推荐的 Java 客户端提供更底层的 API需要分布式锁、Leader 选举、精细控制 ZooKeeper 节点本文选的是Spring Cloud ZooKeeper 因为它与 Spring Boot 无缝集成代码量最少。2.环境介绍IDEA :2026.1JDK17maven:3.9.xzookeeper:3.9.5spring boot:3.2.5先启动Zookeeper默认端口号是2181本文项目结构如下zk-demo/ ├── pom.xml ├── zk-demo-provider/ │ ├── pom.xml │ └── src/main/java/com/guo/provider/ │ ├── ProviderApplication.java │ └── controller/ProviderController.java └── zk-demo-consumer/ ├── pom.xml └── src/main/java/com/guo/consumer/ ├── ConsumerApplication.java ├── controller/ConsumerController.java └── config/RestTemplateConfig.java2.创建父工程打开IDEA左上角点击 “文件”—“新建”—“项目”这里左侧选择“Java”名称填 “zk-demo”,构建系统选“Maven”这里JDK选17然后点击”创建“创建项目后界面如下然后右击”src“然后点击”删除“ 父工程没有代码只管配置然后打开父工程的依赖填写下面的依赖参考后面的代码然后刷新一下添加依赖。注意上图中的spring boot版本已经改成3.2.5 此处不能使用高版本的Spring Bootpom文件的依赖内容参考如下?xml version1.0 encodingUTF-8?projectxmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.guo/groupIdartifactIdzk-demo/artifactIdversion1.0-SNAPSHOT/versionpackagingpom/packagingparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion3.2.5/versionrelativePath//parentpropertiesjava.version17/java.versionspring-cloud.version2023.0.0/spring-cloud.version/propertiesdependencyManagementdependenciesdependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-dependencies/artifactIdversion${spring-cloud.version}/versiontypepom/typescopeimport/scope/dependency/dependencies/dependencyManagementdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-zookeeper-discovery/artifactId/dependency/dependencies/project注意只定版本不实际引入。子模块需要自己写依赖可省略版本。实际引入子模块会自动继承无需再写。3.生产者模块3.1 创建生产者模块右击 项目名称点击”新建“然后点击 ”模块“。模块这里左侧选”Java“,然后构建系统选 MavenJDK选17然后点击 创建。下面这里是生产者的pom.xml文件的内容。3.2 编写配置文件右击生产者zk-demo-provide模块的 resources 文件夹点击”新建“然后点击”文件“文件名是application.yml配置文件内容参考如下spring:application:name:provider# 服务名将作为 ZooKeeper 中的节点名cloud:zookeeper:connect-string:localhost:2181# ZooKeeper 地址discovery:enabled:true# 是否启用服务注册register:true# 是否注册当前服务root:/services# 注册的根路径可选server:port:8081#项目的端口下面是配置文件截图的内容。3.3 新增项目结构右击生产者zk-demo-provider模块选择新建然后点击”软件包“软件包的名称为com.guo.provider创建完后项目结构如下3.4 主启动类右击生产者模块zk-demo-provider中的provider文件夹选择”新建“—“Java类”。启动类的名称为ProviderApplication启动类的参考代码如下packagecom.guo.provider;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.client.discovery.EnableDiscoveryClient;SpringBootApplicationEnableDiscoveryClient// 开启服务发现让应用能注册到 ZooKeeperpublicclassProviderApplication{publicstaticvoidmain(String[]args){SpringApplication.run(ProviderApplication.class,args);}}创建完后项目代码和结构如下3.5 业务控制器(Controller)右击生产者中的provider文件夹选择”新建“—“软件包”软件包名称为com.guo.provider.controller创建完后项目结构如下然后右击刚才创建的controller文件夹点击”新建“—“Java类”Java类的名字为ProviderController参考代码如下packagecom.guo.provider.controller;importorg.springframework.beans.factory.annotation.Value;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.PathVariable;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;RestControllerRequestMapping(/provider)publicclassProviderController{Value(${server.port})privateStringport;GetMapping(/info/{id})publicStringgetInfo(PathVariable(id)Integerid){returnProvider: received id id, response from port port;}}4.消费者模块4.1 创建消费者模块右击zk-demo项目选择 ”新建“ ,然后 选择 ”模块“模块名称和类型参考如下创建完后消费者的pom.xml文件参考如下4.2 编写配置文件右击消费者的resources文件夹选择”新建“然后选择”文件“文件名字为application.yml消费者模块的配置内容参考如下spring:application:name:consumercloud:zookeeper:connect-string:localhost:2181# 连接地址discovery:enabled:true# 是否开启服务注册register:true# 是否注册自己root:/services# 根节点server:port:8082#4.3 新增项目结构右击 消费者模块的java 文件夹选择”新建“—“软件包”软件包名称参考是com.guo.consumer创建完后项目结构如下4.4 主启动类右击刚才创建的consumer文件夹选择 ”新建“—“Java类”启动类名为ConsumerApplication启动类参考代码如下packagecom.guo.consumer;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.client.discovery.EnableDiscoveryClient;SpringBootApplicationEnableDiscoveryClientpublicclassConsumerApplication{publicstaticvoidmain(String[]args){SpringApplication.run(ConsumerApplication.class,args);}}4.5 配置RestTemplate(带负载均衡)RestTemplate 是 Spring 提供的同步 HTTP 客户端工具用于Java 程序中调用第三方 / 其他微服务的 HTTP 接口发送 GET、POST 等请求。右击 consumer文件夹选择”新建“—“软件包”软件包的名字为com.guo.consumer.config右击刚才创建的config文件夹选择”新建“——“Java类”这里的类名为RestTemplateConfig这里的参考的代码如下packagecom.guo.consumer.config;importorg.springframework.cloud.client.loadbalancer.LoadBalanced;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.web.client.RestTemplate;ConfigurationpublicclassRestTemplateConfig{BeanLoadBalanced// 使得 RestTemplate 能够使用服务名进行调用并自动负载均衡publicRestTemplaterestTemplate(){returnnewRestTemplate();}}4.6 调用控制器Controller先新建controller文件夹。右击 consumer文件夹中点击”新建“—“软件包”软件包名称为com.guo.consumer.controller然后右击controller文件夹选择”新建“—“Java类”这里的类名为ConsumerControllerConsumerController的参考代码如下packagecom.guo.consumer.controller;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.PathVariable;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;importorg.springframework.web.client.RestTemplate;RestControllerRequestMapping(/consumer)publicclassConsumerController{AutowiredprivateRestTemplaterestTemplate;GetMapping(/call/{id})publicStringcallProvider(PathVariable(id)Integerid){// 使用服务名 provider而不是具体的 IP:端口Stringurlhttp://provider/provider/info/id;// 实际的 HTTP 请求由 RestTemplate 发出ZooKeeper 只负责将 provider 解析为具体地址returnrestTemplate.getForObject(url,String.class);}}5.测试先启动 生产者模块。再启动消费者模块然后打开浏览器访问下面的地址http://localhost:8082/consumer/call/123在浏览器中看懂下面的内容这表明 consumer 通过 ZooKeeper 获取了 provider 的地址然后使用 RestTemplate 发起了真正的 HTTP 调用。参考代码1百度网盘通过网盘分享的文件zookeeper-demo.zip链接: https://pan.baidu.com/s/1v-KSKsoArheqy3_aTSADqA?pwdfywi 提取码: fywi2夸克网盘我用夸克网盘给你分享了「zookeeper-demo.zip」点击链接或复制整段内容打开「夸克APP」即可获取。/6c283b5Ahm链接https://pan.quark.cn/s/6c87938d4e80?pwdLhW6提取码LhW6