一、简介
网关是一个服务：
Spring Cloud GateWay是Spring Cloud的?个全新项?，?标是取代Netflix Zuul，基于Spring5.0+SpringBoot2.0+WebFlux（基于?性能的Reactor模式响应式通信框架Netty，异步?阻塞模型）等技术开发，性能?于Zuul，官?测试，GateWay是Zuul的1.6倍，旨在为微服务架构提供?种简单有效的统?的API路由管理?式。
二、开始使用
1.引入包（gateway）????????
<!-- 网关 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!-- 负载均衡 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
2. 配置nacos进行服务注册和发现
? ? ? ? 描述：使用nacos+gateway实现各模块服务的负载均衡
? ? ? ? nacos的配置使用可以参考文章：
????????SpringCloud：注册中心nacos_Cx_轩的博客-CSDN博客
3..yml配置
spring:
application:
name: Cx-gateway
cloud:
gateway:
httpclient:
connect-timeout: 90000 #连接超时 毫秒
response-timeout: 90s #应答超时 java.time.Duration http状态码504
discovery:
locator:
enabled: false # 启用探测器 默认false,开启后可以通过ip:port/服务名称/接口地址进行服务转发
lower-case-service-id: true # 路由名小写
routes:
- id: Cx-admin # admin后台
uri: lb://Cx-admin
predicates:
- Path=/admin/**
filters:
- StripPrefix=1 # 过滤前缀 admin
- id: Cx-es # es服务
uri: lb://Cx-es
predicates:
- Path=/es/**
filters:
- StripPrefix=1 # 过滤前缀 es
此处对predicates断言进行使用描述：（常用的几种列举出来方便大家参考）
1.Path路径断言
predicates:
-Path=/xx # 拦截此路径下的所有请求发送到网关配置的uri (以一个模块一个路径去区分)
2.Query断言
predicates:
-Query=name,age. #参数值可以写正则，也可以只写参数名
3.Method断言
predicates:
-Method=get
4.Host断言
predicates:
-Host=xxxx.com
5.Cookie断言
predicates:
-Cookie=user,Cx #cookie断言和上面介绍的几种断言方式都大同小异，唯一不同的是他必须连同属性值一起验证，不能单独只验证属性是否存在
6.Header断言
predicates:
-Header=id,1234\d+ # 正则表达式\d+ 数字，header断言是检查头信息里是否携带了相关属性或令牌
7.时间路由
predicates:
- After=2022-02-07T17:05:00.789+08:00[Asia/Shanghai] # 时间匹配有三种模式，分别是Before、After和Between，指定了在什么时间范围内路由才会生效
三、网关+单点登录使用
1.使用jwt生成无状态token令牌，然后在网关项目中进行auth验证。
2.创建网关全局拦截
@Configuration
@Component
@Slf4j
public class AuthFilter implements GlobalFilter,Ordered {
private static final String AUTHORIZE_TOKEN = "token";
private static AntPathMatcher matcher = new AntPathMatcher();
@Override
public int getOrder() {
return 0;
}
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
ServerHttpRequest request = exchange.getRequest();
String url = request.getPath().toString();
log.info("【登录拦截】获取请求地址路径："+url);
// 不需要拦截的url直接通过
if(isNotAuth(url)){
return chain.filter(exchange);
}
String token = request.getHeaders().getFirst(AUTHORIZE_TOKEN);
if(StrUtil.isBlank(token)){
token = request.getQueryParams().getFirst(AUTHORIZE_TOKEN);
}
if(StrUtil.isBlank(token)){
log.info("【登录拦截】未获取到token值...");
loginResponse(exchange);
}
log.debug("【登录拦截】获取token值:"+token);
try {
SSOToken ssoToken = SSOToken.parser(token);
// 获取token中的用户名
String userId = ssoToken.getId();
log.info("【登录拦截】获取userId:"+userId);
} catch (Exception e) {
log.error("【登录拦截】异常:"+e.getMessage());
return loginResponse(exchange);
}
return chain.filter(exchange);
}
public static Mono<Void> loginResponse(ServerWebExchange exchange) {
JSONObject json = JSONUtil.createObj();
json.set("code", 401);
json.set("msg", "请重新登陆授权");
ServerHttpResponse response = exchange.getResponse();
byte[] bytes = JSONUtil.toJsonStr(json).getBytes(StandardCharsets.UTF_8);
//指定编码，否则在浏览器中会中文乱码
response.getHeaders().add("Content-Type", "text/plain;charset=UTF-8");
DataBuffer buffer = response.bufferFactory().wrap(bytes);
return response.writeWith(Flux.just(buffer));
}
private boolean isNotAuth(String url) {
List<String> uriList = new ArrayList<>();
// admin后台不需要拦截
uriList.add("/admin/**");
uriList.add("/sso/login");
for (String pattern : uriList) {
if (matcher.match(pattern, url)) {
// 不需要拦截
return true;
}
}
return false;
}
}
上述代码中SSOToken就是jwt的封装，大家可以直接使用jwt进行解析即可。
注：此处使用jwt无状态token令牌，为了方便不同模块、不同前端项目针对不同ip和端口部署的分布式应用时在进行用户验权时可以不需要考虑会话session和cookie只需要将token存储在浏览器中即可全局使用。在访问时只校验token的有效性。所以在使用jwt的token时可以降低token的有效时长在增加安全性。
|