log.info(“Loaded GatewayFilterFactory [Authorize]”);

}

//读取配置文件中的参数 赋值到 配置类中

@Override

public List shortcutFieldOrder() {

//Config.enabled

return Arrays.asList(“enabled”);

}

@Override

public GatewayFilter apply(AuthorizeGatewayFilterFactory.Config config) {

return (exchange, chain) -> {

//判断是否开启授权验证

if (!config.isEnabled()) {

return chain.filter(exchange);

}

ServerHttpRequest request = exchange.getRequest();

HttpHeaders headers = request.getHeaders();

//从请求头中获取token

String token = headers.getFirst(AUTHORIZE_TOKEN);

if (token == null) {

//从请求头参数中获取token

token = request.getQueryParams().getFirst(AUTHORIZE_TOKEN);

}

ServerHttpResponse response = exchange.getResponse();

//如果token为空，直接返回401，未授权

if (StringUtils.isEmpty(token)) {

response.setStatusCode(HttpStatus.UNAUTHORIZED);

//处理完成，直接拦截，不再进行下去

return response.setComplete();

}

/**

• todo chain.filter(exchange) 之前的都是过滤器的前置处理

• chain.filter().then(

• 过滤器的后置处理…

• )

*/

//授权正常，继续下一个过滤器链的调用

return chain.filter(exchange);

};

}

@Data

@AllArgsConstructor

@NoArgsConstructor

public static class Config {

// 控制是否开启认证

private boolean enabled;

}

}

局部过滤器需要在路由中配置才能生效，配置如下：

spring:

cloud:

gateway:

路由

routes:

id只要唯一即可，名称任意

• id: gateway-provider_1

uri: http://localhost:9024

配置断言

predicates:

Path Route Predicate Factory断言，满足/gateway/provider/**这个请求路径的都会被路由到http://localhost:9024这个uri中

• Path=/gateway/provider/**

配置过滤器（局部）

filters:

• AddResponseHeader=X-Response-Foo, Bar

AuthorizeGatewayFilterFactory自定义过滤器配置，值为true需要验证授权，false不需要

• Authorize=true

此时直接访问：

http://localhost:9023/gateway/provider/port，不携带token，返回如下图：

请求参数带上token：

http://localhost:9023/gateway/provider/port?token=abcdcdecd-ddcdeicd12，成功返回，如下图：

上述的

AuthorizeGatewayFilterFactory只是涉及到了过滤器的前置处理，后置处理是在chain.filter().then()中的then()方法中完成的，具体可以看下项目源码中的TimeGatewayFilterFactory，代码就不再贴出来了，如下图：

GlobalFilter（全局过滤器）

===================

全局过滤器应用到全部路由上，无需开发者配置，Spring Cloud Gateway也内置了一些全局过滤器，如下图：

GlobalFilter的功能其实和GatewayFilter是相同的，只是GlobalFilter的作用域是所有的路由配置，而不是绑定在指定的路由配置上。多个GlobalFilter可以通过@Order或者getOrder()方法指定每个GlobalFilter的执行顺序，order值越小，GlobalFilter执行的优先级越高。

注意，由于过滤器有pre和post两种类型，pre类型过滤器如果order值越小，那么它就应该在pre过滤器链的顶层，post类型过滤器如果order值越小，那么它就应该在pre过滤器链的底层。示意图如下：

当然除了内置的全局过滤器，实际工作中还需要定制过滤器，下面来介绍一下如何自定义。

场景：模拟Nginx的Access Log 功能，记录每次请求的相关信息。代码如下：

/**

• 实现GlobalFilter

*/

@Slf4j

@Component

@Order(value = Integer.MIN_VALUE)

public class AccessLogGlobalFilter implements GlobalFilter {

@Override

public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {

//filter的前置处理

ServerHttpRequest request = exchange.getRequest();

String path = request.getPath().pathWithinApplication().value();

InetSocketAddress remoteAddress = request.getRemoteAddress();

return chain

//继续调用filter

.filter(exchange)

//filter的后置处理

.then(Mono.fromRunnable(() -> {

ServerHttpResponse response = exchange.getResponse();

HttpStatus statusCode = response.getStatusCode();

log.info(“请求路径:{},远程IP地址:{},响应码:{}”, path, remoteAddress, statusCode);

}));

}

}

好了，全局过滤器不必在路由上配置，注入到IOC容器中即可全局生效。

此时发出一个请求，控制台打印信息如下：

请求路径:/gateway/provider/port,远程IP地址:/0:0:0:0:0:0:0:1:64114,响应码:200 OK

如何集成注册中心？

=========

上述demo中并没有集成注册中心，每次路由配置都是指定固定的服务uri，如下图：

这样做有什么坏处呢？

• 服务的IP的地址一旦修改了，路由配置中的uri必须修改

• 服务集群中无法实现负载均衡

此时就需要集成的注册中心，使得网关能够从注册中心自动获取uri（负载均衡）。

这里的注册中心当然选择Nacos，又不熟悉的小伙伴请看陈某《Spring Cloud 进阶》专栏的第一篇文章：五十五张图告诉你微服务的灵魂摆渡者Nacos究竟有多强？

pom文件中新增Nacos依赖，如下：

com.alibaba.cloud

spring-cloud-starter-alibaba-nacos-discovery

启动类上开启注册中心功能，如下图：

配置文件中指定nacos注册中心的地址：

spring:

application:

指定服务名称，在nacos中的名字

name: cloud-gateway

cloud:

nacos:

discovery:

nacos的服务地址，nacos-server中IP地址:端口号

server-addr: 127.0.0.1:8848

路由配置中唯一不同的就是路由的uri，格式：lb://service-name，这是固定写法：

• lb：固定格式，指的是从nacos中按照名称获取微服务,并遵循负载均衡策略

• service-name：nacos注册中心的服务名称，这里并不是IP地址形式的

集成Nacos注册中心完整的配置demo如下：

spring:

application:

指定服务名称，在nacos中的名字

name: cloud-gateway

cloud:

nacos:

discovery:

nacos的服务地址，nacos-server中IP地址:端口号

server-addr: 127.0.0.1:8848

gateway:

路由

routes:

id只要唯一即可，名称任意

• id: gateway-provider_1

使用了lb形式，从注册中心负载均衡的获取uri

uri: lb://gateway-provider

配置断言

predicates:

Path Route Predicate Factory断言，满足/gateway/provider/**这个请求路径的都会被路由到http://localhost:9024这个uri中

• Path=/gateway/provider/**

配置过滤器（局部）

filters:

• AddResponseHeader=X-Response-Foo, Bar

为什么指定了lb就可以开启负载均衡，前面说过全局过滤器LoadBalancerClientFilter就是负责路由寻址和负载均衡的，可以看到如下源码：

如何实现动态路由？

=========

上述例子都是将网关的一系列配置写到项目的配置文件中，一旦路由发生改变必须要重新项目，这样维护成本很高。

其实我们可以将网关的配置存放到配置中心中，这样由配置中心统一管理，一旦路由发生改变，只需要在配置中心修改，这样便能达到一处修改，多出生效的目的。

这里当然要使用Nacos作为配置中心了，添加依赖如下：

com.alibaba.cloud

spring-cloud-starter-alibaba-nacos-config

在bootstrap.yml文件中指定Nacos作为配置中心的一些相关配置：

spring:

application:

指定服务名称，在nacos中的名字

name: cloud-gateway

cloud:

nacos:

todo 此处作为演示，仅仅配置了后缀，其他分组，命名空间根据需要自己配置

config:

server-addr: 127.0.0.1:8848

指定文件后缀未yaml

file-extension: yaml

在nacos中的public命名空间中创建dataId为cloud-gateway.yaml的配置（未指定环境），配置内容如下：

到这里已经配置完成了。至于效果自己动动小手试试吧…

如何自定义全局异常处理？

============

通过前面的测试可以看到一个现象：一旦路由的微服务下线或者失联了，Spring Cloud Gateway直接返回了一个错误页面，如下图：

显然这种异常信息不友好，前后端分离架构中必须定制返回的异常信息。

传统的Spring Boot 服务中都是使用@ControllerAdvice 来包装全局异常处理的，但是由于服务下线，请求并没有到达。

小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。

深知大多数初中级Java工程师，想要提升技能，往往是自己摸索成长，但自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！

因此收集整理了一份《2024年最新Java开发全套学习资料》送给大家，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。

由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频

如果你觉得这些内容对你有帮助，可以添加下面V无偿领取！（备注Java）

总结

这个月马上就又要过去了，还在找工作的小伙伴要做好准备了，小编整理了大厂java程序员面试涉及到的绝大部分面试题及答案，希望能帮助到大家

成长，但自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！**

因此收集整理了一份《2024年最新Java开发全套学习资料》送给大家，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。
[外链图片转存中…(img-ISvrMqbk-1711154192554)]
[外链图片转存中…(img-Fe6kVQSY-1711154192555)]
[外链图片转存中…(img-jbRCTKYt-1711154192555)]

由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频

如果你觉得这些内容对你有帮助，可以添加下面V无偿领取！（备注Java）
[外链图片转存中…(img-NuWjaBR4-1711154192556)]

总结

这个月马上就又要过去了，还在找工作的小伙伴要做好准备了，小编整理了大厂java程序员面试涉及到的绝大部分面试题及答案，希望能帮助到大家

[外链图片转存中…(img-rzZ0nXBE-1711154192556)]

[外链图片转存中…(img-AJWVP1Kt-1711154192557)]

本文已被CODING开源项目：【一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频+实战项目源码】收录