网关的作用
- 对用户请求作身份认证、权限校验
- 将用户请求路由到微服务,并实现负载均衡
- 对用户请求作限流
引入依赖
<!--nacos服务注册发现依赖--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!--网关gateway依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency>
application.yml文件
server:port: 10010
spring:application:name: gatewaycloud:nacos:server-addr: localhost:8848 # nacos地址gateway:routes:- id: user-service # 路由标识,必须唯一uri: lb://userservice # 路由的目标地址predicates: # 路由断言,判断请求是否符合规则- Path=/user/** # 路径断言,判断路径是否是以/user开头,如果是则符合- id: order-serviceuri: lb://orderservicepredicates:- Path=/order/**
然后就出现了服务无法访问的情况,一直报错
Whitelabel Error Page
This application has no configured error view, so you are seeing this as a fallback.Wed May 18 15:38:29 CST 2022
[fd8c3a90-7] There was an unexpected error (type=Service Unavailable, status=503).
原因如下
由于springcloud2020弃用了Ribbon,因此Alibaba在2021版本nacos中删除了Ribbon的jar包,因此无法通过lb路由到指定微服务,出现了503情况。
所以只需要引入springcloud loadbalancer包即可
解决办法:在pom.xml文件中添加了一个依赖:
<!--客户端负载均衡loadbalancer-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
重新启动,果然可以了。 如果还不行把UserApplication和OrderApplication重新启动一下试试就可以了
GatewayFilterFactory过滤器工厂
server:port: 10010
spring:application:name: gatewaycloud:nacos:server-addr: localhost:8848 # nacos地址gateway:routes:- id: user-service # 路由标识,必须唯一uri: lb://userservice # 路由的目标地址predicates: # 路由断言,判断请求是否符合规则- Path=/user/** # 路径断言,判断路径是否是以/user开头,如果是则符合
# filters:
# - AddRequestHeader=Truth,Itcast is freaking awesome! # 局部过滤器- id: order-serviceuri: lb://orderservicepredicates:- Path=/order/**default-filters:- AddRequestHeader=Truth,Itcast is freaking awesome! # 默认过滤器
总结:这里使用的是添加请求头
全局过滤器GlobalFilter
步骤1:自定义过滤器
自定义类,实现GlobalFilter接口,添加@Order注解
//@Order(-1)
@Component
public class AuthorizeFilter implements GlobalFilter , Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 1.获取请求上下文ServerHttpRequest request = exchange.getRequest();// 2.获取请求参数MultiValueMap<String, String> params = request.getQueryParams();// 3.获取authorization参数String authorization = params.getFirst("authorization");// 4.校验if ("admin".equals(authorization)) {// 5.放行return chain.filter(exchange);}// 6.拦截// 6.1.设置状态码401exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);// 6.2.结束处理return exchange.getResponse().setComplete();}@Overridepublic int getOrder() {return -1;}
}
过滤器执行顺序
网关跨域问题处理
application.yml文件
spring:cloud:gateway:globalcors: # 全局的跨域处理add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题corsConfigurations:'[/**]':allowedOrigins: # 允许哪些网站的跨域请求- "http://localhost:8090"- "http://www.leyou.com"allowedMethods: # 允许的跨域ajax的请求方式- "GET"- "POST"- "DELETE"- "PUT"- "OPTIONS"allowedHeaders: "*" # 允许在请求中携带的头信息allowCredentials: true # 是否允许携带cookiemaxAge: 360000 # 这次跨域检测的有效期