Spring Cloud：Gateway（统一服务入口）

Api 网关

也是一种服务，就是通往后端的唯一入口，类似于整个微服务架构的门面，所有的外部客户端进行访问，都需要经过它来进行过滤和调度，类似于公司的前台

而Spring Cloud Gateway就是Api网关的一种具体实现

网关的核心功能

权限控制：作为微服务的入口，对用户进行权限校验，校验失败则会进行拦截
动态路由：一切的请求先经过网关，但是网关不处理业务，而是根据某种规则，把请求转发到某个微服务
负载均衡：当路由的服务目标有多个时，还需要做负载均衡
限流:请求流量过高时，按照网关中配置微服务能够接受的流量进行放行，避免服务压力过大

Spring Cloud Gateway的使用

实现需要先引入网关的依赖

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

添加Gateway的路由配置

server:port: 10030
spring:application:name: gatewaycloud:nacos:discovery:server-addr: 123.57.4.74:8848gateway:routes: #网关配置- id: product-serviceuri: lb://product-servicepredicates:- Path=/product/**- id: order-serviceuri: lb://order-servicepredicates:- Path=/order/**

通过Api网关服务访问product-service服务和order-service服务

RoutePredicate Factories（路由断言工厂）

用于定义路由的匹配条件

Predicate

用于确定请求是否匹配某个路由的条件

接受一个参数，返回一个布尔类型，用于判断接受的请求参数是否满足条件

定义⼀个Predicate

判断请求参数s是否为空，为空为true

public class StringPredicate implements Predicate<String> {@Overridepublic boolean test(String s) {return s==null || s.isEmpty();}
}

使用

    @Testpublic void test1(){Predicate<String> predicate=new StringPredicate();System.out.println(predicate.test("aa"));System.out.println(predicate.test(""));}

Predicate的其他写法

内置函数

@Testpublic void test(){Predicate<String> predicate=new Predicate<String>() {@Overridepublic boolean test(String s) {return s==null || s.isEmpty();}};System.out.println(predicate.test("aa"));System.out.println(predicate.test(""));}

lambda形式

@Testpublic void test2(){Predicate<String> predicate= s-> s==null || s.isEmpty();System.out.println(predicate.test("aa"));System.out.println(predicate.test(""));}

其他方法

negate()求反

@Testpublic void test3(){Predicate<String> predicate= s-> s==null || s.isEmpty();System.out.println(predicate.negate().test("aa"));System.out.println(predicate.negate().test(""));}

or()

@Testpublic void test4(){Predicate<String> predicate= s-> "aa".equals(s);Predicate<String> predicate2= s-> "bb".equals(s);System.out.println(predicate.or(predicate).test("aa"));System.out.println(predicate.or(predicate).test(""));}

and()

 @Testpublic void test5(){Predicate<String> predicate= s-> s!=null && s.isEmpty();Predicate<String> predicate2= s-> s!=null && s.chars().allMatch(Character::isDigit);System.out.println(predicate.and(predicate2).test("aa"));System.out.println(predicate.and(predicate2).test("123"));}

Spring Cloud Gateway默认提供了很多RoutePredicateFactory,这些Predicate会分别匹配HTTP请求的不同属性,并且多个Predicate可以通过and逻辑进⾏组合

匹配指定如期之后的请求

匹配指定如期之前的请求

指定的Cookie和Header

及该cookie或者header值符合指定的正则表达式

具体详细看Route Predicate Factories :: Spring Cloud Gateway

GatewayFilter Factories（网关过滤工厂）

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

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

Pre类型过滤器：路由处理前执行(转发到后端服务之前执行),在Pre类型过滤器中可以做鉴权，限流的处理
Post类型过滤器：请求执行完成后，将结果返回给客户端之前执行

gateway可将把Filter可分为GatewayFilter和GlobalFilter

GatewayFilter只对一个路由起作用
GlobalFilter对所有的路由起作用

Spring Cloud Gateway提供了非常多的Filter

GatewayFilter Factories :: Spring Cloud Gateway

过滤器执⾏顺序

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

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

自定义过滤器

自定义Gateway Filter

@Service
public class CustomGatewayFilterFactory extends AbstractGatewayFilterFactory<CustomConfig> implements Ordered {private static final Logger log = LoggerFactory.getLogger(CustomGatewayFilterFactory.class);public CustomGatewayFilterFactory() {super(CustomConfig.class);}@Overridepublic GatewayFilter apply(CustomConfig config) {return new GatewayFilter() {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info(" pre Filter,Config:{}",config);return chain.filter(exchange).then(Mono.fromRunnable(()->{log.info("post Filter");}));}};}@Overridepublic int getOrder() {return Ordered.LOWEST_PRECEDENCE;}
}

@Data
public class CustomConfig {private String name;
}

注：类名统⼀以GatewayFilterFactory结尾,因为默认情况下,过滤器的name会采⽤该定义类的前缀.这⾥的name=Custom(yml配置中使⽤)

then方法是请求执行之后处理的

getOrder是定义优先级，值越大，优先级越小

测试

自定义GlobalFilter

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

测试

此时的order-service并没有定义Filter