SpringCloud笔记2.md

SpringCloud笔记2

---

一、SpringCloud 相关介绍

1、SpringCloud 和 SpringBoot 版本选型

1）、Springboot 版本选择

SpringBoot 官方建议升级到 2.X 以上版本，并且提供了迁移指南。

2）、SpringCloud 版本选择

• SpringCloud 的版本是以伦敦地铁站英文首字母来作为版本号的命名。由地铁站名称字母 A-Z 依次类推的形式来发布迭代版本。
• 因为 SpringCloud 是一个由许多子项目组成的综合项目，各子项目有不同的发布节奏。为了管理 SpringCloud 与各个子项目的版本依赖关系，发布了一个清单，其中包括了某个 SpringCloud 版本对应的子项目版本。为了避免 SpringCloud 版本号与子项目版本版本号混淆，SpringCloud 采用了名称而非版本号的命名，这些版本的名字采用了伦敦地铁站的名字，根据字母表的顺序来对应版本时间顺序。
• 当 SpringCloud 的发布内容积累到临界点或者一个重大 bug 被解决后，会发布一个 "service releases" 版本，简称 SRX 版本。比如 Greenwich.SRX2 就是 SpringCloud 发布的 Greenwich 版本的第 2 个 SRX 版本。

3）、SpringBoot 和 SpringCloud 版本对应关系

① 版本对应关系

② 更详细的版本对应查看方法

可以通过这个网址去进行查看：

https://start.spring.io/actuator/info

③ 官网版本查看

进入 springcloud 的官网，选择一个你想用的 springcloud 的版本，然后点进去会发现在官网中会推荐你使用一个相应的 springboot 版本。

注：

• 如果只用 springboot 那么直接使用最小版本即可。
• 如果同时使用 springboot 和 springcloud ，需要照顾 springcloud ，由 springcloud 决定 springboot 的版本。

二、服务工程构建

1、创建父工程

Pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>springcloud2020</artifactId>
    <version>1.0-SNAPSHOT</version>
    <!-- 父工程，打包方式为 pom,不再是默认的 jar -->
    <packaging>pom</packaging>

    <!-- 统一管理 jar 包版本 -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <junit.version>4.12</junit.version>
        <log4j.version>1.2.17</log4j.version>
        <lombok.version>1.16.18</lombok.version>
        <mysql.version>5.1.47</mysql.version>
        <druid.version>1.1.16</druid.version>
        <mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version>
    </properties>
    
    <!--子模块继承之后，提供作用：锁定版本 + 子module 不用写 groupId 和 version-->
    <dependencyManagement>

    </dependencyManagement>

    <dependencies>
        <!--SpringBoot 版本-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>2.2.2.RELEASE</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>

        <!--Springcloud 版本-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Hoxton.SR1</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>

        <!--Springcloud alibaba 版本-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>2.1.0.RELEASE</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.version}</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>${druid.version}</version>
        </dependency>

        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>${mybatis.spring.boot.version}</version>
        </dependency>
    </dependencies>


</project>

小知识：

Maven 依赖中 <dependencyManagement></dependencyManagement> 的作用：

答：Maven 中使用 dependencyManagement 元素提供了一种管理依赖版本号的方式。通常会在一个组织或者项目的最顶层父 POM 中看到 dependencyManagement 元素。

使用 dependencyManagement 元素能让所有在子项目中引用一个依赖而不用显示的列出版本号，Maven 会沿着父子层次向上走，直到找到一个拥有 dependencyManagement 元素的项目，然后它就会使用这个 dependencyManagement 元素中指定的版本号。

注意：

1、dependencyManagement 里面只是声明依赖，并不实现引入，因此子项目需要显示的声明需要用的依赖

2、如果不在子项目中声明依赖，是不会从父项目中继承下来的，只有在子项目中写了该依赖项，并且没有指定具体版本，才会从父项目中继承该项，并且 version 和 scope 都读取自父 pom

3、如果子项目中指定了版本号，那会使用子项目中指定的版本

2、支付模块构建

1）、创建一个服务提供者 springcloud-provider-payment8001

① pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud2020</artifactId>
        <groupId>com.hepingfly.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.hepingfly.springcloud</groupId>
    <artifactId>springcloud-provider-payment8001</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.2.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
            <version>1.5.9.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.0</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.44</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.10</version>
        </dependency>
    </dependencies>
</project>

② 相关 Java 代码

// controller 代码-----------------------------------------------------------------------------
/**
 * @auther hepingfly
 * @date 2020/11/8 9:00 下午
 */
@RestController
public class PaymentController {

    @Resource
    private PaymentService paymentService;

    @PostMapping("/payment/save")
    public Result save(Payment payment) {
        int result = paymentService.save(payment);
        if (result > 0) {
            return new Result(200,"插入成功");
        } else {
            return new Result(444, "插入失败");
        }
    }

    @GetMapping("/payment/get/{id}")
    public Result getPaymentById(@PathVariable("id") Long id) {
        Payment payment = paymentService.getPaymentById(id);
        if (payment != null) {
            return new Result(200, "查询成功", payment);
        } else {
            return new Result(444, "没有对应的记录", null);
        }
    }
}

// service 代码--------------------------------------------------------------------------------

/**
 * @auther hepingfly
 * @date 2020/11/5 9:33 下午
 */
@Service
public class PaymentServiceImpl implements PaymentService {

    @Resource
    private PaymentDAO paymentDAO;
    @Override
    public int save(Payment payment) {
        return paymentDAO.save(payment);
    }

    @Override
    public Payment getPaymentById(Long id) {
        return paymentDAO.getPaymentById(id);
    }
}

3、热部署使用

代码改动之后可以自动重启生效，而不需要你手动去进行重启。

① 引入 maven 依赖到 pom 文件中

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-devtools</artifactId>
    <version>1.5.9.RELEASE</version>
    <scope>runtime</scope>
    <optional>true</optional>
</dependency>

② 添加 maven 插件到 pom 文件中

<build>
    <finalName>springcloud2020</finalName>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
            <version>2.3.4.RELEASE</version>
            <configuration>
                <fork>true</fork>
                <addResources>true</addResources>
            </configuration>
        </plugin>
    </plugins>
</build>

注：

这个可以放在父工程中。

③ 开启 idea 自动编译

④ 使用快捷键修改 idea 中 registry 值

windows 下使用： ctrl + shift + alt + / 然后选 Registry

mac 下使用 ： ctrl + shift + option + / 然后选 Registry

⑤ 重启 idea

4、订单模块构建

1）、创建一个服务消费者 springcloud-consumer-order80

① pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud2020</artifactId>
        <groupId>com.hepingfly.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>springcloud-consumer-order80</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.2.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
            <version>1.5.9.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.10</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

② 相关 Java 代码

// controller 代码-----------------------------------------------------------------------------
/**
 * @auther hepingfly
 * @date 2020/12/7 10:42 下午
 */
@RestController
@Slf4j
public class OrderController {

    /**
     * 1、RestTemplate 是什么？
     * RestTemplate 提供了多种便捷访问远程 Http 服务的方法
     * 是一种简单便捷的访问 restful 服务模板类，是 Spring 提供的用于访问
     * Rest 服务的客户端模板工具类
     *
     * 2、如何使用
     * 使用 restTemplate 访问 restful 接口非常的简单粗暴
     * (url,requestMap,ResponseBean.class) 三个参数分别表示：
     * Rest请求地址，请求参数，HTTP 响应被转换的对象类型
     */
    @Resource
    private RestTemplate restTemplate;

    public static final String PAYMENT_URL = "http://localhost:8001";

    @GetMapping("/consumer/payment/save")
    public Result<Payment> save(Payment payment) {
        return restTemplate.postForObject(PAYMENT_URL + "/payment/save", payment, Result.class);
    }

    @GetMapping("/consumer/payment/get/{id}")
    public Result<Payment> getPayment(@PathVariable("id") Long id) {
        return restTemplate.getForObject(PAYMENT_URL + "/payment/get/" + id, Result.class);
    }
}

三、Eureka 相关

1、服务治理

什么是服务治理？

SpringCloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理。在传统的 rpc 远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，所以需要使用服务治理，管理服务与服务之间依赖关系，可以实现服务调用、负载均衡、容错等，实现服务注册与发现。

2、服务注册与发现

1）、服务注册与发现

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

3、Eureka 组件

Eureka 包含两个组件：Eureka Server 和 Eureka Client

• Eureka Server 提供服务注册服务
  • 各个微服务节点通过配置启动后，会在 EurekaServer 中进行注册，这样 Eureka Server服务注册表中将会存储所有可用服务节点信息，并且服务节点的信息可以在界面中直观的看到。
• Eureka Client 通过注册中心进行访问
  • 是一个 Java 客户端，用于简化 EurekaServer 的交互，客户端同时也具备一个内置的、使用轮询负载算法的负载均衡器。应用启动后，将会向 EurekaServer 发送心跳（默认周期是 30s）。如果 Eureka Server 在多个心跳周期内没有接收到某个节点的心跳，Eureka Server 将会从服务注册表中把这个服务节点移除（默认 90s）

4、编码实现

1）、创建一个 Eureka Server springcloud-eureka-server7001

① pom.xml

<parent>
        <artifactId>springcloud2020</artifactId>
        <groupId>com.hepingfly.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>springcloud-eureka-server7001</artifactId>

    <dependencies>
        <!--eureka server-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            <version>2.2.9.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>com.hepingfly.springcloud</groupId>
            <artifactId>springcloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.2.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
            <version>1.5.9.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.10</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

这里需要注意的是：

Eureka Server1.X 和 2.X 版本依赖的区别：

旧版本：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
    <version>2.2.9.RELEASE</version>
</dependency>

新版本：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    <version>2.2.9.RELEASE</version>
</dependency>

② application.yml

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

2）、把服务提供者注册进 Eureka

① 修改 pom 文件

旧版本：

<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-eureka</artifactId>
 <version>2.2.9.RELEASE</version>
</dependency>

新版本：

<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
 <version>2.2.9.RELEASE</version>
</dependency>

② 修改 application.yml 配置文件，添加下面 eureka 的配置信息

eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka
    #表示是否将自己注册进 eureka
    register-with-eureka: true
    # 是否从 eurekaserver 抓取已有的注册信息。单节点无所谓，集群必须设置为 true才能配合 ribbon 使用负载均衡
    fetch-registry: true

③ 修改主启动类，添加 eureka 客户端注解

@SpringBootApplication
@EnableEurekaClient       // Eureka 客户端注解
public class Application {
    public static void main(String[] args) throws ParserConfigurationException {
        DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
        documentBuilderFactory.setFeature("http://apache.org/xml/features/disallow-doctype-decl", true);
        SpringApplication.run(Application.class, args);
    }
}

5、集群 eureka 搭建

1）、搭建步骤

新建另 一个 Eureka Server springcloud-eureka-server7002

① pom 文件和 springcloud-eureka-server7001 保持一致

② application.yml 文件

----------------------------先看单机版配置文件-----------------------
eureka:
  instance:
    hostname: localhost   #eureka 服务端实例名称
  client:
    # flase 表示不向注册中心注册自己
    register-with-eureka: false
    # false 表示自己就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与 eureka server 交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
      
--------------------------server7001 配置文件 -------------------------
server:
  port: 7001
eureka:
  instance:
    hostname: eureka7001.com   #eureka 服务端实例名称
  client:
    # flase 表示不向注册中心注册自己
    register-with-eureka: false
    # false 表示自己就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与 eureka server 交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://eureka7002.com:7002/eureka/  #7001 这台 server 需要把服务注册进 7002 中，7002 也要把服务注册进7001 中，相互注册，相互守望

--------------------------server7002 配置文件 -------------------------

server:
  port: 7002
eureka:
  instance:
    hostname: eureka7002.com   #eureka 服务端实例名称
  client:
    # flase 表示不向注册中心注册自己
    register-with-eureka: false
    # false 表示自己就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与 eureka server 交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://eureka7001.com:7001/eureka/  #7002 需要把服务注册进 7001 中

2）、将支付服务发布到 eureka 集群中

springcloud-provider-payment8001 服务发布到 eureka 集群中

① 修改 application.yml 文件

# ---------------------单机版配置--------------------
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka
    #表示是否将自己注册进 eureka
    register-with-eureka: true
    # 是否从 eurekaserver 抓取已有的注册信息。单节点无所谓，集群必须设置为 true才能配合 ribbon 使用负载均衡
    fetch-registry: true
 
# ---------------------集群版配置--------------------
eureka:
  client:
    service-url:
      # 集群版 eureka 配置
    defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
    #表示是否将自己注册进 eureka
    register-with-eureka: true
    # 是否从 eurekaserver 抓取已有的注册信息。单节点无所谓，集群必须设置为 true才能配合 ribbon 使用负载均衡
    fetch-registry: true

3）、将订单服务发布到 eureka 集群中

springcloud-consumer-order80 服务发布到 eureka 集群中

① 修改 application.yml 文件

# ---------------------单机版配置--------------------
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka
    #表示是否将自己注册进 eureka
    register-with-eureka: true
    # 是否从 eurekaserver 抓取已有的注册信息。单节点无所谓，集群必须设置为 true才能配合 ribbon 使用负载均衡
    fetch-registry: true
    
# ---------------------集群版配置--------------------
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
    #表示是否将自己注册进 eureka
    register-with-eureka: true
    # 是否从 eurekaserver 抓取已有的注册信息。单节点无所谓，集群必须设置为 true才能配合 ribbon 使用负载均衡
    fetch-registry: true

6、支付服务集群搭建

1）、搭建步骤

新建另 一个 支付服务（服务提供者） springcloud-provider-payment8002

① pom 文件和 springcloud-provider-payment8001 保持一致

② application.yml 文件

server:
  port: 8002

spring:
  application:
  # 应用名称都叫 springcloud-payment-service ，只不过一个名称下面可能有 8001，8002 多个服务
    name: springcloud-payment-service  
    
eureka:
  client:
    service-url:
      # 集群版 eureka 配置
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
    #表示是否将自己注册进 eureka
    register-with-eureka: true
    # 是否从 eurekaserver 抓取已有的注册信息。单节点无所谓，集群必须设置为 true才能配合 ribbon 使用负载均衡
    fetch-registry: true

③ 修改服务消费者的请求地址

// --------------------原始的服务消费者---------------------
@RestController
@Slf4j
public class OrderController {
    @Resource
    private RestTemplate restTemplate;

    public static final String PAYMENT_URL = "http://localhost:8001";

    @GetMapping("/consumer/payment/save")
    public Result<Payment> save(Payment payment) {
        return restTemplate.postForObject(PAYMENT_URL + "/payment/save", payment, Result.class);
    }

    @GetMapping("/consumer/payment/get/{id}")
    public Result<Payment> getPayment(@PathVariable("id") Long id) {
        return restTemplate.getForObject(PAYMENT_URL + "/payment/get/" + id, Result.class);
    }
}


// --------------------现在的服务消费者---------------------
@RestController
@Slf4j
public class OrderController {
    @Resource
    private RestTemplate restTemplate;
	
    // 请求地址修改为直接根据应用名称，来源于配置文件中 spring 的应用名称
    public static final String PAYMENT_URL = "http://springcloud-payment-service ";

    @GetMapping("/consumer/payment/save")
    public Result<Payment> save(Payment payment) {
        return restTemplate.postForObject(PAYMENT_URL + "/payment/save", payment, Result.class);
    }

    @GetMapping("/consumer/payment/get/{id}")
    public Result<Payment> getPayment(@PathVariable("id") Long id) {
        return restTemplate.getForObject(PAYMENT_URL + "/payment/get/" + id, Result.class);
    }
}

注：

上面都操作完了以后，可能会存在一个问题，就是找不到对应的主机名称。

因为一个 springcloud-payment-service 应用名称下面有 2 个服务，8001 和 8002。服务消费者去访问的时候它不知道访问哪个，所以会报找不到对应的主机名称。

解决方式：

在服务消费者的 restTemplate 中添加负载均衡注解

@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced  // 添加负载均衡注解，赋予 RestTemplate 负载均衡的能力，默认是轮询
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

7、服务发现 Discovery

1）、简介

对于注册进 eureka 里面的微服务，可以通过服务发现来获得该服务的信息。简单来说，就是拿到注册进 eureka 里面的服务的信息。

① 修改 springcloud-provider-payment8001

@RestController
public class PaymentController {

    @Resource
    private PaymentService paymentService;

    /**
     * 服务发现客户端，通过这个 discoveryClient 可以获取注册进 eureka 的服务信息
     */
    @Resource
    private DiscoveryClient discoveryClient;

    @GetMapping("/payment/discovery")
    public Object discovery() {
        /**
         * 获取到的是注册进 eureka 里面有哪几个服务（服务列表）
         * 相当于 eureka 里面有几个配置文件spring.application.name 的值
         */
        List<String> services = discoveryClient.getServices();
        for (String service: services) {
            System.out.println("服务列表" + service);
        }
        /**
         * 获取一个服务下面有多少个实例
         * springcloud-payment-service 这个服务名称下面有两个服务实例
         */
        List<ServiceInstance> instances = discoveryClient.getInstances("springcloud-payment-service");
        for (ServiceInstance instance : instances) {
            // 这个服务实例的相关信息都可以拿到
            System.out.println(instance.getServiceId() + instance.getHost() + instance.getPort() + instance.getUri());
        }
        return this.discoveryClient;
    }
}

② 修改主启动类

@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient  // 添加开启服务发现注解
public class Application {
    public static void main(String[] args) throws ParserConfigurationException {
        DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
        documentBuilderFactory.setFeature("http://apache.org/xml/features/disallow-doctype-decl", true);
        SpringApplication.run(Application.class, args);
    }
}

8、eureka 自我保护

1）、概述

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

2）、故障现象

3）、禁止自我保护

① Eureka Server 端

eureka:
  server:
    # 禁用自我保护模式，这样不可用的服务会被及时剔除
    enable-self-preservation: false
    # 间隔时间，单位是毫秒
    eviction-interval-timer-in-ms: 2000

② 客户端

eureka:
  instance:
    # eureka 客户端向服务端发送心跳的时间间隔，单位是秒（默认是 30s）
    lease-renewal-interval-in-seconds: 1
    # eureka 服务端在收到最后一次心跳后等待时间上限，单位是秒（默认是 90s），超时将剔除服务
    lease-expiration-duration-in-seconds: 2

9、eureka 停更

四、SpringCloud整合 Zookeeper 代替 Eureka

1、zookeeper 作为注册中心

• zookeeper 是一个分布式协调工具，可以实现注册中心的功能
• 需要关闭 Linux 防火墙后启动 zookeeper 服务器
• 用 zookeeper 服务器取代 Eureka 服务器，zk 作为服务注册中心

2、服务提供者

① pom 文件

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.2.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>com.hepingfly.springcloud</groupId>
            <artifactId>springcloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!--springcloud 整合 zookeeper 客户端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
            <version>3.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.10</version>
        </dependency>
    </dependencies>

② 配置文件 application.yml

server:
  port: 8004
spring:
  application:
    # 注册到 zookeeper 的服务名称
    name: springcloud-provider-payment
  cloud:
    zookeeper:
      connect-string: 192.168.1.110:2181

③ 主启动类

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

④ controller

@RestController
public class PaymentController {
    @Value("${server.port}")
    private String port;
    @RequestMapping(value = "/payment/zk")
    public String paymentZK() {
        return "springcloud with zk" + port + UUID.randomUUID().toString();
    }
}

注意：

之后启动的时候可能会存在一个问题，因为我们在 pom 文件中引入了一个依赖 spring-cloud-starter-zookeeper-discovery 这个依赖会帮我们导入 zookeeper 的 jar 包，如果导入的这个 jar 包和服务器上安装的 zookeeper 版本不一致的话，就会报 jar 包冲突。

解决方式：

排除冲突的 zookeeper jar 包，引入新的 jar 包。

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
    <version>3.0.0</version>
    <!--排除自带的 zookeeper -->
    <exclusions>
        <exclusion>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
        </exclusion>
    </exclusions>
</dependency>

<!--添加新的 zookeeper 版本，该 zookeeper 版本和服务器上的 zookeeper 版本一致-->
<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.6</version>
</dependency>

解决完这个问题后，你启动应用，就会自动把当前应用名称注册到 zookeeper 中，对应 zookeeper 根节点下面也会多一个 service 节点。

3、临时节点还是永久节点

微服务应用注册到 zookeeper 后，在 zookeeper 节点下面会自动创建节点，但是这个节点是临时节点还是永久节点呢？

如果这个时候，你把微服务应用停掉，过一会（不是立刻）你会发现 zookeeper 下面的节点不存在了，因此它是临时节点。

五、Consul 相关

1、consul 简介

1）、consul 简单说明

• consul 是一套开源的分布式服务发现和配置管理系统，由 HashiCrop 公司用 Go 语言开发。
• consul 提供了微服务系统中的服务治理，配置中心，控制总线等功能。这些功能中的每一个都可以根据需要单独使用，也可以一起使用以构建全方位的服务网格。总之，consul 提供了一种完整的服务网格解决方案。

2）、consul 可以做哪些事

• 服务发现
  • 提供 HTTP 和 DNS 两种发现方式
• 健康检查
  • 支持多种方式。HTTP 、TCP、Docker、Shell 脚本定制化
• KV 存储
  • Key Value 的存储方式
• 多数据中心
  • Consul 支持多数据中心
• 可视化 web 界面

3）、consul 中文文档

https://www.springcloud.cc/spring-cloud-consul.html

2、服务提供者注册进 consul

① pom 文件

<dependencies>
    <!--springcloud consul-server -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        <version>3.0.0</version>
    </dependency>

    <!--springboot 整合 web 组件-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>2.2.2.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.18.10</version>
    </dependency>
</dependencies>

② 配置文件 application.yml

server:
  port: 8006
spring:
  application:
    # 注册到 consul 的服务名称
    name: consul-provider-payment
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        service-name: ${spring.application.name}

③ 主启动类

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

④ controller

@RestController
public class PaymentController {

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

    @RequestMapping(value = "/payment/consul")
    public String paymentConsul() {
        return "springcloud with consul" + port + UUID.randomUUID().toString();
    }
}