常见面试题

1、什么是微服务？
2、微服务之间是如何独立通讯的？
3、spingcloud与Dubbo有哪些区别？
4、springboot和springcloud，谈谈对他们的理解
5、什么是服务熔断？什么是服务降级？
6、微服务的优缺点分别是什么？说下你在项目中遇到的坑
7、你知道的微服务的技术栈有哪些？
8、eureka和zookeeper都可以提供服务注册与发现的功能，请说说他们的区别

image.png

1、概述

1、服务拆分后，服务众多，客户端该如何访问？
2、众多服务之间该如何通信？http、rpc
3、众多服务该如何治理？
4、服务挂了怎么办？

解决方案：
1、Spring Cloud NetFlix 一站式解决方案
api网关：zuul组件
feign—-httpclient—-http通信，同步，阻塞
服务注册发现：Eureka
熔断机制：Hystrix
2、Apache Dubbo Zookeeper 半自动，需要整合别人的
API:没有。整合第三方，或自己实现
Dubbo
Zookeeper
没有：借助Hystrix
3、Spring Cloud Alibaba 一站式解决方案！成本更低，更加简便

image.png

2、cloud与boot的版本选择

参考：https://spring.io/projects/spring-cloud#overwrite
更加详细的版本范围参考：start.spring.io/actuator/info
本次学习springcloud的版本选择为：
pringcloud: Hoxton.SR1
springboot: 2.2.2.RELEASE
springcloud alibaba: 2.1.0.RELEASE
java: java8
maven: 3.5及以上
mysql： 5.7及以上
springcloud此时最新的稳定发布版为：Hoxton.SR1
springboot此时最新的稳定发布版为：2.2.4.RELEASE

springboot为什么不选择最新的2.2.4.RELEASE？
查看springcloud此稳定版本文档发现推荐使用springboot的版本为：2.2.2.RELEASE

image.png
订单-支付工程融合进以上技术

3、项目初始化cloud2022

1、创建父工程

1、创建mave项目选择maven-archetype-site框架
2、设置字符集编码为utf-8 File Encoding
3、设置注解生效 Compliler===》Annotation Processors
4、设置java编译版本为java8 Compliler===》java Complicer

2、父工程pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" 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.   <modelVersion>4.0.0</modelVersion>
  7.   <groupId>com.guang.springcloud</groupId>
  8.   <artifactId>cloud2022</artifactId>
  9.   <version>1.0-SNAPSHOT</version>
  10.     <packaging>pom</packaging>
  12.     <!-- 统一管理jar包版本 -->
  13.     <properties>
  14.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  15.         <maven.compiler.source>1.8</maven.compiler.source>
  16.         <maven.compiler.target>1.8</maven.compiler.target>
  17.         <junit.version>4.12</junit.version>
  18.         <log4j.version>1.2.17</log4j.version>
  19.         <lombok.version>1.16.18</lombok.version>
  20.         <mysql.version>5.1.47</mysql.version>
  21.         <druid.version>1.1.16</druid.version>
  22.         <mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version>
  23.     </properties>
  25.     <!-- 子模块继承之后，提供作用：锁定版本+子modlue不用写groupId和version  -->
  26.     <dependencyManagement>
  27.         <dependencies>
  28.             <!--spring boot 2.2.2-->
  29.             <dependency>
  30.                 <groupId>org.springframework.boot</groupId>
  31.                 <artifactId>spring-boot-dependencies</artifactId>
  32.                 <version>2.2.2.RELEASE</version>
  33.                 <type>pom</type>
  34.                 <scope>import</scope>
  35.             </dependency>
  36.             <!--spring cloud Hoxton.SR1-->
  37.             <dependency>
  38.                 <groupId>org.springframework.cloud</groupId>
  39.                 <artifactId>spring-cloud-dependencies</artifactId>
  40.                 <version>Hoxton.SR1</version>
  41.                 <type>pom</type>
  42.                 <scope>import</scope>
  43.             </dependency>
  44.             <!--spring cloud alibaba 2.1.0.RELEASE-->
  45.             <dependency>
  46.                 <groupId>com.alibaba.cloud</groupId>
  47.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  48.                 <version>2.1.0.RELEASE</version>
  49.                 <type>pom</type>
  50.                 <scope>import</scope>
  51.             </dependency>
  52.             <dependency>
  53.                 <groupId>mysql</groupId>
  54.                 <artifactId>mysql-connector-java</artifactId>
  55.                 <version>${mysql.version}</version>
  56.             </dependency>
  57.             <dependency>
  58.                 <groupId>com.alibaba</groupId>
  59.                 <artifactId>druid</artifactId>
  60.                 <version>${druid.version}</version>
  61.             </dependency>
  62.             <dependency>
  63.                 <groupId>org.mybatis.spring.boot</groupId>
  64.                 <artifactId>mybatis-spring-boot-starter</artifactId>
  65.                 <version>${mybatis.spring.boot.version}</version>
  66.             </dependency>
  67.             <dependency>
  68.                 <groupId>junit</groupId>
  69.                 <artifactId>junit</artifactId>
  70.                 <version>${junit.version}</version>
  71.             </dependency>
  72.             <dependency>
  73.                 <groupId>log4j</groupId>
  74.                 <artifactId>log4j</artifactId>
  75.                 <version>${log4j.version}</version>
  76.             </dependency>
  77.             <dependency>
  78.                 <groupId>org.projectlombok</groupId>
  79.                 <artifactId>lombok</artifactId>
  80.                 <version>${lombok.version}</version>
  81.                 <optional>true</optional>
  82.             </dependency>
  83.         </dependencies>
  84.     </dependencyManagement>
  86.     <build>
  87.         <plugins>
  88.             <plugin>
  89.                 <groupId>org.springframework.boot</groupId>
  90.                 <artifactId>spring-boot-maven-plugin</artifactId>
  91.                 <configuration>
  92.                     <fork>true</fork>
  93.                     <addResources>true</addResources>
  94.                 </configuration>
  95.             </plugin>
  96.         </plugins>
  97.     </build>
  99. </project>

maven跳过单元测试：点击闪电即可

4、支付模块的构建cloud-provider-payment8001

1、创建子模块cloud-provider-payment8001

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>cloud2020</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-payment8001</artifactId>
  15.     <dependencies>
  16.         <dependency>
  17.             <groupId>org.springframework.boot</groupId>
  18.             <artifactId>spring-boot-starter-web</artifactId>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-actuator</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.mybatis.spring.boot</groupId>
  26.             <artifactId>mybatis-spring-boot-starter</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>com.alibaba</groupId>
  30.             <artifactId>druid-spring-boot-starter</artifactId>
  31.             <version>1.1.10</version>
  32.         </dependency>
  33.         <!--mysql-connector-java-->
  34.         <dependency>
  35.             <groupId>mysql</groupId>
  36.             <artifactId>mysql-connector-java</artifactId>
  37.         </dependency>
  38.         <!--jdbc-->
  39.         <dependency>
  40.             <groupId>org.springframework.boot</groupId>
  41.             <artifactId>spring-boot-starter-jdbc</artifactId>
  42.         </dependency>
  43.         <dependency>
  44.             <groupId>org.springframework.boot</groupId>
  45.             <artifactId>spring-boot-devtools</artifactId>
  46.             <scope>runtime</scope>
  47.             <optional>true</optional>
  48.         </dependency>
  49.         <dependency>
  50.             <groupId>org.projectlombok</groupId>
  51.             <artifactId>lombok</artifactId>
  52.             <optional>true</optional>
  53.         </dependency>
  54.         <dependency>
  55.             <groupId>org.springframework.boot</groupId>
  56.             <artifactId>spring-boot-starter-test</artifactId>
  57.             <scope>test</scope>
  58.         </dependency>
  59.     </dependencies>
  61. </project>

3、application.yml

  1. server:
  2.   port: 8001
  4. spring:
  5.   application:
  6.     name: cloud-payment-service
  7.   datasource:
  8.     type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
  9.     driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包 com.mysql.jdbc.Driver
  10.     url: jdbc:mysql://localhost:3306/db2022?useUnicode=true&characterEncoding=utf-8&useSSL=false
  11.     username: root
  12.     password: 123456
  15. mybatis:
  16.   mapperLocations: classpath:mapper/*.xml
  17.   type-aliases-package: com.guang.springcloud.entity    # 所有Entity别名类所在包

4、创建主启动类（略）

5、编写业务类

1、创建数据库表

  1. CREATE TABLE `payment` (
  2.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
  3.   `serial` varchar(200) DEFAULT '',
  4.   PRIMARY KEY (`id`)
  5. ) ENGINE=InnoDB DEFAULT CHARSET=utf8

2、PaymentDao

  1. @Mapper
  2. public interface PaymentDao {
  4.     int insertPayment(Payment payment);
  6.     Payment selectPaymentById(Long id);
  7. }

3、payment-mapper.xml

  1. <mapper namespace="com.guang.springcloud.dao.PaymentDao">
  3.     <resultMap id="BaseResultMap" type="com.guang.springcloud.entity.Payment">
  4.         <id column="id" property="id" jdbcType="BIGINT"/>
  5.         <result column="serial" property="serial" jdbcType="VARCHAR"/>
  6.     </resultMap>
  9. <!--    int insertPayment(Payment payment);-->
  10.    <insert id="insertPayment" parameterType="Payment" useGeneratedKeys="true" keyProperty="id">
  11.        insert into payment(serial)values (#{serial});
  12.    </insert>
  14. <!--    Payment selectPaymentById(int id);-->
  15.     <select id="selectPaymentById" resultType="Payment" resultMap="BaseResultMap">
  16.         select id,serial from payment
  17.         where id=#{id};
  18.     </select>
  19. </mapper>

4、PaymentService

  1. @Service
  2. public class PaymentServiceImpl implements PaymentService {
  4.     @Autowired
  5.     private PaymentDao paymentDao;
  7.     public int insertPayment(Payment payment){
  8.         return paymentDao.insertPayment(payment);
  9.     }
  11.     public Payment selectPaymentById(Long id) {
  12.         return paymentDao.selectPaymentById(id);
  13.     }
  15. }

5、PaymentController

  1. @RestController
  2. @RequestMapping("/payment")
  3. public class PaymentController {
  5.     @Autowired
  6.     private PaymentService paymentService;
  8.     @PostMapping("/insert")
  9.     public CommonResult insertPayment(@RequestBody Payment payment){
  10.         if(payment==null){
  11.             return new CommonResult(300,"插入数据库失败，参数错误");
  12.         }
  14.         int result = paymentService.insertPayment(payment);
  15.         return new CommonResult(200,"插入数据库成功",result);
  16.     }
  18.     @GetMapping("/getPayment/{id}")
  19.     public CommonResult selectPaymentById(@PathVariable("id") Long id){
  20.         Payment payment = paymentService.selectPaymentById(id);
  21.         if(payment!=null){
  22.             return new CommonResult(200,"查询成功",payment);
  23.         }else {
  24.             return new CommonResult(300,"查询失败，参数不存在",id);
  25.         }
  26.     }
  27. }

5、热部署devtools

1、在项目8001中添加依赖

  1. <dependency>
  2.     <groupId>org.springframework.boot</groupId>
  3.     <artifactId>spring-boot-devtools</artifactId>
  4.     <scope>runtime</scope>
  5.     <optional>true</optional>
  6. </dependency>

2、在cloud2022中添加插件

  1. <build>
  2.     <finalName>你自己的工程名字</finalName>
  3.     <plugins>
  4.         <plugin>
  5.             <groupId>org.springframework.boot</groupId>
  6.             <artifactId>spring-boot-maven-plugin</artifactId>
  7.             <configuration>
  8.                 <fork>true</fork>
  9.                 <addResources>true</addResources>
  10.             </configuration>
  11.         </plugin>
  12.     </plugins>
  13. </build>

3、修改IDEA配置
settings——》compiler——》将首字母为A、D、B、C四个选项打勾
退出后使用快捷键Ctrl+Alt+Shift+/ 设置
image.png
最后重启IDEA即可

6、消费者模块cloud-consumer-order80

pom.xml

  1. <artifactId>cloud-consumer-order80</artifactId>
  3.     <dependencies>
  4.         <dependency>
  5.             <groupId>org.springframework.boot</groupId>
  6.             <artifactId>spring-boot-starter-web</artifactId>
  7.         </dependency>
  8.         <dependency>
  9.             <groupId>org.springframework.boot</groupId>
  10.             <artifactId>spring-boot-starter-actuator</artifactId>
  11.         </dependency>
  13.         <dependency>
  14.             <groupId>org.springframework.boot</groupId>
  15.             <artifactId>spring-boot-devtools</artifactId>
  16.             <scope>runtime</scope>
  17.             <optional>true</optional>
  18.         </dependency>
  19.         <dependency>
  20.             <groupId>org.projectlombok</groupId>
  21.             <artifactId>lombok</artifactId>
  22.             <optional>true</optional>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.boot</groupId>
  26.             <artifactId>spring-boot-starter-test</artifactId>
  27.             <scope>test</scope>
  28.         </dependency>
  29.     </dependencies>

application.yml

  1. server:
  2.   port: 80

实体类Payment、CommonResult（略）

配置RestTemplate访问远程URL

  1. @Configuration
  2. public class RestTamplateConfig {
  3.     @Bean
  4.     public RestTemplate getRestTemplate(){
  5.         return new RestTemplate();
  6.     }
  7. }

OrderController

  1. @RestController
  2. public class OrderController {
  4.     public static final String Payment_URL="http://localhost:8001/payment";
  6.     @Autowired
  7.     private RestTemplate restTemplate;
  9.     @GetMapping("/consumer/payment/insert")
  10.     public CommonResult insertPayment(@RequestBody Payment payment){
  11.         return restTemplate.postForObject(Payment_URL+"/insert",payment,CommonResult.class);
  12.     }
  14.     @GetMapping("/consumer/payment/get/{id}")
  15.     public CommonResult selectPaymentById(@PathVariable("id")Long id){
  16.         return restTemplate.getForObject(Payment_URL+"/get/"+id,CommonResult.class,id);
  17.     }
  18. }

7、工程重构-提取公共模块cloud-api-common

pom.xml

  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>cloud2022</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-api-common</artifactId>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>org.springframework.boot</groupId>
  17.             <artifactId>spring-boot-devtools</artifactId>
  18.             <scope>runtime</scope>
  19.             <optional>true</optional>
  20.         </dependency>
  21.         <dependency>
  22.             <groupId>org.projectlombok</groupId>
  23.             <artifactId>lombok</artifactId>
  24.             <optional>true</optional>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>cn.hutool</groupId>
  28.             <artifactId>hutool-all</artifactId>
  29.             <version>5.1.0</version>
  30.         </dependency>
  31.     </dependencies>
  33. </project>

Payment(略)、CommonResult

  1. public class CommonResult<T>
  2. {
  3.     private Integer code;
  4.     private String message;
  5.     private T data;
  7.     public CommonResult()
  8.     {
  9.     }
  11.     public CommonResult(Integer code, String message, T data)
  12.     {
  13.         this.code = code;
  14.         this.message = message;
  15.         this.data = data;
  16.     }
  17.     public CommonResult( Integer code,String message) {
  18.         this( code, message,null);
  19.     }
  21.     public CommonResult(T data) {
  22.         this(200, "操作成功", data);
  23.     }
  25.     //setter--getter
  26.     public T getData() {
  27.         return data;
  28.     }
  30.     public void setData(T data) {
  31.         this.data = data;
  32.     }
  34.     public String getMessage() {
  35.         return message;
  36.     }
  38.     public void setMessage(String message) {
  39.         this.message = message;
  40.     }
  42.     public Integer getCode() {
  43.         return code;
  44.     }
  46.     public void setCode(Integer code) {
  47.         this.code = code;
  48.     }
  49. }

maven 进行clean与install操作

80与8001

在pom.xml中引入cloud-api-common的依赖后，删除entity包下的实体类

  1.  <dependency>
  2.             <groupId>com.guang.springcloud</groupId>
  3.             <artifactId>cloud-api-common</artifactId>
  4.             <version>1.0-SNAPSHOT</version>
  5.         </dependency>

8、服务注册与发现中心

1、Eureka（停更）

1.1 、简介

什么是服务治理　　
Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理

在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，管理比较复杂，所以需要使用服务治理，管理服务于服务之间依赖关系，可以实现服务调用、负载均衡、容错等，实现服务发现与注册。

什么是服务注册与发现
Eureka采用了CS的设计架构，Eureka Server 作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用 Eureka的客户端连接到 Eureka Server并维持心跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行。
在服务注册与发现中，有一个注册中心。当服务器启动的时候，会把当前自己服务器的信息 比如 服务地址通讯地址等以别名方式注册到注册中心上。另一方（消费者|服务提供者），以该别名的方式去注册中心上获取到实际的服务通讯地址，然后再实现本地RPC调用RPC远程调用框架核心设计思想：在于注册中心，因为使用注册中心管理每个服务与服务之间的一个依赖关系(服务治理概念)。在任何rpc远程框架中，都会有一个注册中心(存放服务地址相关信息(接口地址))
springcloud - 图6
Eureka包含两个组件：Eureka Server和Eureka Client

Eureka Server提供服务注册服务
各个微服务节点通过配置启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观看到。


EurekaClient通过注册中心进行访问
是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点移除（默认90秒）

1.2、单机版Eureka7001构建

1、创建module==》cloud-eureka-server7001
2、导依赖
以前的老版本（当前使用2018）

org.springframework.cloud
spring-cloud-starter-eureka

现在新版本（当前使用2020.2）

org.springframework.cloud
spring-cloud-starter-netflix-eureka-server

  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>cloud2022</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-eureka-server7001</artifactId>
  14.     <dependencies>
  15.         <!--eureka-server-->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  19.         </dependency>
  20.         <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  21.         <dependency>
  22.             <groupId>com.guang.springcloud</groupId>
  23.             <artifactId>cloud-api-common</artifactId>
  24.             <version>${project.version}</version>
  25.         </dependency>
  26.         <!--boot web actuator-->
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-actuator</artifactId>
  34.         </dependency>
  35.         <!--一般通用配置-->
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-devtools</artifactId>
  39.             <scope>runtime</scope>
  40.             <optional>true</optional>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>org.projectlombok</groupId>
  44.             <artifactId>lombok</artifactId>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-test</artifactId>
  49.             <scope>test</scope>
  50.         </dependency>
  51.         <dependency>
  52.             <groupId>junit</groupId>
  53.             <artifactId>junit</artifactId>
  54.         </dependency>
  55.     </dependencies>
  57. </project>

3、配置文件

  1. server:
  2.   port: 7001
  4. eureka:
  5.   instance:
  6.     hostname: localhost #eureka服务端的实例名称
  7.   client:
  8.     #false表示不向注册中心注册自己。
  9.     register-with-eureka: false
  10.     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
  11.     fetch-registry: false
  12.     service-url:
  13.       #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
  14.       defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

4、主启动类

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

5、测试
localhost:7001即可

1.3、服务8001进驻单机版eureka

1、改pom

  1. <!--eureka-client-->
  2.         <dependency>
  3.             <groupId>org.springframework.cloud</groupId>
  4.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  5.         </dependency>

2、改yml

  1. eureka:
  2.   client:
  3.     #表示是否将自己注册进EurekaServer默认为true。
  4.     register-with-eureka: true
  5.     #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
  6.     fetchRegistry: true
  7.     service-url:
  8.       defaultZone: http://localhost:7001/eureka

3、主启动类加上 @EnableEurekaClient
4、测试 localhost:7001 红色字段为eureka的自我保护机制

1.4、服务80进驻单机版Eureka

1、改pom

  1. <!--eureka-client-->
  2.         <dependency>
  3.             <groupId>org.springframework.cloud</groupId>
  4.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  5.         </dependency>

2、改yml

  1. spring:
  2.     application:
  3.         name: cloud-order-service
  5. eureka:
  6.   client:
  7.     #表示是否将自己注册进EurekaServer默认为true。
  8.     register-with-eureka: true
  9.     #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
  10.     fetchRegistry: true
  11.     service-url:
  12.       defaultZone: http://localhost:7001/eureka

3、主启动类加上 @EnableEurekaClient

1.5、集群版Eureka概述

问题：微服务RPC远程服务调用最核心的是什么
高可用，试想你的注册中心只有一个only one， 它出故障了那就呵呵(￣▽￣)”了，会导致整个为服务环境不可用

解决办法：搭建Eureka注册中心集群 ，实现负载均衡+故障容错

1.6、集群版Eureka环境搭建

1、创建Module====》cloud-eureka-server7002
2、改pom（参考7001）

  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>cloud2022</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-eureka-server7002</artifactId>
  14.     <dependencies>
  15.         <!--eureka-server-->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  19.         </dependency>
  20.         <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  21.         <dependency>
  22.             <groupId>com.guang.springcloud</groupId>
  23.             <artifactId>cloud-api-common</artifactId>
  24.             <version>${project.version}</version>
  25.         </dependency>
  26.         <!--boot web actuator-->
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-actuator</artifactId>
  34.         </dependency>
  35.         <!--一般通用配置-->
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-devtools</artifactId>
  39.             <scope>runtime</scope>
  40.             <optional>true</optional>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>org.projectlombok</groupId>
  44.             <artifactId>lombok</artifactId>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-test</artifactId>
  49.             <scope>test</scope>
  50.         </dependency>
  51.         <dependency>
  52.             <groupId>junit</groupId>
  53.             <artifactId>junit</artifactId>
  54.         </dependency>
  55.     </dependencies>
  57. </project>

3、修改电脑hosts文件
路径：C:\windows\System32\drivers\etc路径下的hosts文件

  1. 127.0.0.1    eureka7001.com
  2. 127.0.0.1    eureka7002.com
  3. 127.0.0.1    eureka7003.com

4、改yml

  1. server:
  2.   port: 7002
  5. eureka:
  6.   instance:
  7.     hostname: eureka7002.com #eureka服务端的实例名称
  8.   client:
  9.     register-with-eureka: false     #false表示不向注册中心注册自己。
  10.     fetch-registry: false     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
  11.     service-url:
  12.       defaultZone: http://eureka7001.com:7001/eureka/

5、相对应7001的yml文件也需要修改

  1. server:
  2.   port: 7001
  5. eureka:
  6.   instance:
  7.     hostname: eureka7001.com #eureka服务端的实例名称
  8.   client:
  9.     register-with-eureka: false     #false表示不向注册中心注册自己。
  10.     fetch-registry: false     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
  11.     service-url:
  12.       defaultZone: http://eureka7002.com:7002/eureka/

6、主启动类

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

1.7、80与8001进驻集群

8001.yml与80.yml修改eureka的访问路径

  1. # 集群版
  2. defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka

1.8、集群版8001

1、创建Module====》cloud-provider-payment
2、改pom(参考8001）

  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>cloud2022</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-provider-payment8002</artifactId>
  14.     <dependencies>
  15.         <!--eureka-client-->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  19.         </dependency>
  20.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  21.             <groupId>com.atguigu.springcloud</groupId>
  22.             <artifactId>cloud-api-common</artifactId>
  23.             <version>${project.version}</version>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-web</artifactId>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-actuator</artifactId>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>org.mybatis.spring.boot</groupId>
  35.             <artifactId>mybatis-spring-boot-starter</artifactId>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>com.alibaba</groupId>
  39.             <artifactId>druid-spring-boot-starter</artifactId>
  40.             <version>1.1.10</version>
  41.         </dependency>
  42.         <!--mysql-connector-java-->
  43.         <dependency>
  44.             <groupId>mysql</groupId>
  45.             <artifactId>mysql-connector-java</artifactId>
  46.         </dependency>
  47.         <!--jdbc-->
  48.         <dependency>
  49.             <groupId>org.springframework.boot</groupId>
  50.             <artifactId>spring-boot-starter-jdbc</artifactId>
  51.         </dependency>
  52.         <dependency>
  53.             <groupId>org.springframework.boot</groupId>
  54.             <artifactId>spring-boot-devtools</artifactId>
  55.             <scope>runtime</scope>
  56.             <optional>true</optional>
  57.         </dependency>
  58.         <dependency>
  59.             <groupId>org.projectlombok</groupId>
  60.             <artifactId>lombok</artifactId>
  61.             <optional>true</optional>
  62.         </dependency>
  63.         <dependency>
  64.             <groupId>org.springframework.boot</groupId>
  65.             <artifactId>spring-boot-starter-test</artifactId>
  66.             <scope>test</scope>
  67.         </dependency>
  68.     </dependencies>
  69. </project>

3、改yml
参考8001 但是端口号得修改为8002

  1. server:
  2.   port: 8002
  4. spring:
  5.   application:
  6.     name: cloud-payment-service
  7.   datasource:
  8.     type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
  9.     driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
  10.     url: jdbc:mysql://localhost:3306/db2022?useUnicode=true&characterEncoding=utf-8&useSSL=false
  11.     username: root
  12.     password: 123456
  14. eureka:
  15.   client:
  16.     #表示是否将自己注册进EurekaServer默认为true。
  17.     register-with-eureka: true
  18.     #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
  19.     fetchRegistry: true
  20.     service-url:
  21.       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版
  22.       #defaultZone: http://localhost:7001/eureka  # 单机版
  25. mybatis:
  26.   mapperLocations: classpath:mapper/*.xml
  27.   type-aliases-package: com.guang.springcloud.entities    # 所有Entity别名类所在包

4、主启动类

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

5、业务类（直接从8001复制粘贴过来）
但是为了知道从那个服务中获取到的数据，所以在返回结果的数据中加上服务端口号。
注意：服务8001也需要返回其端口号

  1.     @Value("${server.port}")
  2.     private String serverPort;
  4. CommonResult(200,"插入数据库成功,服务端口："+serverPort,result);

6、由于80服务的端口是写死的，所以要将其写成对外开放的服务名
在80服务的接口上将访问地址改为对外的服务名

  1. //    http://CLOUD-PAYMENT-SERVICE
  2. //    public static final String Payment_URL="http://localhost:8001/payment";
  3.     public static final String Payment_URL="http://CLOUD-PAYMENT-SERVICE";

7、Restemplate做负载均衡
否则访问服务时，将会值访问8001服务，而不会对8002服务进行访问

  1. @Configuration
  2. public class RestTamplateConfig {
  3.     @Bean
  4.     @LoadBalanced
  5.     public RestTemplate getRestTemplate(){
  6.         return new RestTemplate();
  7.     }
  8. }

8、测试

1.9、actuator完善微服务信息

问题：
image.png
1、主机名称：服务名称修改
添加：instance的instance-id部分
8002与80也做相应的修改

  1. eureka:
  2.   client:
  3.     #表示是否将自己注册进EurekaServer默认为true。
  4.     register-with-eureka: true
  5.     #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
  6.     fetchRegistry: true
  7.     service-url:
  8.       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版
  9.       #defaultZone: http://localhost:7001/eureka  # 单机版
  10.   instance:
  11.     instance-id: payment8001

2、设置访问信息有ip显示
添加部分：prefer-ip-address: true
进驻的服务都得修改

  1. eureka:
  2.   client:
  3.     #表示是否将自己注册进EurekaServer默认为true。
  4.     register-with-eureka: true
  5.     #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
  6.     fetchRegistry: true
  7.     service-url:
  8.       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版
  9.       #defaultZone: http://localhost:7001/eureka  # 单机版
  10.   instance:
  11.     instance-id: payment8001
  12.     prefer-ip-address: true     #访问路径可以显示IP地址

2.0、服务发现Discovery

1、8001的PaymentController

  1.      @Resource
  2.     private DiscoveryClient discoveryClient;
  4.     @GetMapping("/discovery")
  5.     public Object discovery()
  6.     {
  7.         List<String> services = discoveryClient.getServices();
  8.         for (String element : services) {
  9.             System.out.println(element);
  10.         }
  12.         List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
  13.         for (ServiceInstance element : instances) {
  14.             System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t"
  15.                     + element.getUri());
  16.         }
  17.         return this.discoveryClient;
  18.     }

2、主启动类
添加注解@EnableDiscoveryClient //服务发现
3、测试

2.1、Eureka自我保护机制

某时刻某个微服务不可用了，Eureka不会立刻清理，依旧会对该微服务的信息进行保存。属于CAP里面的AP分支

概述
保护模式主要用于一组客户端和Eureka Server之间存在网络分区场景下的保护。一旦进入保护模式，Eureka Server将会尝试保护其服务注册表中的信息，不再删除服务注册表中的数据，也就是不会注销任何微服务。

为什么会产生Eureka自我保护机制？
为了防止EurekaClient可以正常运行，但是 与 EurekaServer网络不通情况下，EurekaServer不会立刻将EurekaClient服务剔除

什么是自我保护模式？
默认情况下，如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳，EurekaServer将会注销该实例（默认90秒）。但是当网络分区故障发生(延时、卡顿、拥挤)时，微服务与EurekaServer之间无法正常通信，以上行为可能变得非常危险了——因为微服务本身其实是健康的，此时本不应该注销这个微服务。Eureka通过“自我保护模式”来解决这个问题——当EurekaServer节点在短时间内丢失过多客户端时（可能发生了网络分区故障），那么这个节点就会进入自我保护模式。

在自我保护模式中，Eureka Server会保护服务注册表中的信息，不再注销任何服务实例。
它的设计哲学就是宁可保留错误的服务注册信息，也不盲目注销任何可能健康的服务实例。一句话讲解：好死不如赖活着

综上，自我保护模式是一种应对网络异常的安全保护措施。它的架构哲学是宁可同时保留所有微服务（健康的微服务和不健康的微服务都会保留）也不盲目注销任何健康的微服务。使用自我保护模式，可以让Eureka集群更加的健壮、稳定。

2.2、如何禁止自我保护

以单机版注册中心为例子
1、Eureka7001.yml

  1. eureka:
  2.   instance:
  3.     hostname: eureka7001.com
  4.   client:
  5.     register-with-eureka: false
  6.     fetch-registry: false
  7.     service-url:
  8.       #defaultZone: http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka
  9.       defaultZone: http://eureka7001.com:7001/eureka
  10.   server:
  11.     #关闭自我保护机制，保证不可用服务被及时踢除,默认为true
  12.     enable-self-preservation: false
  13.     #设置时间间隔为2秒
  14.     eviction-interval-timer-in-ms: 2000

2、payment8001.yml

  1. eureka:
  2.   client: #服务提供者provider注册进eureka服务列表内
  3.     service-url:
  4.       register-with-eureka: true
  5.       fetch-registry: true
  6.       # cluster version
  7.       #defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka
  8.       # singleton version
  9.       defaultZone: http://eureka7001.com:7001/eureka
  10. #心跳检测与续约时间
  11. #开发时设置小些，保证服务关闭后注册中心能即使剔除服务
  12.   instance:
  13.     #Eureka客户端向服务端发送心跳的时间间隔，单位为秒(默认是30秒)
  14.     lease-renewal-interval-in-seconds: 1
  15.     #Eureka服务端在收到最后一次心跳后等待时间上限，单位为秒(默认是90秒)，超时将剔除服务
  16.     lease-expiration-duration-in-seconds: 2

3、测试
关闭服务8001后，Eureka会立即将服务删除，不会继续保留

2、ZooKeeper

1、linux系统安装好zookeeper

关闭防火墙

2、创建服务cloud-provider-payment8004

1、改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>cloud2022</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-provider-payment8004</artifactId>
  15.     <dependencies>
  16.         <!-- SpringBoot整合Web组件 -->
  17.         <dependency>
  18.             <groupId>org.springframework.boot</groupId>
  19.             <artifactId>spring-boot-starter-web</artifactId>
  20.         </dependency>
  21.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  22.             <groupId>com.atguigu.springcloud</groupId>
  23.             <artifactId>cloud-api-commons</artifactId>
  24.             <version>${project.version}</version>
  25.         </dependency>
  26.         <!-- SpringBoot整合zookeeper客户端 -->
  27.         <dependency>
  28.             <groupId>org.springframework.cloud</groupId>
  29.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-devtools</artifactId>
  34.             <scope>runtime</scope>
  35.             <optional>true</optional>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>org.projectlombok</groupId>
  39.             <artifactId>lombok</artifactId>
  40.             <optional>true</optional>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>org.springframework.boot</groupId>
  44.             <artifactId>spring-boot-starter-test</artifactId>
  45.             <scope>test</scope>
  46.         </dependency>
  47.     </dependencies>
  48. </project>

2、改yml

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

3、主启动类

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

4、业务类

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

3、Linux启动zookeeper

4、启动服务8004报错

jar包冲突的问题

5、解决方案

改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>mscloud03</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-provider-payment8004</artifactId>
  15.     <dependencies>
  16.         <!-- SpringBoot整合Web组件 -->
  17.         <dependency>
  18.             <groupId>org.springframework.boot</groupId>
  19.             <artifactId>spring-boot-starter-web</artifactId>
  20.         </dependency>
  21.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  22.             <groupId>com.atguigu.springcloud</groupId>
  23.             <artifactId>cloud-api-commons</artifactId>
  24.             <version>${project.version}</version>
  25.         </dependency>
  26.         <!-- SpringBoot整合zookeeper客户端 -->
  27.         <dependency>
  28.             <groupId>org.springframework.cloud</groupId>
  29.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  30.             <!--先排除自带的zookeeper3.5.3-->
  31.             <exclusions>
  32.                 <exclusion>
  33.                     <groupId>org.apache.zookeeper</groupId>
  34.                     <artifactId>zookeeper</artifactId>
  35.                 </exclusion>
  36.             </exclusions>
  37.         </dependency>
  38.         <!--添加zookeeper3.4.9版本-->
  39.         <dependency>
  40.             <groupId>org.apache.zookeeper</groupId>
  41.             <artifactId>zookeeper</artifactId>
  42.             <version>3.4.9</version>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-devtools</artifactId>
  47.             <scope>runtime</scope>
  48.             <optional>true</optional>
  49.         </dependency>
  50.         <dependency>
  51.             <groupId>org.projectlombok</groupId>
  52.             <artifactId>lombok</artifactId>
  53.             <optional>true</optional>
  54.         </dependency>
  55.         <dependency>
  56.             <groupId>org.springframework.boot</groupId>
  57.             <artifactId>spring-boot-starter-test</artifactId>
  58.             <scope>test</scope>
  59.         </dependency>
  60.     </dependencies>
  61. </project>

6、测试

linux下查看zookeeper是否存在新的节点
查看节点是否可以获得节点的详细信息
访问路由是否可以得到数据

7、zk节点是临时？持久？

将服务注册进zk后，关闭服务后发现，在一定的时间后zk会将该节点清除。

8、服务80进驻zk

1、创建Module=====》cloud-providerzk-order80
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>mscloud</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-consumerzk-order81</artifactId>
  15.     <dependencies>
  16.         <!-- SpringBoot整合Web组件 -->
  17.         <dependency>
  18.             <groupId>org.springframework.boot</groupId>
  19.             <artifactId>spring-boot-starter-web</artifactId>
  20.         </dependency>
  21.         <!-- SpringBoot整合zookeeper客户端 -->
  22.         <dependency>
  23.             <groupId>org.springframework.cloud</groupId>
  24.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  25.             <!--先排除自带的zookeeper-->
  26.             <exclusions>
  27.                 <exclusion>
  28.                     <groupId>org.apache.zookeeper</groupId>
  29.                     <artifactId>zookeeper</artifactId>
  30.                 </exclusion>
  31.             </exclusions>
  32.         </dependency>
  33.         <!--添加zookeeper3.4.9版本-->
  34.         <dependency>
  35.             <groupId>org.apache.zookeeper</groupId>
  36.             <artifactId>zookeeper</artifactId>
  37.             <version>3.4.9</version>
  38.         </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>
  55.     </dependencies>
  56. </project>

3、改yml

  1. server:
  2.   port: 80
  4. spring:
  5.   application:
  6.     name: cloud-consumer-order
  7.   cloud:
  8.   #注册到zookeeper地址
  9.     zookeeper:
  10.       connect-string: 192.168.133.128:2181

4、主启动类

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

5、配置RestTamplate

  1. @Configuration
  2. public class ApplicationContextBean
  3. {
  4.     @Bean
  5.     @LoadBalanced
  6.     public RestTemplate getRestTemplate()
  7.     {
  8.         return new RestTemplate();
  9.     }
  10. }

6、controller

  1. @RestController
  2. public class OrderZKController
  3. {
  4.     public static final String INVOKE_URL = "http://cloud-provider-payment";
  6.     @Autowired
  7.     private RestTemplate restTemplate;
  9.     @GetMapping("/consumer/payment/zk")
  10.     public String paymentInfo()
  11.     {
  12.         String result = restTemplate.getForObject(INVOKE_URL+"/payment/zk", String.class);
  13.         System.out.println("消费者调用支付服务(zookeeper)--->result:" + result);
  14.         return result;
  15.     }
  17. }

7、测试
查看linux下的zk节点
访问服务8004路由
访问服务80路由

3、Consul

下载地址：https://www.consul.io/downloads.html
中文学习文档：https://www.springcloud.cc/spring-cloud-consul.html

1、简介

Consul 是一套开源的分布式服务发现和配置管理系统，由 HashiCorp 公司用 Go 语言开发。

提供了微服务系统中的服务治理、配置中心、控制总线等功能。这些功能中的每一个都可以根据需要单独使用，也可以一起使用以构建全方位的服务网格，总之Consul提供了一种完整的服务网格解决方案。

它具有很多优点。包括： 基于 raft 协议，比较简洁； 支持健康检查, 同时支持 HTTP 和 DNS 协议 支持跨数据中心的 WAN 集群 提供图形界面 跨平台，支持 Linux、Mac、Windows

2、能干嘛

服务发现：提供HTTP和DNS两种发现方式
健康监测：支持等多种方式，HTTP、TCP、Docker、Shell脚本定制化监控
KV存储：key、value的存储方式
多数据中心：Consul支持多数据中心
可视化Web界面

3、下载安装

以windows的consul1.6.1版本为例子
参考官网安装动画、下载安装完成后consul—version 查看版本号
使用consul agent -dev启动consul
测试：http://localhost:8500

4、服务8006进驻consul

1、创建Module====》cloud-providerconsul-payment8006
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>mscloud</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-providerconsul-payment8006</artifactId>
  15.     <dependencies>
  16.         <!--SpringCloud consul-server -->
  17.         <dependency>
  18.             <groupId>org.springframework.cloud</groupId>
  19.             <artifactId>spring-cloud-starter-consul-discovery</artifactId>
  20.         </dependency>
  21.         <!-- SpringBoot整合Web组件 -->
  22.         <dependency>
  23.             <groupId>org.springframework.boot</groupId>
  24.             <artifactId>spring-boot-starter-web</artifactId>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-starter-actuator</artifactId>
  29.         </dependency>
  30.         <!--日常通用jar包配置-->
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-devtools</artifactId>
  34.             <scope>runtime</scope>
  35.             <optional>true</optional>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>org.projectlombok</groupId>
  39.             <artifactId>lombok</artifactId>
  40.             <optional>true</optional>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>org.springframework.boot</groupId>
  44.             <artifactId>spring-boot-starter-test</artifactId>
  45.             <scope>test</scope>
  46.         </dependency>
  47.     </dependencies>
  48. </project>

3、改yml

  1. ###consul服务端口号
  2. server:
  3.   port: 8006
  5. spring:
  6.   application:
  7.     name: consul-provider-payment
  8. ####consul注册中心地址
  9.   cloud:
  10.     consul:
  11.       host: localhost
  12.       port: 8500
  13.       discovery:
  14.         #hostname: 127.0.0.1
  15.         service-name: ${spring.application.name}

4、主启动类

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

5、controller

  1. @RestController
  2. public class PaymentController
  3. {
  4.     @Value("${server.port}")
  5.     private String serverPort;
  7.     @GetMapping("/payment/consul")
  8.     public String paymentInfo()
  9.     {
  10.         return "springcloud with consul: "+serverPort+"\t\t"+ UUID.randomUUID().toString();
  11.     }
  12. }

6、测试
访问localhost:8006/payment/consul 查看服务是否进驻
查看接口访问路径是否得到返回信息

5、服务80进驻consul

1、新建Module====》cloud-consumerconsul-order80
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>mscloud</artifactId>
  7.         <groupId>com.guang.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-consumerconsul-order82</artifactId>
  15.     <dependencies>
  16.          <!--SpringCloud consul-server -->
  17.         <dependency>
  18.             <groupId>org.springframework.cloud</groupId>
  19.             <artifactId>spring-cloud-starter-consul-discovery</artifactId>
  20.         </dependency>
  21.         <!-- SpringBoot整合Web组件 -->
  22.         <dependency>
  23.             <groupId>org.springframework.boot</groupId>
  24.             <artifactId>spring-boot-starter-web</artifactId>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-starter-actuator</artifactId>
  29.         </dependency>
  30.         <!--日常通用jar包配置-->
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-devtools</artifactId>
  34.             <scope>runtime</scope>
  35.             <optional>true</optional>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>org.projectlombok</groupId>
  39.             <artifactId>lombok</artifactId>
  40.             <optional>true</optional>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>org.springframework.boot</groupId>
  44.             <artifactId>spring-boot-starter-test</artifactId>
  45.             <scope>test</scope>
  46.         </dependency>
  47.     </dependencies>
  48. </project>

3、改yml

  1. ###consul服务端口号
  2. server:
  3.   port: 80
  5. spring:
  6.   application:
  7.     name: cloud-consumer-order
  8. ####consul注册中心地址
  9.   cloud:
  10.     consul:
  11.       host: localhost
  12.       port: 8500
  13.       discovery:
  14.         #hostname: 127.0.0.1
  15.         service-name: ${spring.application.name}

4、主启动类

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

5、配置RestTamplate

  1. @Configuration
  2. public class ApplicationContextBean
  3. {
  4.     @Bean
  5.     @LoadBalanced
  6.     public RestTemplate getRestTemplate()
  7.     {
  8.         return new RestTemplate();
  9.     }
  10. }

6、controller

  1. @RestController
  2. public class OrderConsulController
  3. {
  4.     public static final String INVOKE_URL = "http://cloud-provider-payment"; //consul-provider-payment
  6.     @Autowired
  7.     private RestTemplate restTemplate;
  9.     @GetMapping(value = "/consumer/payment/consul")
  10.     public String paymentInfo()
  11.     {
  12.         String result = restTemplate.getForObject(INVOKE_URL+"/payment/consul", String.class);
  13.         System.out.println("消费者调用支付服务(consule)--->result:" + result);
  14.         return result;
  15.     }
  16. }

7、测试
查看localhost:8006/payment/consul 查看服务是否进驻
查看两个接口路由是否得到返回数据

4、三个注册中心的异同

image.png
image.png
CAP==》关注粒度是数据，而不是整体系统设计的策略。
C:Consistency（强一致性）
A:Availability（可用性）
P：Partition tolerance(分区容错性）

最多只能同时较好的满足两个。
CAP理论的核心是：一个分布式系统不可能同时很好的满足一致性，可用性和分区容错性这三个需求，
因此，根据 CAP 原理将 NoSQL 数据库分成了满足 CA 原则、满足 CP 原则和满足 AP 原则三 大类：
CA - 单点集群，满足一致性，可用性的系统，通常在可扩展性上不太强大。
CP - 满足一致性，分区容忍必的系统，通常性能不是特别高。
AP - 满足可用性，分区容忍性的系统，通常可能对一致性要求低一些。

AP:Eureka
AP架构
当网络分区出现后，为了保证可用性，系统B可以返回旧值，保证系统的可用性。
结论：违背了一致性C的要求，只满足可用性和分区容错，即AP
image.png
CP(Zookeeper/Consul)
CP架构
当网络分区出现后，为了保证一致性，就必须拒接请求，否则无法保证一致性
结论：违背了可用性A的要求，只满足一致性和分区容错，即CP
image.png

9、负载均衡服务调用-Ribbon

1、Ribbon(维护模式）

1.1简介

官网：https://github.com/Netflix/ribbon/wiki/Getting-Started
未来替换方案：LoadBalance

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。

简单的说，Ribbon是Netflix发布的开源项目，主要功能是提供客户端的软件负载均衡算法和服务调用。Ribbon客户端组件提供一系列完善的配置项如连接超时，重试等。简单的说，就是在配置文件中列出Load Balancer（简称LB）后面所有的机器，Ribbon会自动的帮助你基于某种规则（如简单轮询，随机连接等）去连接这些机器。我们很容易使用Ribbon实现自定义的负载均衡算法。

1.2能干嘛

负载均衡+RestTemplate

LB(负载均衡)相当于之前RestTemplate的@LoadBalanced

集中式LB
即在服务的消费方和提供方之间使用独立的LB设施(可以是硬件，如F5, 也可以是软件，如nginx), 由该设施负责把访问请求通过某种策略转发至服务的提供方；

进程内LB
将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选择出一个合适的服务器。
Ribbon就属于进程内LB，它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址。

2、Ribbon负载均衡演示

image.png
Ribbon在工作时分成两步
第一步先选择 EurekaServer ,它优先选择在同一个区域内负载较少的server.
第二步再根据用户指定的策略，在从server取到的服务注册列表中选择一个地址。
其中Ribbon提供了多种策略：比如轮询、随机和根据响应时间加权。

10、服务接口调用-OpenFeign

11、Hystrix

12、网关

1、zuul路由网关

1.1、概述简介

Zuul是一种提供动态路由、监视、弹性、安全性等功能的边缘服务。
Zuul是Netflix出品的一个基于JVM路由和服务端的负载均衡器

API网关为微服务架构中的服务提供了统一的访问入口，客户端通过API网关访问相关服务。API网关的定义类似于设计模式中的门面模式，它相当于整个微服务架构中的门面，所有客户端的访问都通过它来进行路由及过滤。它实现了请求路由、负载均衡、校验过滤、服务容错、服务聚合等功能。

image.png
》代理
》路由
》负载均衡
网关为入口，由网关与微服务进行交互，所以网关必须要实现负载均衡的功能；
网关会获取微服务注册中心里面的服务连接地址，再配合一些算法选择其中一个服务地址，进行处理业务。
这个属于客户端侧的负载均衡，由调用方去实现负载均衡逻辑。
image.png

1.2、路由基本配置

功能：路由功能负责将外部请求转发到具体的服务实例上去，是实现统一访问入口的基础
1、新建Module模块cloud-zuul-gateway9527
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>mscloud</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-zuul-gateway9527</artifactId>
  13.     <dependencies>
  14.         <dependency>
  15.             <groupId>org.springframework.cloud</groupId>
  16.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  17.         </dependency>
  18.         <dependency>
  19.             <groupId>org.springframework.cloud</groupId>
  20.             <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
  21.         </dependency>
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter-actuator</artifactId>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-devtools</artifactId>
  30.             <scope>runtime</scope>
  31.             <optional>true</optional>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>org.projectlombok</groupId>
  35.             <artifactId>lombok</artifactId>
  36.             <optional>true</optional>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>org.springframework.boot</groupId>
  40.             <artifactId>spring-boot-starter-test</artifactId>
  41.             <scope>test</scope>
  42.         </dependency>
  43.     </dependencies>
  44. </project>

3、yml

  1. server:
  2.   port: 9527
  4. spring:
  5.   application:
  6.     name: cloud-zuul-gateway
  8. eureka:
  9.   client:
  10.     service-url:
  11.       #defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka
  12.       defaultZone: http://eureka7001.com:7001/eureka
  13.   instance:
  14.     instance-id: gateway-9527.com
  15.     prefer-ip-address: true

4、修改hosts文件
127.0.0.1 myzuul.com
5、主启动类

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

6、启动项目
》三个eureka集群
》一个服务提供者microservicecloud-provider-dept-8001
》一个路由
7、测试
不用路由：localhost:8001/paymentInfo
启用路由：
>zuul映射配置+注册中心注册后对外暴露的服务名称+rest调用地址
>myzuul.com:9527/cloud-provider-payment/paymentInfo

1.3、路由访问映射规则