一、SpringCloud是什么？

Spring最擅长的就是集成，把世界上最好的框架拿过来，集成到自己的项目中。
Spring Cloud也是一样，它将现在非常流行的一些技术整合到一起，实现了诸如：配置管理，服务发现，智能路
由，负载均衡，熔断器，控制总线，集群状态等等功能。其主要涉及的组件包括：
Netflix
Eureka：注册中心
Zuul：服务网关
Ribbon：负载均衡
Feign：服务调用
Hystrix：熔断器

1.1 Spring Cloud与Spring Boot版本对应关系

二、服务拆分

2.1 服务拆分案例

例子
	1. 把以往单体架构的的项目里面有N个模块
	2. 我们单独把中间的几个业务拿出来分为N个小模块

3. 两个模块分别是 用户模块和订单模块
	4. 现在调用两个模块中间是没有任何关联的

5. 当我们想用端口号为8080的订单服务调用端口号为8081的查询用户API时，我们把两个模块分为两个项目来写，我们如何来实现远程调用呢？

2.2 服务拆分-服务远程调用

微服务调用方式

1. 注册RestTemplate
			@MapperScan("cn.itcast.order.mapper")
			@SpringBootApplication
			public class OrderApplication {
			
			    public static void main(String[] args) {
			        SpringApplication.run(OrderApplication.class, args);
			    }
			
			    /** * 创建RestTemplate并注入Spring容器 * @return */
			    @Bean
			    public RestTemplate restTemplate(){
			        return new RestTemplate();
			    }
			}
	2. 服务远程调用RestTemplate
		@Service
		public class OrderService {
		
		    @Autowired
		    private OrderMapper orderMapper;
		    @Autowired
		    private RestTemplate restTemplate;
		    public Order queryOrderById(Long orderId) {
		        // 1.查询订单
		        Order order = orderMapper.findById(orderId);
		        // 2.利用RestTemplate发起HTTP请求，查询用户
		        String url="http://localhost:8081/user/"+order.getUserId();
		        // 2.1发送HTTP请求，实现远程调用，
		        // 第二个参数 告诉RestTemplate我们返回的是User对象，他会自动帮我们把JSON反序列化成User类型
		        User user = restTemplate.getForObject(url, User.class);
		        // 3. 将我们远程调用得到的数据封装到Order中
		        order.setUser(user);
		        // 4.返回
		        return order;
		    }
		}

2.3 提供者与消费者

服务提供者：一次业务中，被其他微服务调用的服务。（提供接口给其他微服务）
服务消费者：一次业务中，调用其他微服务的服务。（调用其他微服务提供的接口）

2.4 Eureka注册中心

2.5 搭建Eureka服务

1. 引入Eureka依赖
			<dependency>
	            <!--eureka服务端依赖            -->
	            <groupId>org.springframework.cloud</groupId>
	            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
	        </dependency>
	2. 编写启动类，添加 @EnableEurekaServer //开启Eureka服务
	3. 添加application.yml添加配置文件
		spring:
		  application:
		    name: eurekaserver #Eureka的服务名称
		eureka:
		  client:
		    service-url:  #eureka地址信息
		      defaultZone: http://127.0.0.1:10086/eureka
	4. 启动成功，打开我们application.yml中eureka的defaultZone：定义的地址就能看见服务

2.6 Eureka服务注册

1. 引入Eureka客户端依赖
			<!--引入 eureka客户端依赖        -->
	        <dependency>
	            <groupId>org.springframework.cloud</groupId>
	            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
	        </dependency>
	2. 添加application.yml添加配置文件
			spring:
			  application:
			    name: userService #User服务端名称
			eureka:
			  client:
			    service-url:  #eureka地址信息
			      defaultZone: http://127.0.0.1:10086/eureka

2.7 Eureka服务发现/服务拉取

服务拉取：方法一

1. 修改访问的URL路径，用服务名代替IP、端口
			String url="http://userservice:8081/user/"+order.getUserId();
	2. 在启动类中的RestTemplate添加负载均衡注解  @LoadBalanced //开启负载均衡
			/** * 创建RestTemplate并注入Spring容器 * @return */
		    @Bean
		    @LoadBalanced //开启负载均衡
		    public RestTemplate restTemplate(){
		        return new RestTemplate();
		    }

服务拉取：方法二

1. 使用发现客户端
		@Autowired
	    private DiscoveryClient discoveryClient;
	2. 拼接url
		//拉取服务
        List<ServiceInstance> userService = discoveryClient.getInstances("userService");
        ServiceInstance serviceInstance = userService.get(0);
        //拼接url
        String url="http://"+serviceInstance.getHost()+":"+serviceInstance.getPort()+"/user/"+id;
	3. 在启动类上开启 发现服务注解
		@EnableDiscoveryClient //开启eureka客户端发现功能

2.8 Ribbon负载均衡执行流程

2.9 Ribbon负载均衡执行流程

2.10 Ribbon饥饿加载

Ribbon默认采用懒加载，即第一次访问时才回去创建LoadBalanceClient，请求时间会很长
	而饥饿加载则会在项目启动时就创建，降低第一次访问的耗时

1.配置饥饿加载
		ribbon:
		  eager-load:
		    enabled: true #开启饥饿加载
		    clients: userservice #指定饥饿加载的服务名称

2.11 Hystrix

Hystrix为每个依赖服务调用分配一个小的线程池，如果线程池已满调用将被立即拒绝，默认不采用排队，加速失败判定时间。
用户的请求将不再直接访问服务，而是通过线程池中的空闲线程来访问服务，如果线程池已满，或者请求超时，则会进行降级处理，什么是服务降级？
服务降级：可以优先保证核心服务。

用户的请求故障时，不会被阻塞，更不会无休止的等待或者看到系统崩溃，至少可以看到一个执行结果（例如返回
友好的提示信息） 。

服务降级虽然会导致请求失败，但是不会导致阻塞，而且最多会影响这个依赖服务对应的线程池中的资源，对其它服务没有响应。触发Hystrix服务降级的情况：
1.线程池已满
2.请求超时

2.11.1 服务降级

引入依赖

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>

开启熔断：在启动类上添加注解

@EnableCircuitBreaker 开启熔断

编写服务降级当该请求超时,会触发服务降级方法给用户友好提示

@RestController
@RequestMapping("/consumer")
@Slf4j
public class ConsumerController {![在这里插入图片描述](http://img.saoniuhuo.com/images/202110/45201633617197417.jpg)

    @Autowired
    public RestTemplate restTemplate;
    @GetMapping("{id}")
    //当请求超时,执行指定的服务降级方法
    @HystrixCommand(fallbackMethod = "fallback") 
    public String getUser(@PathVariable Long id){
        return restTemplate.getForObject("http://userservice/user/"+id,String.class);
    }
    public String fallback(Long id){
        return "网络拥挤,请稍后再试！！！";
    }
}

要注意；因为熔断的降级逻辑方法必须跟正常逻辑方法保证：相同的参数列表和返回值声明。

正常测试请求

关闭调用方法的微服务

2.11.2 默认fallback

刚才把fallback写在了某个业务方法上，如果这样的方法很多，那岂不是要写很多。所以可以Fallback配置加在类上，实现默认fallback；
在业务类上添加注解 @DefaultProperties(defaultFallback = “默认服务降级方法”)
编写服务降级方法

public String defaultFallback() {
		return "默认提示：对不起，网络太拥挤了！";
	}

在业务方法上添加注解 @HystrixCommand

2.12 服务熔断

在服务熔断中，使用的熔断器，也叫断路器，其英文单词为：Circuit Breaker 熔断机制与家里使用的电路熔断原理
类似；当如果电路发生短路的时候能立刻熔断电路，避免发生灾难。在分布式系统中应用服务熔断后；服务调用方
可以自己进行判断哪些服务反应慢或存在大量超时，可以针对这些服务进行主动熔断，防止整个系统被拖垮。
Hystrix的服务熔断机制，可以实现弹性容错；当服务请求情况好转之后，可以自动重连。通过断路的方式，将后续
请求直接拒绝，一段时间（默认5秒）之后允许部分请求通过，如果调用成功则回到断路器关闭状态，否则继续打
开，拒绝请求的服务。

三、Nacos

3.1 Nacos下载-Windows版

Nacos官网

1. 在 Nacos的bin目录下cmd命令行输入 单击模式命令行
			startup.cmd -m standalone
	2. 启动完毕后

3. 在网页打开
		http://本机ip:8848/nacos/index.html 登陆账号密码 都是 nacos

3.2 Nacos注册中心

1.在父工程中添加Nacos管理依赖
		<dependency>
		    <groupId>com.alibaba.cloud</groupId>
		    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
		    <version>2.2.5.RELEASE</version>
		    <type>pom</type>
		    <scope>import</scope>
		</dependency>
	2. 在子模块中导入 nacos客户端依赖
		<!-- nacos客户端依赖包 -->
		<dependency>
		    <groupId>com.alibaba.cloud</groupId>
		    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
		</dependency>
	3. 在application核心文件中配置nacos地址
	   spring:
	   	 cloud:
		   nacos:
		     server-addr: localhost:8848 #nacos服务地址

3.3 添加集群

1. 在application中添加集群名称
		spring: 
		  discovery:
            cluster-name: HZ #集群名称 这里代表杭州
	当A模块向B模块发送请求时，会优先查看A模块和B模块是否在同一个集群中，若在同一个集群中发送数据延迟会大大降低

3.4 Nacos加权负载均衡

实例的权重控制：
		1. Nacos控制台可以设置实例的权重值，0~1之间
		2. 同集群内的多个实例，权重越高访问的频率越高
		3. 权重为0则完全不会访问

3.5 Nacos环境隔离

1. namespace用来做环境隔离
	2. 每个namespace都有唯一的ID
	3. 不同namespace下的服务不可见，无法跨namespace调用服务

3.5.1 Nacos新建隔离环境

4. 在application核心配置文件写入当前业务模块所在的命名空间
		spring:
		  cloud:
            nacos:
              discovery:
        	    namespace:  #命名空间的ID

3.6 Nacos配置管理

3.6.1 实现Nacos统一配置管理

3.6.2 Nacos微服务配置拉取

拉取Nacos上的配置中心的设置具体配置看3.6.1的图2

@Value("${pattern.dateformat}") //${"获取Nacos配置中心的值"}
     private String format;
     @RequestMapping("now")
    public void now(){
     System.out.println(LocalDateTime.now().format(DateTimeFormatter.ofPattern(format)));
    }

3.6.3 Nacos配置中心实现配置热更新

什么是热更新呢？就是当我们修改了Nacos配置文件后不需要重新启动微服务，我们的代码就可以自动监测到配置，如果发现了修改会自动更新配置
方式一：

在@Value("${Nacos配置中心的属性}")注解的类上添加@RefreshScope

方式二：推荐

@Data
	@Component
	@ConfigurationProperties(prefix = "pattern")//获取配置文件前缀
	public class PatternProperties {
	    //如果前缀和当前属性拼接上在配置中心存在的话，就会自动注入到该属性
	    private String format;
	}

3.6.4 Nacos多服务共享配置

@Data
	@Component
	@ConfigurationProperties(prefix = "pattern")//获取配置文件前缀
	public class PatternProperties {
	    //如果前缀和当前属性拼接上在配置中心存在的话，就会自动注入到该属性
	    private String format;
	    private String envSharedValue;
	}

@GetMapping("/env")
    private Object Share(){
        return patternProperties;
    }

3.7 Nacos集群搭建

四、Feign

4.1 Feign远程调用

1. 导入依赖
		<!--        openFeign依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
	2. 启动类上添加Feign的开启注解
		@EnableFeignClients //开启openFeign
	3. 定义openFeign接口
		@FeignClient("userService")//要求与Nacos中的服务名一致
		public interface UserClient {
		    @GetMapping("/user/{id}")//暴露userService微服务的请求方法
		    User findById(@PathVariable("id") Long id);
		}
	4. 调用
		@Autowired
	    public UserClient userClient;
	    public Order openFeign(Long orderId) {
	        // 1.查询订单
	        Order order = orderMapper.findById(orderId);
	        //2.利用Feign实现远程调用
	        User user = userClient.findById(order.getUserId());
	        order.setUser(user);
	        // 4.返回
	        return order;
	    }

4.2 Feign自定义配置

方式一：配置文件方式

feign:
	  client:
	    config:
	      default: # 这里用default就是全局配置，如果是写服务名称，则是针对某个微服务的配置
	        loggerLevel: FULL #日志级别

方式二： java代码方式，需要先声明一个Bean：

public class FeignClientConfiguration {
	    @Bean
	    public Logger.Level feignLoggerLevel(){
	        return Logger.Level.FULL;
	    }
	}
	
	而后如果是全局配置，则把它放到@EnableFeignClients这个注解中：
	@EnableFeignClients(defaultConfiguration = FeignAutoConfiguration.class)

而后如果是全局配置，则把它放到@EnableFeignClients这个注解中：	@EnableFeignClients(defaultConfiguration = FeignAutoConfiguration.class)
如果是局部配置，则把它放到@FeignClient这个注解中：	@FeignClient(value = “userService”,configuration = FeignAutoConfiguration.class)

五、 Gateway网关

5.1 网关的作用

对用户做身份验证、权限校验
将用户的请求路由到微服务，并实现负载均衡
对用户请求做限流

5.2 网关的搭建

要注意依赖版本冲突问题，否则网关启动失败

1. 添加网关依赖和nacos服务发现依赖
		<!--网关依赖        -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>
        <!--nacos服务发现依赖        -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
	2. application核心文件设置网关配置
		server:
		  port: 10010 #网关端口
		spring:
		  application:
		    name: gateway #服务名称
		  cloud:
		    nacos:
		      server-addr: localhost:8848 #nacosnacos地址
		    gateway:
		      routes: #网关路由配置
		        - id: user-service #路由id，自定义，只要唯一即可
		          uri: lb://userService #路由的目标地址 lb就是负载均衡，后面跟服务名称
		          predicates:  #路由断言，也就是判断请求是否符合路由规则的条件
		            - Path=/user/** #这个是按照路径匹配，只要以/user/开头就符合要求 - id: order-service uri: lbb://orderService predicates: - Path=/order/**

5.3 过滤器Filter

官网：

常见过滤器

过滤器名称	说明
AddRequestHeader	对匹配的上的请求添加请求头
AddRequestParameters	对匹配上的路由添加请求参数
AddResponseHeader	从网关返回的请求添加响应头
StripPrefix	对匹配上的请求取出前缀

5.3.1 给单个路由添加过滤器

server:
  port: 10010 #网关端口
spring:
  application:
    name: gateway #服务名称
  cloud:
    nacos:
      server-addr: localhost:8848 #nacosnacos地址
    gateway:
      routes: #网关路由配置
        - id: user-service #路由id，自定义，只要唯一即可
          uri: lb://userService #路由的目标地址 lb就是负载均衡，后面跟服务名称
          predicates:  #路由断言，也就是判断请求是否符合路由规则的条件
            - Path=/user/** #这个是按照路径匹配，只要以/user/开头就符合要求
          filters:
            - AddRequestHeader=Truth,yyds
            - AddResponseHeader=Truth,yyds
        - id: order-service
          uri: lb://orderService
          predicates:
            - Path=/order/**

5.3.2 default-filters给所有路由定义过滤器

在网关的yml配置文件中设置

spring:
		  application:
		    name: gateway #服务名称
		  cloud:
		    nacos:
		      server-addr: localhost:8848 #nacosnacos地址
		    gateway:
		      routes: #网关路由配置
		        - id: user-service #路由id，自定义，只要唯一即可
		          uri: lb://userService #路由的目标地址 lb就是负载均衡，后面跟服务名称
		          predicates:  #路由断言，也就是判断请求是否符合路由规则的条件
		            - Path=/user/** #这个是按照路径匹配，只要以/user/开头就符合要求
		        - id: order-service
		          uri: lb://orderService
		          predicates:
		            - Path=/order/**
		      default-filters: #默认过滤器，对所有路由都生效
		        - AddRequestHeader=Truth,yyds #添加请求头
		        - AddResponseHeader=Truth,yyds #添加响应头

5.3.3 GlobalFilter全局过滤器

GlobalFilter与default-filters的区别
1 全局过滤器的作用也是处理一切进入网关的请求和微服务响应，与GatewayFilter作用一样
2 区别在于GatewayFilter通过配置定义,处理逻辑是固定的。而GlobalFilter的逻辑需要自己写代码实现

1. 实现GlobalFilter接口的方法
	2. 标记当前的全局过滤器优先级 @Order
	@Order(-1)//决定了GlobalFilter全局过滤器的优先级，数字越小，优先级越高
	@Component
	public class AuthorizationFilter implements GlobalFilter {
	
	    @Override
	    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
	        //1.获取请求参数
	        ServerHttpRequest request = exchange.getRequest();
	        MultiValueMap<String, String> queryParams = request.getQueryParams();
	        //2.获取参数中的第一个为authorization的值
	        String authorization = queryParams.getFirst("authorization");
	        //3.判断是否相等
	        if("admin".equals(authorization)){
	            //4.相等 放行
	            return chain.filter(exchange);//若有下一个全局过滤器就执行下一个全局过滤器
	        }
	        //5.否 拦截
	        //5.1设置状态码
	        exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
	        //5.2拦截请求
	        return exchange.getResponse().setComplete();
	    }
	}

六、配置中心

6.1 Spring Cloud Config分布式配置中心

说明

在分布式系统中，由于服务数量非常多，配置文件分散在不同的微服务项目中，管理不方便。为了方便配置文件集
中管理，需要分布式配置中心组件。在Spring Cloud中，提供了Spring Cloud Config，它支持配置文件放在配置服
务的本地，也支持放在远程Git仓库（GitHub、码云）。

图解

在GItee上创建好仓库后,创建配置文件

命名方式：配置文件的命名方式：{application}-{profile}.yml 或 {application}-{profile}.properties
	application为应用名称
	profile用于区分开发环境，测试环境、生产环境等

在Git上创建好配置文件后创建一个新的模块当配置类

config模块导入依赖：
		<dependencies>
			<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
			</dependency>
			<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-config-server</artifactId>
			</dependency>
		</dependencies>

并在config配置模块启动类上开启注解

@EnableConfigServer 开启配置模块

在config模块中设置application.yml文件连接远程仓库

server:
 port: 12000
spring:
 application:
  name: config-server
 cloud:
  config:
   server:
    git:
     uri: 填写Git仓库的地址
eureka:
 client:
  service-url:
   defaultZone: http://127.0.0.1:10086/eureka

6.2 获取配置中心的配置

先导入依赖

<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-config</artifactId>
	</dependency>

上面的操作已经把我们需要的yml配置文件设置到Git上,接下来我们将获取Git上面的yml配置文件
把我们所需的yml删除,创建一个bootstrap.yml引导文件,优先级比application.yml高

spring:
 cloud:
  config:
   # 要与仓库中的配置文件的application保持一致
   name: user
   # 要与仓库中的配置文件的profile保持一致
   profile: dev
   # 要与仓库中的配置文件所属的版本（分支）一样
   label: master
   discovery:
    # 使用配置中心
    enabled: true
    # 配置中心服务名
    service-id: config-server
eureka:
 client:
  service-url:
   defaultZone: http://127.0.0.1:10086/eureka

SpringCloud