主要内容

  • 服务注册中心：zookeeper代替eureka
  • Consul服务注册与发现

    1. 注册中心Zookeeper

    zookeeper是一个分布式协调工具，可以实现注册中心功能
    关闭linux服务器防火墙后，启动zookeeper服务器
    centos：

    systemctl stop firewalld

Ubuntu：

sudo ufw disable

zookeeper服务器取代Eureka服务器，zk作为服务注册中心

2.服务提供者

2.1 新建cloud-provider-payment8004微服务模块

2.2 pom

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>jdk8cloud2021</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-provider-payment8004</artifactId>
  14.     <properties>
  15.         <maven.compiler.source>8</maven.compiler.source>
  16.         <maven.compiler.target>8</maven.compiler.target>
  17.     </properties>
  18.     <dependencies>
  19.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  20.             <groupId>com.atguigu.springcloud</groupId>
  21.             <artifactId>cloud-api-commons</artifactId>
  22.             <version>${project.version}</version>
  23.         </dependency>
  24.         <!-- SpringBoot整合zookeeper客户端 -->
  25.         <dependency>
  26.             <groupId>org.springframework.cloud</groupId>
  27.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-web</artifactId>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>org.springframework.boot</groupId>
  35.             <artifactId>spring-boot-devtools</artifactId>
  36.             <scope>runtime</scope>
  37.             <optional>true</optional>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.projectlombok</groupId>
  41.             <artifactId>lombok</artifactId>
  42.             <optional>true</optional>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-starter-test</artifactId>
  47.             <scope>test</scope>
  48.         </dependency>
  49.     </dependencies>
  50. </project>

2.3 application.yml

  1. #8004表示注册到zookeeper服务器的支付服务提供者端口号
  2. server:
  3.   port: 8004
  5. #服务别名----注册zookeeper到注册中心名称
  6. spring:
  7.   application:
  8.     name: cloud-provider-payment
  9.   cloud:
  10.     zookeeper:
  11.       connect-string: 192.168.190.128:2181

2.4 主启动类

  1. @SpringBootApplication
  2. @EnableDiscoveryClient //该注解用于向使用consul或者zookeeper作为注册中心时注册服务
  3. public class PaymentMain8004 {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(PaymentMain8004.class, args);
  6.     }
  7. }

2.5 controller

  1. @RestController
  2. @Slf4j
  3. public class PaymentController {
  4.     @Value("${server.port}")
  5.     private String serverPort;
  7.     @RequestMapping(value = "/payment/zk")
  8.     public String paymentzk() {
  9.         return "springcloud with zookeeper: " + serverPort + "\t" + UUID.randomUUID().toString();
  10.     }
  12. }

2.6 测试：解决jar包冲突

2.6.1 解决jar包冲突

image.png
image.png
如果安装的zookeeper版本高于3.5.3则不会出现冲突报错。我是3.5.7没有报错
报错解决方案：排除引入的3.5.3-beta，引入与安装的zookeeper对应的版本

  1. <dependencies>
  2.   <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  3.     <groupId>com.atguigu.springcloud</groupId>
  4.     <artifactId>cloud-api-commons</artifactId>
  5.     <version>${project.version}</version>
  6.   </dependency>
  7.   <!-- SpringBoot整合zookeeper客户端 -->
  8.   <dependency>
  9.     <groupId>org.springframework.cloud</groupId>
  10.     <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  11.     <!--先排除自带的zookeeper3.5.3-->
  12.     <exclusions>
  13.       <exclusion>
  14.         <groupId>org.apache.zookeeper</groupId>
  15.         <artifactId>zookeeper</artifactId>
  16.       </exclusion>
  17.     </exclusions>
  18.   </dependency>
  19.   <!--添加zookeeper3.5.7版本-->
  20.   <dependency>
  21.     <groupId>org.apache.zookeeper</groupId>
  22.     <artifactId>zookeeper</artifactId>
  23.     <version>3.5.7</version>
  24.   </dependency>

这样又会产生新的错误：SLF4J多次绑定
image.png
zookeeper跟starter-web中都有slf4j产生了冲突
image.png
所以排除掉zookeeper中的slf4j
image.png
再次启动成功

2.6.2 查看服务是否注册成功

虚拟机cd到zookeeper安装目录下：cd /usr/local/moudle/zookeeper-3.5.7
连接zookeeper客户端：bin/zkCli.sh
查看服务是否注册成功：
image.png

2.6.3 测试controller

image.png
通过 get /services/cloud-provider-payment/39f814f5-8ddd-4fa3-9d95-130ff687f736 获取节点信息
image.png
在线解析json串：https://tool.lu/json
image.png

2.7 思考

注册到zookeeper的微服务是一个zNode节点，这个节点是临时节点还是持久节点？

我们在注册的时候会生成一个流水号id，我们将服务断开，发现刚断开时zookeeper还保存着该服务，等待一段时间后，该节点被删除。所以是临时节点。重新启动8004的微服务，可以看到生成了一个新的流水号id
image.png

如果先前配置了zookeeper的集群，请确保一半以上的服务器处于开启状态，否者zookeeper服务无法使用

3 服务消费者

3.1 新建cloud-consumerzk-order80

3.2 pom

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>jdk8cloud2021</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-consumer-order80</artifactId>
  14.     <properties>
  15.         <maven.compiler.source>8</maven.compiler.source>
  16.         <maven.compiler.target>8</maven.compiler.target>
  17.     </properties>
  18.     <dependencies>
  19.         <!--eureka-client-->
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  23.         </dependency>
  24.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  25.             <groupId>com.atguigu.springcloud</groupId>
  26.             <artifactId>cloud-api-commons</artifactId>
  27.             <version>${project.version}</version>
  28.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-starter-web</artifactId>
  33.         </dependency>
  34.         <dependency>
  35.             <groupId>org.springframework.boot</groupId>
  36.             <artifactId>spring-boot-starter-actuator</artifactId>
  37.         </dependency>
  39.         <dependency>
  40.             <groupId>org.springframework.boot</groupId>
  41.             <artifactId>spring-boot-devtools</artifactId>
  42.             <scope>runtime</scope>
  43.             <optional>true</optional>
  44.         </dependency>
  45.         <dependency>
  46.             <groupId>org.projectlombok</groupId>
  47.             <artifactId>lombok</artifactId>
  48.             <optional>true</optional>
  49.         </dependency>
  50.         <dependency>
  51.             <groupId>org.springframework.boot</groupId>
  52.             <artifactId>spring-boot-starter-test</artifactId>
  53.             <scope>test</scope>
  54.         </dependency>
  56.     </dependencies>
  57. </project>

3.3 yml

  1. #80表示注册到zookeeper服务器的消费服务提供者端口号
  2. server:
  3.   port: 80
  5. #服务别名----注册zookeeper到注册中心名称
  6. spring:
  7.   application:
  8.     name: cloud-consumer-order
  9.   cloud:
  10.     zookeeper:
  11.       connect-string: 192.168.190.128:2181

3.4. 主启动类

  1. @SpringBootApplication
  2. @EnableDiscoveryClient
  3. public class OrderZKMain80 {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(OrderZKMain80.class, args);
  6.     }
  7. }

3.5. 配置类

  1. @Configuration
  2. public class ApplicationContextConfig {
  3.     @Bean
  4.     @LoadBalanced //使用@LoadBalanced注解赋予RestTemplate负载均衡的能力
  5.     public RestTemplate restTemplate() {
  6.         return new RestTemplate();
  7.     }
  8. }

3.6. 业务类

  1. @RestController
  2. @Slf4j
  3. public class OrderZKController {
  4.     public static final String INVOKE_URL = "http://cloud-provider-payment";
  5.     @Resource
  6.     private RestTemplate restTemplate;
  8.     @GetMapping("/consumer/payment/zk")
  9.     public String paymentInfo() {
  10.         return restTemplate.getForObject(INVOKE_URL + "/payment/zk", String.class);
  11.     }
  12. }

3.7. 测试

image.png