注册中心场景分析:
    1. 在分布式服务体系结构比较简单的场景下,我们的服务可能是这样的
    image.png
    现在 Order-Service 需要调用外部服务的 User-Service ,对于外部的服务依赖,我们直接配置在我们的服务配置文件中,在服务调用关系比较简单的场景,是完全OK的。随着服务的扩张,User-Service 可能需要进行集群部署,如下:
    image.png
    如果系统的调用不是很复杂,可以通过配置管理,然后实现一个简单的客户端负载均衡也是OK的,但是随着业务的发展,服务模块进行更加细粒度的划分,业务也变得更加复杂,再使用简单的配置文件管理,将变得难以维护。当然我们可以再前面加一个服务代理,比如nginx做反向代理, 如下
    image.png
    如果我们是如下场景呢?
    image.png
    服务不再是A-B,B-C 那么简单,而是错综复杂的微小服务的调用
    这个时候我们可以借助于Zookeeper的基本特性来实现一个注册中心,什么是注册中心,顾名思义,就是让众多的服务,都在Zookeeper中进行注册,啥是注册,注册就是把自己的一些服务信息,比如IP,端口,还有一些更加具体的服务信息,都写到 Zookeeper节点上, 这样有需要的服务就可以直接从zookeeper上面去拿,怎么拿呢? 这时我们可以定义统一的名称,比如,User-Service, 那所有的用户服务启动的时候,都在User-Service 这个节点下面创建一个子节点(临时节点),这个子节点保持唯一就好,代表了每个服务实例的唯一标识,有依赖用户服务的比如Order-Service 就可以通过User-Service 这个父节点,就能获取所有的User-Service 子节点,并且获取所有的子节点信息(IP,端口等信息),拿到子节点的数据后Order-Service可以对其进行缓存,然后实现一个客户端的负载均衡,同时还可以对这个User-Service 目录进行监听, 这样有新的节点加入,或者退出,Order-Service都能收到通知,这样Order-Service重新获取所有子节点,且进行数据更新。这个用户服务的子节点的类型为临时节点。 第一节课有讲过,Zookeeper中临时节点生命周期是和SESSION绑定的,如果SESSION超时了,对应的节点会被删除,被删除时,Zookeeper 会通知对该节点父节点进行监听的客户端, 这样对应的客户端又可以刷新本地缓存了。当有新服务加入时,同样也会通知对应的客户端,刷新本地缓存,要达到这个目标需要客户端重复的注册对父节点的监听。这样就实现了服务的自动注册和自动退出。
    image.png
    Spring Cloud 生态也提供了Zookeeper注册中心的实现,这个项目叫 Spring Cloud Zookeeper 下面我们来进行实战。
    项目说明:
    为了简化需求,我们以两个服务来进行讲解,实际使用时可以举一反三
    user-center : 用户服务
    product-center: 产品服务
    用户调用产品服务,且实现客户端的负载均衡,产品服务自动加入集群,自动退出服务。
    项目构建
    1. 创建user-center 项目
    image.png
    同样的方式创建一个 product-center
    2. 解压项目用idea打开,用maven导入项目
    image.png
    同样的方式引入product-center 项目

    1. 配置zookeeper
      user-center 服务:
      application.properties

      1. spring.application.name=user-center
      2. #zookeeper 连接地址
      3. #如果使用了 spring cloud zookeeper config这个配置应该配置在 bootstrap.yml/bootstrap.properties
      4. spring.cloud.zookeeper.connect-string=192.168.109.200:2181
      5. #将本服务注册到zookeeper,如果不希望自己被发现可以配置为false, 默认为 true
      6. spring.cloud.zookeeper.discovery.register=true

      代码编写:
      配置 Resttemplate 支持负载均衡方式 ```java @SpringBootApplication public class UserCenterApplication {

      public static void main(String[] args) { SpringApplication.run(UserCenterApplication.class, args); }

    1. @Bean

    @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } }

    编写测试类:<br />TestController, Spring Cloud 支持 Feign, Spring RestTemplate,WebClient 以 逻辑名称,替代具体url的形式访问。
    ```java
    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 TestController {
    
        @Autowired
        private RestTemplate restTemplate;
    
        @GetMapping("/test")
        public String test(){
            return this.restTemplate.getForObject( "http://product-center/getInfo" ,String.class);
        }
    }
    

    product-center 服务:
    application.properties

    spring.application.name=user-center
    #zookeeper 连接地址
    spring.cloud.zookeeper.connect-string=192.168.109.200:2181
    #将本服务注册到zookeeper
    spring.cloud.zookeeper.discovery.register=true
    

    主类,接收一个getInfo 请求

    @SpringBootApplication
    @RestController
    public class ProductCenterApplication {
    
       @Value("${server.port}")
       private String port;
    
       @Value( "${spring.application.name}" )
       private String name;
    
       @GetMapping("/getInfo")
       public String getServerPortAndName(){
    
          return  this.name +" : "+ this.port;
       }
       public static void main(String[] args) {
          SpringApplication.run(ProductCenterApplication.class, args);
       }
    }
    

    启动两个product-center 实例
    通过idea 配置,启动多个实例,用端口区分不同的应用
    image.png
    image.png
    启动一个user-center 实例,默认8080端口
    image.png
    启动服务 :访问 http://localhost:8080/test
    image.png
    image.png
    已经实现了,服务端的自动发现和客户端负载均衡。
    停掉product-center: 10002,再次访问
    image.png
    一定的超时时间过去之后,product-center: 10002 会从zookeeper中剔除,zookeeper会通知客户端,进行本地缓存刷新,再次访问, 已经实现了失效节点的自动退出。
    image.png