统一服务入口-Gateway（二）

目录

1.Gateway Filter Factories（网关过滤器工厂）

1.1GatewayFilter

1.2GlobalFilter

2.过滤器执行顺序

3.自定义GatewayFilter

3.1定义GatewayFilter

3.2配置过滤器

3.3测试

4.自定义GlobalFilter

4.1定义GlobalFilter

4.2测试

承接上文：统一服务入口-Gateway（一）-CSDN博客

1.Gateway Filter Factories（网关过滤器工厂）

Predicate决定了请求由哪一个路由处理，如果在请求处理前后需要加一些逻辑，这就是Filter(过滤器)的作用范围了

Filter分为两种类型：Pre类型和Post类型

Pre类型过滤器：路由处理之前执行（请求转发到后端服务之前执行），在Pre类型过滤器中可以做鉴权，限流等

Post类型过滤器：请求执行完成后，将结果返回给客户端之前执行

Spring Cloud Gateway中内置了很多Filter,用于拦截和链式处理web请求.比如权限校验，访问超时等设定.

Spring Cloud Gateway从作用范围上，把Filter可分为GatewayFilter和GlobalFilter.

GatewayFilter:应用到单个路由或者一个分组的路由上.

GlobalFilter:应用到所有的路由上，也就是对所有的请求生效.

1.1GatewayFilter

GatewayFilter同Predicate类似，都是在配置文件application.yml中配置，每个过滤器的逻辑都是固定的.比如AddRequestParameterGatewayFilter Factory只需要在配置文件中写AddRequestParameter,就可以为所有的请求添加一个参数

快速上手

1.在application.yml中添加filter

server:port: 10030
spring:application:name: gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848namespace: b460e95c-d4b9-42a3-810f-cdf0051ce008gateway:metrics:enabled: trueroutes:- id: product-service   #路由规则id, 随便起, 不重复即可uri: lb://product-service/ #目标服务地址predicates:   #路由条件- Path=/product/**- After=2024-01-01T00:00:00.000+08:00[Asia/Shanghai]filters:- AddRequestParameter=userName, romised- id: order-service   #路由规则id, 随便起, 不重复即可uri: lb://order-service/ #目标服务地址predicates: #路由条件- Path=/order/**,/feign/**

该filter只添加在了product-service路由下，因此只对product-service路由生效

2.接收参数并打印

在product-service服务中接收请求的参数，并打印出来

 @RequestMapping("/product")@RestControllerpublic class ProductController {@Autowiredprivate ProductService productService;@RequestMapping("/{productId}")public ProductInfo getProductById(@PathVariable("productId") Integer 
productId, String userName){System.out.println("收到请求,Id:"+productId);System.out.println("userName:"+userName);return productService.selectProductById(productId);}}

3.测试

重启服务，访问请求，观察日志

http://127.0.0.1:10030/product/1001

控制台打印日志：

GatewayFilter说明

Spring Cloud Gateway提供的Filter特别多，下面列出一些常见的过滤器说明

详细可参考官方文档：GatewayFilter Factories :: Spring Cloud Gateway

Default Filters

前面的filter添加在指定路由下，所以只对当前路由生效，若需要对全部路由生效，可以使用：spring.cloud.gateway.default-filters

配置举例：

spring:cloud: gateway:default-filters:- AddResponseHeader=X-Response-Default-Red, Default-Blue- PrefixPath=/httpbin

1.2GlobalFilter

GlobalFilter是Spring Cloud Gateway中的全局过滤器，它和GatewayFilter的作用是相同的.
GlobalFilter会应用到所有的路由请求上，全局过滤器通常用于实现与安全性，性能监控和日志记录等相关的全局功能.

Spring Cloud Gateway内置的全局过滤器也有很多，比如：

• Gateway Metrics Filter:网关指标，提供监控指标
• Forward Routing Filter:用于本地forword,请求不转发到下游服务器
• LoadBalancer Client Filter:针对下游服务，实现负载均衡.
• ...

更多过滤器参考：Global Filters :: Spring Cloud Gateway 

快速上手

1.添加依赖

 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency>

2.添加配置

spring:cloud:gateway:metrics:enabled: true
management:endpoints:web:exposure:include: "*"endpoint:health:show-details: alwaysshutdown:enabled: true

3.测试

访问http://127.0.0.1:10030/actuator 显示所有监控的信息链接

2.过滤器执行顺序

一个项目中，既有GatewayFilter,又有GlobalFilter时，执行的先后顺序是什么呢?

请求路由后，网关会把当前项目中的GatewayFilter和GlobalFilter合并到一个过滤器链(集合)中，并进行排序，依次执行过滤器.

每一个过滤器都必须指定一个int类型的order值，默认值为0,表示该过滤的优先级.order值越小，优先级越高，执行顺序越靠前。

• Filter通过实现Order接口或者添加@Order注解来指定order值.
• SpringCloud Gateway提供的Filter由Spring指定.用户也可以自定义Filter,由用户指定.
• 当过滤器的order值一样时，会按照defaultFilter>GatewayFilter>GlobalFilter的顺序执行.

3.自定义GatewayFilter

3.1定义GatewayFilter

@Slf4j
@Component
public class CustomGatewayFilterFactory extends AbstractGatewayFilterFactory<CustomConfig> implements Ordered {public CustomGatewayFilterFactory() {super(CustomConfig.class);}@Overridepublic GatewayFilter apply(CustomConfig config) {return new GatewayFilter() {/*** ServerWebExchange: HTTP 请求-响应交互契约, 提供了对HTTP请求和响应的访问* GatewayFilterChain: 过滤器链* Mono: Reactor的核心类, 数据流发布者,Mono最多只能触发一个事件.可以把Mono用在异步完成任务时,发出通知* chain.filter(exchange)  执行请求* Mono.fromRunnable()  创建一个包含Runnable元素的数据流*/@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {//Pre类型   执行请求   Post类型log.info("Pre Filter, config:{} ",config);  //Pre类型过滤器代码逻辑return chain.filter(exchange).then(Mono.fromRunnable(()->{log.info("Post Filter....");  //Post类型过滤器代码逻辑}));}};}@Overridepublic int getOrder() {return Ordered.LOWEST_PRECEDENCE;//配置优先级, order越⼤, 优先级越低}
}

 @Datapublic static class CustomConfig {private String name;}

3.2配置过滤器

spring:application:name: gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848namespace: b460e95c-d4b9-42a3-810f-cdf0051ce008gateway:metrics:enabled: trueroutes:- id: product-service   #路由规则id, 随便起, 不重复即可uri: lb://product-service/ #目标服务地址predicates:   #路由条件- Path=/product/**- After=2024-01-01T00:00:00.000+08:00[Asia/Shanghai]filters:- AddRequestParameter=userName, romised- name: Custom    #过滤器名称args:name: test_custom

3.3测试

重启服务访问接口，观察日志：http://127.0.0.1:10030/product/1001

4.自定义GlobalFilter

GlobalFilter的实现比较简单，它不需要额外的配置，只需要实现GlobalFilter接口，自动会过滤所有的Filter

4.1定义GlobalFilter

@Slf4j
@Component
public class CustomGlobalFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("Pre Global Filter");return chain.filter(exchange).then(Mono.fromRunnable(()->{log.info("Post Global Filter...");}));}@Overridepublic int getOrder() {return Ordered.LOWEST_PRECEDENCE;}
}

4.2测试

重启服务，访问接口，观察日志：http://127.0.0.1:10030/product/1001

从日志中,也可以看出来, 当GatewayFilter 和GlobalFilter 过滤器order⼀样时, 会先执行GatewayFilter