一、SpringCloud概念

业务场景介绍：
        开发一个电商网站,要实现支付订单的功能,流程如下：
        创建一个订单之后,如果用户立刻支付了这个订单,我们需要将订单状态更新为“已支付”
        扣减相应的商品库存
        通知仓储中心,进行发货
        给用户的这次购物增加相应的积分
服务分析
        订单服务、库存服务、仓储服务、积分服务
流程调用
        用户针对一个订单完成支付之后，就会去找订单服务，更新订单状态
        订单服务调用库存服务，完成相应功能
        订单服务调用仓储服务，完成相应功能
        订单服务调用积分服务，完成相应功能

 SpringCloud:

基本组件 

1、SpringCloud核心组件：Eureka
Eureka是微服务架构中的注册中心，专门负责服务的注册与发现。
订单服务想要调用库存服务、仓储服务，或者是积分服务，怎么调用？
订单服务压根儿就不知道人家库存服务在哪台机器上啊！他就算想要发起一个请求，都不知道发送给谁，有心无力！

  Eureka Client：负责将这个服务的信息注册到Eureka Server中
Eureka Server：注册中心，里面有一个注册表，保存了各个服务所在的机器和端口号

Spring Cloud核心组件：Feign

现在订单服务确实知道库存服务、积分服务、仓库服务在哪里了，同时也监听着哪些端口号了。
但是新问题又来了：如何从订单服务跟其他服务建立网络连接，接着发送请求过去。

 Spring Cloud核心组件：Ribbon

集群服务：库存服务部署在了5台机器上
192.168.169:9000
192.168.170:9000
192.168.171:9000
192.168.172:9000
192.168.173:9000
Ribbon就是专门解决这个问题的。它的作用是负载均衡，会帮你在每次请求时选择一台机器，均匀的把请求分发到各个机器上
首先Ribbon会从 Eureka Client里获取到对应的服务注册表，也就知道了所有的服务都部署在了哪些机器上，在监听哪些端口号。
然后Ribbon就可以使用默认的Round Robin算法，从中选择一台机器

出现问题：
微服务架构中的服务雪崩问题

如果系统处于高并发的场景下，大量请求涌过来的时候，订单服务的
100
个线程都会卡在请求积分

服务这块。导致订单服务没有一个线程可以处理请求

然后就会导致别人请求订单服务的时候，发现订单服务也挂了，不响应任何请求了

Hystrix
是隔离、熔断以及降级的一个框架。

比如订单服务请求库存服务是一个线程池，请求仓储服务是一个线程池，请求积分服务是一个线程池。

每个线程池里的线程就仅仅用于请求那个服务

积分服务挂了

会导致订单服务里的那个用来调用积分服务的线程都卡死不能工作！

但是由于订单服务调用库存服务、仓储服务的这两个线程池都是正常工作的，所以这两个服务不会受到

任何影响。

———————————————————————-

这个时候如果别人请求订单服务，订单服务还是可以正常调用库存服务扣减库存，调用仓储服务通知发

货。

只不过调用积分服务的时候，每次都会报错。但是如果积分服务都挂了，每次调用都要去卡住几秒钟！

所以我们直接对积分服务熔断不就得了，比如在
5
分钟内请求积分服务直接就返回了，不要去走网络请求

卡住几秒钟，这个过程，就是所谓的熔断！

那人家又说，兄弟，积分服务挂了你就熔断，好歹你干点儿什么啊！别啥都不干就直接返回啊？

没问题，咱们就来个降级：

每次调用积分服务，你就在数据库里记录一条消息，说给某某用户增加了多少积分，因为积分服务挂

了，导致没增加成功！

这样等积分服务恢复了，你可以根据这些记录手工加一下积分。这个过程，就是所谓的降级。

组件总和

Eureka
：各个服务启动时，
Eureka Client
都会将服务注册到
Eureka Server
，并且
Eureka Client
还

可以反过来从
Eureka Server
拉取注册表，从而知道其他服务在哪里

Ribbon
：服务间发起请求的时候，基于
Ribbon
做负载均衡，从一个服务的多台机器中选择一台

Feign
：基于
Feign
的动态代理机制，根据注解和选择的机器，拼接请求
URL
地址，发起请求

Hystrix
：发起请求是通过
Hystrix
的线程池来走的，不同的服务走不同的线程池，实现了不同服务

调用的隔离，避免了服务雪崩的问题

Zuul
：如果前端、移动端要调用后端系统，统一从
Zuul
网关进入，由
Zuul
网关转发请求给对应的服

务

「阿里开源组件」

Nacos
：阿里巴巴开源产品，一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平

台。

Sentinel
：面向分布式服务架构的轻量级流量控制产品，把流量作为切入点，从流量控制、熔断降

级、系统负载保护等多个维度保护服务的稳定性。

RocketMQ
：一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的

消息发布与订阅服务。

Dubbo
：
Apache Dubbo™
是一款高性能
Java RPC
框架，用于实现服务通信。

Seata
：阿里巴巴开源产品，一个易于使用的高性能微服务分布式事务解决方案。

「阿里商业化组件」

Alibaba Cloud ACM
：一款在分布式架构环境中对应用配置进行集中管理和推送的应用配置中心产

品。

Alibaba Cloud OSS
：阿里云对象存储服务（
Object Storage Service
，简称
OSS
），是阿里云提供

的海量、安全、低成本、高可靠的云存储服务。您可以在任何应用、任何时间、任何地点存储和访

问任意类型的数据。

Alibaba Cloud SchedulerX
：阿里中间件团队开发的一款分布式任务调度产品，提供秒级、精准、

高可靠、高可用的定时（基于
Cron
表达式）任务调度服务。

Alibaba Cloud SMS
：覆盖全球的短信服务，友好、高效、智能的互联化通讯能力，帮助企业迅速

搭建客户触达通道

二、nacos搭建

1、新建项目,将此项目作为父项目，给子类提供依赖(Maven项目)

2、cloud01项目导入依赖

 packing(打包类型,默认为jar)
pom : 父级项目(pom项目里没有java代码,也不执行任何代码,只是为了聚合工程或传递依赖用的)
jar : 内部调用或者是作服务使用
war : 需要部署的项目
dependencyManagement(管理jar包的版本,让子项目中引用一个依赖而不用显示的列出版本号)
dependencyManagement与dependencies区别:
dependencies即使在子项目中不写该依赖项,那么子项目仍然会从父项目中继承该依赖项（全部继承）
dependencyManagement里只是声明依赖,并不实现引入,因此子项目需要显示的声明需要用的依赖。
如果不在子项目中声明依赖,是不会从父项目中继承下来的。
只有在子项目中写了该依赖项,并且没有指定具体版本,才会从父项目中继承该项,并且version和scope都读取自父pom。
另外如果子项目中指定了版本号,那么会使用子项目中指定的jar版本。
modules(用来管理同个项目中的各个模块)

<?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>Cloud_01</artifactId>
  <version>1.0-SNAPSHOT</version>
  <packaging>pom</packaging>

  <modules>
    <module>nacos_provider</module>
    <module>nacos_consumer</module>
  </modules>

  <name>Cloud_01 Maven Webapp</name>
  <!-- FIXME change it to the project's website -->
  <url>http://www.example.com</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.7</maven.compiler.source>
    <maven.compiler.target>1.7</maven.compiler.target>
    <spring-boot.version>2.4.1</spring-boot.version>
    <spring-cloud.version>2020.0.0</spring-cloud.version>
    <spring-cloud-alibaba.version>2021.1</spring-cloud-alibaba.version>
  </properties>

  <dependencies>

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>com.alibaba.cloud</groupId>
      <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
    </dependency>

  </dependencies>

  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-dependencies</artifactId>
        <version>${spring-boot.version}</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency> <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-dependencies</artifactId>
      <version>${spring-cloud.version}</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
      <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-alibaba-dependencies</artifactId>
        <version>${spring-cloud-alibaba.version}</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>

</project>

3、下载nacos服务

①、nacos官网：nacos官网

选择第二个

②、启动服务：

 咱们就使用cmd文件进行启动：startup.cmd

 ③、打开页面： 

会有一个地址,复制进去nacos的主界面，并且登录 

 ④、将自带的sql脚本导入数据库：

⑥、打开application.properties文件(这个文件在下载完nacos后的一个conf文件目录下面)

新增以下连接数据库内容：并重新启动

spring.datasource.platform=mysql
db.num=1
db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?
characterEncoding=utf-8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useUnicode=true&useSSL=false&serverTimezone=UTC
db.user.0=root
db.password.0=123456

 2、新建子项目：生产者项目(此时新建的项目为Spring Initializr项目)

 ①、子项目需要认父：pom.xml(我们要去pom文件中修改，相当于找个爹)

<parent>
    <artifactId>Cloud_01</artifactId>
    <groupId>org.example</groupId>
    <version>1.0-SNAPSHOT</version>
</parent>

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.provider</groupId>
    <artifactId>code</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>nacos_provider</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <artifactId>Cloud_01</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-boot.version>2.4.1</spring-boot.version>
    </properties>

    <dependencies>

    </dependencies>

    <dependencyManagement>

    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.4.1</version>
                <configuration>
                    <mainClass>com.provider.code.NacosProviderApplication</mainClass>
                </configuration>
                <executions>
                    <execution>
                        <id>repackage</id>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>

</project>

②、父项目需要认子：pom.xml(相当于上面，有人认你当爹，你要承认这个儿子)

<modules>
  <module>nacos_provider</module>
</modules>

③、配置yml文件

spring:
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
        # host文件中配置
  application:
    name: nacos-provider
server:
  port: 8081

④、在启动类加入注解

@EnableDiscoveryClient

运行：

 成功，并在nacos中产生服务

3、新建子项目：消费者项目

①、子项目需要认父：pom.xml，将不需要的依赖删掉，如生产者的

<parent>
    <artifactId>Cloud_01</artifactId>
    <groupId>org.example</groupId>
    <version>1.0-SNAPSHOT</version>
</parent>

 ②、父项目需要认子：pom.xml

<modules>
  <module>nacos_provider</module>
  <module>nacos_consumer</module>
</modules>

③、配置yml文件

spring:
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
  application:
    name: nacos-consumer
server:
  port: 8082

④、在启动类加入注解

@EnableDiscoveryClient

三、方法调用

例子：生产者生产物品，消费者拿

1、生产者

①、建个controller层：生产任务

package com.provider.code;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ProviderController {

    @RequestMapping("/run")
    public  String run(){
        return "任务";
    }

}

2、消费者

①、 在启动类写域名访问的一个对象

package com.consumer.code;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableDiscoveryClient
public class NacosConsumerApplication {


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

    //RestTemplate  域名访问的一个对象
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

②、controller层调用对象：ConsumerController 

package com.consumer.code;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;


@RestController
public class ConsumerController {

    private RestTemplate template;

    @Autowired
    public ConsumerController(RestTemplate template) {
        this.template = template;
    }

    @RequestMapping("/run")
    public String run(){
        //消费者找生产者读取一个任务(要做跨服务器访问)
        return template.getForObject("http://127.0.0.1:8081/run",String.class);
    }

}

 这样消费者也可以取到任务了

3、消费者调用路径写死的解决方案

①、去nacos中找到服务名称

②、将此名称放入路径中

return template.getForObject(“http://nacos-provider/run”,String.class); 

③、在消费者内导入依赖（负载均衡）

ribbon状态:停止更新
替代方案:Spring Cloud Loadbalancer

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-loadbalancer</artifactId>
        </dependency>
    </dependencies>

④、在消费者的启动类NacosConsumerApplication导入注解

 达到负载均衡的目的

see  you