Spring Cloud Zookeeper 使用教程

项目介绍

Spring Cloud Zookeeper 是 Spring Cloud 生态系统中的一个组件，它利用 Apache Zookeeper 作为服务注册和发现的中心。Zookeeper 是一个分布式协调服务，提供了高可用性和负载均衡的特性。Spring Cloud Zookeeper 不仅支持服务注册和发现，还提供了分布式锁和配置管理等功能。

项目快速启动

环境准备

• Java 8 或更高版本
• Apache Zookeeper 安装并运行
• Maven 或 Gradle 构建工具

创建项目

1. 创建一个新的 Spring Boot 项目

   使用 Spring Initializr 创建一个新的项目，并添加以下依赖：

   <dependencies>
       <dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
       </dependency>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-web</artifactId>
       </dependency>
   </dependencies>
   

2. 配置 application.yml

   在 src/main/resources 目录下创建 application.yml 文件，并添加以下配置：

   spring:
     application:
       name: my-service
     cloud:
       zookeeper:
         connect-string: localhost:2181
   server:
     port: 8080
   

3. 编写服务提供者代码

   创建一个简单的 REST 控制器：

   import org.springframework.web.bind.annotation.GetMapping;
   import org.springframework.web.bind.annotation.RestController;
   
   @RestController
   public class MyController {
   
       @GetMapping("/hello")
       public String hello() {
           return "Hello from My Service!";
       }
   }
   

4. 启动应用

   运行 Spring Boot 应用，服务将会在 Zookeeper 中注册。

应用案例和最佳实践

服务发现

Spring Cloud Zookeeper 提供了服务发现的功能，使得服务消费者可以动态地发现和调用服务提供者。以下是一个简单的服务消费者示例：

1. 添加依赖

   在服务消费者的 pom.xml 中添加以下依赖：

   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
   </dependency>
   

2. 配置 application.yml

   配置服务消费者的 application.yml：

   spring:
     application:
       name: my-consumer
     cloud:
       zookeeper:
         connect-string: localhost:2181
   server:
     port: 8081
   

3. 编写服务消费者代码

   使用 @LoadBalanced 注解实现负载均衡：

   import org.springframework.cloud.client.loadbalancer.LoadBalanced;
   import org.springframework.context.annotation.Bean;
   import org.springframework.web.client.RestTemplate;
   
   @SpringBootApplication
   public class MyConsumerApplication {
   
       @Bean
       @LoadBalanced
       public RestTemplate restTemplate() {
           return new RestTemplate();
       }
   
       public static void main(String[] args) {
           SpringApplication.run(MyConsumerApplication.class, args);
       }
   }
   

   创建一个控制器来调用服务提供者：

   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.web.bind.annotation.GetMapping;
   import org.springframework.web.bind.annotation.RestController;
   import org.springframework.web.client.RestTemplate;
   
   @RestController
   public class ConsumerController {
   
       @Autowired
       private RestTemplate restTemplate;
   
       @GetMapping("/consume")
       public String consume() {
           return restTemplate.getForObject("http://my-service/hello", String.class);
       }
   }
   

配置管理

Spring Cloud Zookeeper 还支持配置管理，可以在 Zookeeper 中集中管理