SpringCloud

SpringCloud

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-3AHUtDBX-1647160769089)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312143355012.png)]

认识微服务 服务架构演变

· 单体架构

· 简单方便，高耦合度，扩展性差，适合小型项目。例如：学生管理系统

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Afhii1Gz-1647160769090)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312144832975.png)]

· 分布式架构

· 松耦合，扩展性好，但架构复杂，难度大。适合大型互联网公司项目，例如：京东、淘宝

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-vIi36HIw-1647160769091)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312145012219.png)]

· 微服务

· 一种良好的分布式架构方案

· 优点：拆分粒度更小、服务更独立、耦合度更低

· 缺点：架构非常复杂，运维、监控、部署难度提高

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-tIDLZMJo-1647160769091)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312145801115.png)]

· 微服务技术对比

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-nXNR8pMY-1647160769092)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312151511896.png)]

· 企业需求

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-5vbxbgfI-1647160769092)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312151751699.png)]

SpringCloud

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-5v78A3Vx-1647160769092)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312152020976.png)]

· SpringBoot与SpringCloud的版本兼容关系

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-foshjM5t-1647160769093)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312152122138.png)]

分布式服务架构案例 微服务远程调用

在order-service的OrderApplication中注册RestTemplate

@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
public class OrderApplication{
    
    public static void main(String[] args){
        SpringApplication.run(OrderApplication.class,args);
  }      
    //注册RestTemplate
    @Bean
    public RestTemplate restTemplate(){
     	return new RestTemplate();   
        }
}

修改order-service中的OrderService的queryOrderById方法

@Service
public class OrderService{
    
    @Autowired
    private RestTemplate restTemplate;
    
    public Order queryOrderById(Long orderId){
        //查询订单
        Order order=orderMapper.findById(orderId);
        // TODO 查询用户
        String url="http://localhost:8081/user/"+order.getUserId();
        User user = restTemplate.getForObject(url,User.class);
        // 封装user信息
        order.setUser(user);
        //返回
        return order;
    }
}

提供者与消费者

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

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

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-oiMKLLMd-1647160769094)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312155107523.png)]

· 提供者与消费者角色是相对的，一个服务可以同时是服务提供者和服务消费者

总结

微服务需要根据业务模式拆分，做到单一职责，不要重新开发相同业务微服务可以将业务暴露为接口，供其他微服务使用不同微服务都应该有自己独立的数据库

eureka注册中心 eureka原理 Eureka的作用

· 在EureKa架构中，微服务角色有两类

EureKaServer：服务端，注册中心

​ 1.记录服务信息

​ 2. 心跳监控

EureKaClient：客户端

​ 1. Provider：服务提供者，user-service

​ 1. 注册自己的信息到EureKaServer

​ 2. 每隔30秒项EureKaServer发送心跳

​ 2. consumer：服务消费者, order-service

​ 1. 根据服务名称从EureKaServer拉取服务列表

​ 2. 基于服务列表做负载均衡，选中一个微服务后发起远程调用

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-FbeICJch-1647160769095)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312163005371.png)]

搭建EureKaServer

引入SpringCloud为eureka提供的starter依赖

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

编写启动类，添加@EnableEureKaServer注解

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class, args);
    }
}

添加application.yml文件

server:
  port: 10086
spring:
  application:
    name: eureka-server
eureka:
  client:
    service-url: 
      defaultZone: http://127.0.0.1:10086/eureka

启动服务

· 启动微服务，然后在浏览器访问：http://127.0.0.1:10086

服务注册

引入下面的eureka-client依赖，user-service

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

编写启动类，添加@EnableEurekaServer注解

SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class, args);
    }
}

修改application.yml文件，添加服务名称、eureka地址

spring:
  application:
    name: userservice #添加服务名称
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka #eureka地址

一个服务可以有多个实例，添加一个SpringBoot的启动配置，再启动一个user-service

复制原来的user-service启动配置

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Rb9UW4zk-1647160769095)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312170748839.png)]

 2. 在弹出的窗口中，填写信息

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-4DW7gqx0-1647160769096)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312170845104.png)]

SpringBoot窗口会出现两个user-service启动配置

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-NPbkde9P-1647160769096)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312170902270.png)]

· 无论是消费者还是服务者，引入eureKa-client依赖、知道eureka地址后，都可以完成服务注册

服务发现

· 在order-service完成服务拉取

服务拉取是基于服务名称获取服务列表，然后在对服务列表做负载均衡

修改OrderService的代码，修改访问的url路径，用服务名代替ip、端口：

String url = "http://userservice/user/"+order.getUserId();

在order-service项目的启动类OrderApplication中的RestTemplate添加负载均衡注解

@Bean
@LoadBalanced
public RestTemplate restTemplate(){
    return new RestTemplate();
}

Ribbon负载均衡原理 负载均衡原理 负载均衡流程

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-vZL0y1uL-1647160769097)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312172346831.png)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-m787iw7q-1647160769098)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312173157490.png)]

负载均衡策略

· Ribbon的负载均衡规则是一个叫做IRule的接口来定义的，每一个子接口都是一种规则

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-AFf9vdlC-1647160769098)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312173400264.png)] [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-oe5IrLFE-1647160769099)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312173551309.png)]

· 通过定义IRule实现可以修改负载均衡规则

代码方式：在order-service中的OrderApplication类中，定义一个新的IRule:

@Bean //（全局）
public IRule randomRule(){
    return new RamdomRule();
}

配置文件方式，在order-service中的application.yml文件中，添加新的配置

userservice:
 ribbon
  NFLoadBalancerRuleClassName: com,netflix.loadbalancer.RandomRule #负载均衡规则，无需重新打包

懒加载

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

ribbon: 
 eager-load:
  enabled : true #开启饥饿加载
  clients: userservice #指定对userservice这个服务饥饿加载

nacos注册中心 认识和安装Nacos

· Nacos是阿里巴巴的产品，现在是SpringCloud中的一个组件

· 下载安装

· 在bin目录下运行指令：startup.cmd -m standalone

Nacos快速入门

引入nacos.discovery父工程依赖

    com.alibaba.cloud
    spring-cloud-alibaba-dependencies
    2.2.6.RELEASE
    pom
    import

在user-service和order-service中的pom文件中引入nacos-discovery依赖

    com.alibaba.cloud
    spring-cloud-starter-alibaba-nacos-discovery

配置nacos地址

spring:
  cloud:
    nacos:
      server-addr: localhost:8848

重启

· 重启微服务后，登录nacos管理页面，可以看到微服务信息

Nacos服务分级存储模型

一级是服务，例如userservice二级是集群，例如杭州或伤害三级是实例，例如杭州机房的某台部署了userservice的服务器

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Wa7YRQwz-1647160769100)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312193154188.png)]

· 如何设置实例的集群属性

1. 修改application.yml

spring: 
 cloud: 
  nacos:
   server-addr:Localhost:8848 # nacos 服务器地址
   discovery:
    cluster-name: HZ # 配置集群名称，也就是机房位置

在order-service中设置负载均衡的IRule为NacosRule，这个规则优先会寻找与自己同集群的服务

userservice:
 ribbon:
  NFLoadBalancerRuleClassName: com.alibaba.cloud.nacos.ribbon.NacosRule #负载均衡规则

注意将user-service的权重都设置为1

NacosRule负载均衡策略

优先选择同集群服务实例列表本地集群找不到提供者，才去其他集群寻找，并且会报警告确认了可用实例列表后，再采用随机负载均衡挑选实例

权重负载均衡

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

Nacos环境隔离

环境隔离 - namespace

· Nacos中服务存储和数据存储的最外层都是一个名为namespace的东西，用来做最外层隔离

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ZO3cOZ4u-1647160769100)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312195837678.png)]

在Nacos控制台可以创建namespace，用来隔离不同环境

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-34z94F47-1647160769101)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312200045363.png)]

填写新的命名空间信息

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-BYaMwRcR-1647160769101)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312200107060.png)]

保存后会在控制台看到命名空间的id，每个namespace都有唯一id

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-YoWfZQ4f-1647160769102)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312200141330.png)]

修改order-serverservice的application.yml配置文件，添加命名空间的ID

spring: 
 cloud: 
  nacos:
   server-addr:Localhost:8848 # nacos 服务器地址
   discovery:
    cluster-name: HZ # 配置集群名称，也就是机房位置
    namespace: #填写命名空间ID

Nacos和Eureka的对比 Nacos注册中心细节分析

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-QAFJZE6A-1647160769102)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312201011528.png)]

临时实力和非临时实例

· 服务注册到Nacos时，可以选择注册为临时或非临时实例

spring:
 cloud:
  nacos:
   discovery:
    ephemeral: false #设置为非临时实例 
# 临时实例宕机时，会从nacos的服务列表中剔除，而非临时实例则不会

共同点

都支持服务注册和服务拉取都支持服务提供者心跳方式做健康检测 区别

Nacos支持服务端主动检测提供者状态：临时实例采用心跳模式，非临时实例采用主动检测模式临时实例心跳不正常会被剔除，非临时实例则不会被剔除Nacos支持服务列表变更的消息推送模式，服务列表更新更及时Nacos集群默认采用AP方式，当集群中存在非临时实例时，采用CP模式；Eureka采用AP方式 Nacos配置管理 统一配置管理

· Nacos除了可以做注册中心，同样可以做配置管理来使用

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-AArZUBom-1647160769103)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312202645295.png)]

在nacos中管理配置

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-llirXRcI-1647160769103)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312203718316.png)]

弹出的表单中，填写配置信息

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-WEa2lKKE-1647160769104)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312203746982.png)]

注意：项目的核心配置，需要热更新的配置才有放到nacos管理的必要。基本不会变更的一些配置还是保存在微服务本地比较好

· 配置获取步骤

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-af8nFrAb-1647160769104)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312204222750.png)]

引入Nacos的配置管理客户端依赖

    com.alibaba.cloud
    spring-cloud-starter-alibaba-nacos-config

在userservice中的resource目录添加一个bootstrap.yml文件，这个文件是引导文件，优先级高于application.yml

spring:
  application:
    name: userservice # 服务名称
  profiles:
    active: dev #开发环境，这里是dev 
  cloud:
    nacos:
      server-addr: localhost:8848 # Nacos地址
      config:
        file-extension: yaml # 文件后缀名

在user-service中将pattern.dateformat这个属性注入到UserController中测试

public class UserController {

    @Autowired
    private UserService userService;

    @Value("${pattern.dateformat}")
    private String dateformat;
    
    @GetMapping("now")
    public String now(){
        return LocalDateTime.now().format(DateTimeFormatter.ofPattern(dateformat));
    }
    // ...略
}

总结：

在Nacos中添加配置文件在微服务中引入nacos的config依赖在微服务中添加bootstrap.yml,配置nacos地址、当前环境、服务名称、文件后缀名。这些决定了程序启动时去nacos读取哪个文件

配置热更新 配置自动刷新

· Nacos中的配置文件变更后，微服务无需重启就可以感知

方式一

· 在@Value注入的变量所在类上添加注解@RefreshScope

@Slf4j
@RestController
@RequestMapping("/user")
@RefreshScope
public class UserController {

    @Autowired
    private UserService userService;

    @Value("${pattern.dateformat}")
    private String dateformat;
    
    @GetMapping("now")
    public String now(){
        return LocalDateTime.now().format(DateTimeFormatter.ofPattern(dateformat));
    }
    // ...略
}

方式二

· 使用@ConfigurationProperties注解 // 推荐

@Component
@Data
@ConfigurationProperties(prefix = "pattern")
public class PatternProperties {
    private String dateformat;
}

· 在UserController中使用这个类代替@Value

@Slf4j
@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private UserService userService;

    @Autowired
    private PatternProperties patternProperties;

    @GetMapping("now")
    public String now(){
        return LocalDateTime.now().format(DateTimeFormatter.ofPattern(patternProperties.getDateformat()));
    }

    // 略
}

配置共享 多种环境的优先级

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-HhXbkPz6-1647160769105)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220312213542915.png)]

[服务名]-[spring.profile.active].yaml，环境配置[服务名].yaml, 默认配置，多环境共享

搭建Nacos集群

· Nacos生产环境下一定要部署为集群

搭建MySQL集群并初始化数据库表下载解压nacos修改集群配置（节点信息）、数据库配置分别启动多个nacos节点nginx反向代理

Feign远程调用 Feign代替RestTemplate

· Feign是一个声明式的http客户端

引入依赖

    org.springframework.cloud
    spring-cloud-starter-openfeign

添加@EnableFeignClients注解

@EnableFeignClients
@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
public class OderApplication{

}

编写FeignCLient接口

@FeignClient("userservice")
public interface UserClient {
    @GetMapping("/user/{id}")
    User findById(@PathVariable("id") Long id);
}

· 这个客户端主要是基于SpringMVC的注解来声明远程调用的信息，比如：

服务名称：userservice请求方式：GET请求路径：/user/{id}请求参数：Long id返回值类型：User

这样，Feign就可以帮助我们发送http请求，无需自己使用RestTemplate来发送了

自定义配置

· Feign可以支持很多的自定义配置

类型	作用	说明
feign.Logger.Level	修改日志级别	包含四种不同的级别：NONE、BASIC、HEADERS、FULL
feign.codec.Decoder	响应结果的解析器	http远程调用的结果做解析，例如解析json字符串为java对象
feign.codec.Encoder	请求参数编码	将请求参数编码，便于通过http请求发送
feign. Contract	支持的注解格式	默认是SpringMVC的注解
feign. Retryer	失败重试机制	请求失败的重试机制，默认是没有，不过会使用Ribbon的重试

· 一般情况下，默认值就能满足我们使用，如果要自定义时，只需要创建自定义的@Bean覆盖默认Bean即可

配置文件方式 配置文件形式

· 基于配置文件修改feign的日志级别可以针对单个服务

feign:  
  client:
    config: 
      userservice: # 针对某个微服务的配置
        loggerLevel: FULL #  日志级别 

· 也可以针对所有服务

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

· 日志的级别分为四种：

NONE：不记录任何日志信息，这是默认值。BASIC：仅记录请求的方法，URL以及响应状态码和执行时间HEADERS：在BASIC的基础上，额外记录了请求和响应的头信息FULL：记录所有请求和响应的明细，包括头信息、请求体、元数据。 代码形式

· 基于Java代码来修改日志级别

public class DefaultFeignConfiguration  {
    @Bean
    public Logger.Level feignLogLevel(){
        return Logger.Level.BASIC; // 日志级别为BASIC
    }
}

· 如果要全局生效，将其放到启动类的@EnableFeignClients这个注解中

@EnableFeignClients(defaultConfiguration = DefaultFeignConfiguration .class) 

· 如果是局部生效，则把它放到对应的@FeignClient这个注解中

@FeignClient(value = "userservice", configuration = DefaultFeignConfiguration .class) 

Feign使用优化

Feign底层发起http请求，依赖于其它的框架。其底层客户端实现包括：

•URLConnection：默认实现，不支持连接池

•Apache HttpClient ：支持连接池

•OKHttp：支持连接池

调高性能：使用连接池代替默认的URLConnection

引入依赖，在order-service的pom文件中引入Apache的HttpClient依赖

    io.github.openfeign
    feign-httpclient

配置连接池，在order-service的application.yml中添加配置

feign:
  client:
    config:
      default: # default全局的配置
        loggerLevel: BASIC # 日志级别，BASIC就是基本的请求和响应信息
  httpclient:
    enabled: true # 开启feign对HttpClient的支持
    max-connections: 200 # 最大的连接数
    max-connections-per-route: 50 # 每个路径的最大连接数

总结，Feign的优化：

1.日志级别尽量用basic

2.使用HttpClient或OKHttp代替URLConnection

​ ① 引入feign-httpClient依赖

​ ② 配置文件开启httpClient功能，设置连接池参数

最佳实践 继承方法

定义一个API接口，利用定义方法，并基于SpringMVC注解做声明。

Feign客户端和Controller都集成改接口

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-GCaqF6Gl-1647160769105)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220313150056881.png)]

优点：

简单实现了代码共享

缺点：

服务提供方、服务消费方紧耦合参数列表中的注解映射并不会继承，因此Controller中必须再次声明方法、参数列表、注解 抽取方法

· 将Feign的Client抽取为独立模块，并且把接口有关的POJO、默认的Feign配置都放到这个模块中，提供给所有消费者使用。

· 例如，将UserClient、User、Feign的默认配置都抽取到一个feign-api包中，所有微服务引用该依赖包，即可直接使用

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-svSxC3I3-1647160769106)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220313150312980.png)]

在feign-api中引入feign的starter依赖

    org.springframework.cloud
    spring-cloud-starter-openfeign

在order-service中使用feign-api，在order-service的pom文件中中引入feign-api的依赖

    cn.itcast.demo
    feign-api
    1.0

解决扫描包问题

方法一：指定Feign应该扫描的包

@EnableFeignClients(basePackages = "cn.itcast.feign.clients")

方法二：指定需要加载的Client接口

@EnableFeignClients(clients = {UserClient.class})

Gateway服务网关 为什么需要网关

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-09h2dalJ-1647160769106)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220313152508081.png)]

在SpringCloud中网关的实现

gatewayzuul

gateway快速入门

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-0JrjY6pk-1647160769106)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220313153713475.png)]

总结：

网关搭建步骤：

创建项目，引入nacos服务发现和gateway依赖

   
    org.springframework.cloud
    spring-cloud-starter-gateway



    com.alibaba.cloud
    spring-cloud-starter-alibaba-nacos-discovery 

配置application.yml，包括服务基本信息、nacos地址、路由

server:
  port: 10010 # 网关端口
spring:
  application:
    name: gateway # 服务名称
  cloud:
    nacos:
      server-addr: localhost:8848 # nacos地址
    gateway:
      routes: # 网关路由配置
        - id: user-service # 路由id，自定义，只要唯一即可
          # uri: http://127.0.0.1:8081 # 路由的目标地址 http就是固定地址
          uri: lb://userservice # 路由的目标地址 lb就是负载均衡，后面跟服务名称
          predicates: # 路由断言，也就是判断请求是否符合路由规则的条件
            - Path=/user
    Mono filter(ServerWebExchange exchange, GatewayFilterChain chain);
}

在filter中编写自定义逻辑，可以实现下列功能：

登录状态判断权限校验请求限流等 自定义全局过滤器

需求：定义全局过滤器，拦截请求，判断请求的参数是否满足下面条件：

参数中是否有authorization，

authorization参数值是否为admin

· 如果同时满足则放行，否则拦截。

·在gateway中定义一个过滤器，实现GolbalFilter接口，添加@Order注解

@Order(-1) // 优先级
@Component
public class AuthorizeFilter implements GlobalFilter {
    @Override
    public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 1.获取请求参数
        MultiValueMap params = exchange.getRequest().getQueryParams();
        // 2.获取authorization参数
        String auth = params.getFirst("authorization");
        // 3.校验
        if ("admin".equals(auth)) {
            // 放行
            return chain.filter(exchange);
        }
        // 4.拦截
        // 4.1.禁止访问，设置状态码
        exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);
        // 4.2.结束处理
        return exchange.getResponse().setComplete();
    }
}

· 过滤器执行顺序

· 请求进入网关会碰到三类过滤器：当前路由的过滤器、DefaultFilter、GlobalFilter

· 请求路由后，会将当前路由过滤器和DefaultFilter、GlobalFilter，合并到一个过滤器链（集合）中，排序后依次执行每个过滤器：

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-bWSiDhqW-1647160769107)(C:Usersmaybe3032AppDataRoamingTyporatypora-user-imagesimage-20220313162214258.png)]

排序的规则是什么呢？

每一个过滤器都必须指定一个int类型的order值，order值越小，优先级越高，执行顺序越靠前。GlobalFilter通过实现Ordered接口，或者添加@Order注解来指定order值，由我们自己指定路由过滤器和defaultFilter的order由Spring指定，默认是按照声明顺序从1递增。当过滤器的order值一样时，会按照 defaultFilter > 路由过滤器 > GlobalFilter的顺序执行。 跨域问题

· 跨域：域名不一致就是跨域，主要包括：

域名不同： www.taobao.com 和 www.taobao.org 和 www.jd.com 和 miaosha.jd.com

域名相同，端口不同：localhost:8080和localhost8081

· 跨域问题：浏览器禁止请求的发起者与服务端发生跨域ajax请求，请求被浏览器拦截的问题

· 解决跨域问题

在gateway服务的application.yml文件

spring:
  cloud:
    gateway:
      # 。。。
      globalcors: # 全局的跨域处理
        add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题
        corsConfigurations:
          '[/**]':
            allowedOrigins: # 允许哪些网站的跨域请求 
              - "http://localhost:8090"
            allowedMethods: # 允许的跨域ajax的请求方式
              - "GET"
              - "POST"
              - "DELETE"
              - "PUT"
              - "OPTIONS"
            allowedHeaders: "*" # 允许在请求中携带的头信息
            allowCredentials: true # 是否允许携带cookie
            maxAge: 360000 # 这次跨域检测的有效期