微服务SpringCloud（Zookeeper作为注册中心）整合十

由于 Eureka 基本上已经停止更新了，所以在以后的项目中是不建议使用Eureka作为注册中心的。接下我们要整合其他的注册中心，目前使用比较多的如Zookeeper、consul、nacos。nacos 我们会在后续专门讲的。下面我们开始整合Zookeeper。
在整合在zookeeper之前，我们需要安装zookeeper。zookeeper的安装可以查阅资料，在这里我们就不做过多的讲解了。
新建Module pcloud-provider-user8003

修改pom文件

  4.0.0

  
    pcloud
    com.younger.springcloud
    1.0-SNAPSHOT
  

  com.younger.springcloud
  pcloud-provider-user8003
  1.0-SNAPSHOT
  pcloud-provider-user8003

  
    
    
      org.springframework.boot
      spring-boot-starter-web
    
    
    
      org.springframework.cloud
      spring-cloud-starter-zookeeper-discovery
    
    
      org.springframework.boot
      spring-boot-devtools
      runtime
      true
    
    
      org.projectlombok
      lombok
      true
    
    
      org.springframework.boot
      spring-boot-starter-test
      test
    

    
      com.younger.springcloud
      pcloud-api-commons
      ${project.version}
    

  

配置yml
application.yml

server:
  port: 8003
#服务别名
spring:
  application:
    name: pcloud-provider-user
# 配置zookeeper地址
  cloud:
    zookeeper:
      connect-string: 127.0.0.1:2181

编写启动类: UserMain8003

package com.younger.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication
@EnableDiscoveryClient //这个是服务发现通用的注解 比如从consul、zookeeper作为注册中心时使用。之前我们使用的注解是专门针对Eureka 的。
public class UserMain8003 {

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

新增controller目录，新增UserController 类。

package com.younger.springcloud.controller;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {

    @Value("${server.port}")
    private String serverPort;

    @RequestMapping(value = "/user/zk")
    public String getZk() {
       return "use zk  with registration center t" + serverPort;
    }

}

启动测试一下：先启动zookeeper，在启动项目8003

看日志信息，已经成功了。

有的同学启动的时候可能会报错，因为用的zookeeper版本和springcloud jar 包版本有冲突。如下图：

从依赖中可以看出，springcloud 使用的版本是 3.5.3,。所以我们使用的zookeeper版本也要是3.5版本的。如果我们不是使用的该版本，我们就需要把springcloud 自带的版本，排除掉。在添加上我们自己的zookeeper版本。

在 修改pom依赖:

      
            org.springframework.cloud
            spring-cloud-starter-zookeeper-discovery
            
            
                
                    org.apache.zookeeper
                    zookeeper
                
            
        
  
  		
        
            org.apache.zookeeper
            zookeeper
            zookeeper的版本
        

我们在访问一下： http://localhost:8003/user/zk

上面我们已经整合完了使用zookeeper作为注册中心，接下来我们需要整合zookeeper作为注册中心如何提供服务呢？
新建Module pcloud-consumerzk-login80

修改pom文件

    
        pcloud
        com.younger.springcloud
        1.0-SNAPSHOT
    

    4.0.0
    pcloud-consumerzk-login80
    
        
        
            org.springframework.boot
            spring-boot-starter-web
        
        
        
            org.springframework.cloud
            spring-cloud-starter-zookeeper-discovery
        

        
            org.springframework.boot
            spring-boot-devtools
            runtime
            true
        
        
            org.projectlombok
            lombok
            true
        
        
            org.springframework.boot
            spring-boot-starter-test
            test
        
    

新增application.yml文件

server:
  port: 80
spring:
  application:
    name: pcloud-consumer-login
  cloud:
    #注册到zookeeper地址
    zookeeper:
      connect-string: 127.0.0.1:2181

新增启动类: LoginMainZk80

package com.younger.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class LoginMainZk80 {

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

目录结构:

ApplicationConfig类:

package com.younger.springcloud.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class ApplicationConfig {

    @Bean
    @LoadBalanced // 通过这注解，可以使RestTemplate有负载均衡的能力
    public RestTemplate restTemplate () {
        return new RestTemplate();
    }
}

UserZkController类:

package com.younger.springcloud.controller;

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 UserZkController {

    // 通过在eureka上注册过的微服务名称调用
    public static final String REMOTE_URL = "http://pcloud-provider-user";
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/consumer/zk")
    public String getUserInfo() {
        String result = restTemplate.getForObject(REMOTE_URL+"/user/zk", String.class);
        return result;
    }
}

测试验证：
现启动服务8003，在启动pcloud-consumerzk-login80 服务。

访问地址: http://localhost:80/consumer/zk