1.什么是Spring Cloud Zookeeper ?
Spring Cloud Zookeeper 是一个用于构建分布式系统的工具,它利用 Apache Zookeeper 提供的服务来实现服务注册与发现、配置管理、负载均衡等功能。具体来说,Spring Cloud Zookeeper 可以做以下几件事情:
-
服务注册与发现:通过 Zookeeper,微服务可以在启动时将自己注册到 Zookeeper 中,其他服务可以通过 Zookeeper 查找并调用这些服务。
-
配置管理:Spring Cloud Zookeeper 可以集中管理应用程序的配置,允许开发者在 Zookeeper 中存储配置信息,并在应用启动时加载这些配置。
-
负载均衡:通过 Zookeeper,Spring Cloud 可以实现对服务的负载均衡,确保请求能够均匀地分配到多个服务实例上。
-
集群管理:Zookeeper 可以帮助管理微服务的集群状态,监控服务的健康状况,并在服务出现故障时进行相应的处理。
-
分布式锁:Zookeeper 提供了分布式锁的功能,可以用于控制对共享资源的访问,确保数据的一致性。
-
事件通知:Zookeeper 支持观察者模式,服务可以监听特定节点的变化,并在节点状态变化时收到通知,从而实现动态配置更新等功能。
2.环境搭建
docker-compose-zookeeper.yml
version: '3'
services:zookeeper:image: zookeeper:3.7.0container_name: zookeeperrestart: unless-stoppedvolumes:- "./zookeeper/data:/data"- "./zookeeper/datalog:/datalog"ports:- "2181:2181"# webuizookeeper-webui:image: tobilg/zookeeper-webuicontainer_name: zookeeper-webuirestart: unless-stoppedenvironment:ZK_DEFAULT_NODE: zookeeper:2181depends_on:- zookeeperlinks:- zookeeperports:- "8089:8080"
docker run
docker-compose -f docker-compose-zookeeper.yml -p zookeeper up -d
可视化界面访问地址:[http://ip地址:8089] ,输入 [{宿主主机ip}:2181/]进入
3.示例场景
我们将创建两个微服务:service-a
和 service-b
。service-a
将注册到 Zookeeper,并能够调用 service-b
。
1. 创建 service-a
1.1. 创建 Spring Boot 项目
使用 Spring Initializr 创建一个新的 Spring Boot 项目,选择以下依赖:
- Spring Web
- Spring Cloud Starter Zookeeper Discovery
1.2. 添加依赖
在 pom.xml
中添加 Spring Cloud Zookeeper 依赖:
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
</dependency>
1.3. 配置 application.yml
在 src/main/resources/application.yml
中配置 Zookeeper 地址:
spring:application:name: service-acloud:zookeeper:connect-string: localhost:2181
server:port: 8080
1.4. 创建 Controller
创建一个简单的 REST 控制器:
@RestController
@RequestMapping("/service-a")
public class ServiceAController {@GetMapping("/hello")public String hello() {return "Hello from Service A!";}
}
2. 创建 service-b
1.1. 创建 Spring Boot 项目
同样使用 Spring Initializr 创建另一个 Spring Boot 项目,选择以下依赖:
- Spring Web
- Spring Cloud Starter Zookeeper Discovery
1.2. 添加依赖
在 pom.xml
中添加 Spring Cloud Zookeeper 依赖:
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
</dependency>
1.3. 配置 application.yml
在 src/main/resources/application.yml
中配置 Zookeeper 地址:
spring:application:name: service-bcloud:zookeeper:connect-string: localhost:2181
server:port: 8081
1.4. 创建 Controller
创建一个简单的 REST 控制器,调用 service-a
:
@RestController
@RequestMapping("/service-b")
public class ServiceBController {@Autowiredprivate RestTemplate restTemplate;@GetMapping("/call-a")public String callServiceA() {String url = "http://service-a/service-a/hello";return restTemplate.getForObject(url, String.class);}
}
1.5. 添加 RestTemplate Bean
在 ServiceBApplication
类中添加 RestTemplate
Bean:
- 当你在
service-b
中调用service-a
时,如果没有使用@LoadBalanced
注解,RestTemplate
将尝试直接使用你提供的 URL(如http://service-a/service-a/hello
)。如果service-a
的主机名无法解析(如UnknownHostException
),则会导致调用失败。 - 加上
@LoadBalanced
后,RestTemplate
会使用 Spring Cloud 的负载均衡机制,自动将服务名(如service-a
)解析为实际的服务实例地址。这是通过与服务注册中心(如 Zookeeper)进行交互来实现的。
@Bean
@LoadBalanced
public RestTemplate restTemplate() {return new RestTemplate();
}
以上只是一些关键代码,所有代码请参见下面代码仓库
代码仓库
- https://github.com/Harries/springcloud-demo(Spring Cloud zookeeper)
4. 测试
分别启动 service-a
和 service-b
。你可以在浏览器中访问以下 URL 测试:
- 访问
service-a
:http://localhost:8080/service-a/hello
- 访问
service-b
:http://localhost:8081/service-b/call-a
,这将调用service-a
的接口并返回结果。
5.引用
- Spring Cloud Zookeeper
- Spring Cloud Zookeeper 快速入门demo | Harries Blog™