Gateway网关

宗政颖逸
2023-12-01

搭建网关服务

1.创建新的moddule,引入SpringCloudGateway的依赖和nacos的服务发现依赖

<!--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>

2.编写路由配置及nacos地址,新建application.yml文件,编写以下内容

server:
  port: 10010 #网关端口
spring:
  application:
    name: gateway #服务名称
  cloud:
    nacos:
      server-addr: localhost:80 #nacos地址,网关服务注册到nacos上
    gateway:
      routes: #网关路由配置
        - id: user-service #路由id,自定义,唯一即可
          uri: lb://userservice #路由的目标地址lb就是负载均衡的意思,后面跟服务名称
          predicates: #路由断言,也就是判断请求是否符合规则的条件
            - Path=/user/** #这个是按照路径匹配,只要以/user/开头就符合要求
        - id: order-service
          uri: lb://orderservice-abc #和服务名称要一致
          predicates:
            - Path=/order/**
            #- After=2031-01-13T15:42:47.789+08:00[Asia/Shanghai] #访问的时间必须大于这里设置的时间,否则无法访问到该服务
            - Before=2031-01-13T15:42:47.789+08:00[Asia/Shanghai] #访问该服务的时间必须小于这里设置的值,否则无法访问到该服务

3.通过网关访问指定服务

localhost:10010/order/101

4.Gateway官方文档地址

https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#the-after-route-perdicate-factory

5.Gateway过滤器

只针对配置过路由的服务生效:

spring.cloud.gateway.reoutes:
    - id: user-service #路由id,自定义,唯一即可
      uri: lb://userservice #路由的目标地址lb就是负载均衡的意思,后面跟服务名称
      predicates: #路由断言,也就是判断请求是否符合规则的条件
        - Path=/user/** #这个是按照路径匹配,只要以/user/开头就符合要求
    - id: order-service
      uri: lb://orderservice-abc #这里要和服务名称保持一致
      predicates:
        - Path=/order/**
        #- After=2031-01-13T15:42:47.789+08:00[Asia/Shanghai] #访问的时间必须大于这里设置的时间,否则无法访问到该服务
        - Before=2031-01-13T15:42:47.789+08:00[Asia/Shanghai] #访问该服务的时间必须小于这里设置的值,否则无法访问到该服务
      filters: #路由过滤器
    	- AddRequestHeader=Truth,Itcast is freaking aowsome! #只针对配置的路由有效

默认过滤器,对所有路由都生效:

spring.cloud.gateway.default-filters:
        - AddRequestHeader=Truth,Itcast is freaking aowsome! #向请求头中添加信息,字段名为Truth,值为Itcast is freaking aowsome!

6.全局过滤器,自定义过滤器类实现GlobalFilter接口,添加@Order注解设置过滤器顺序

package cn.itcast.gateway;

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.Order;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.util.MultiValueMap;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;

//@Order(-1)/*方法一:通过注解的方式设置过滤器的顺序,值越小有限级越高*/
@Component
public class AuthorizeFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        //1.获取请求参数
        ServerHttpRequest request = exchange.getRequest();
        MultiValueMap<String, String> params = request.getQueryParams();

        //2.获取参数中的 authrization 参数
        String auth = params.getFirst("authrization");

        //3.判断参数值是否等于admin
        if("admin".equals(auth)){
            //4.相等,放行
            return chain.filter(exchange);
        }
        //5.不相等,拦截
        //5.1设置状态码
        exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
        return exchange.getResponse().setComplete();
    }


    /**
     * 方法二:通过实现接口的方式设置过滤器的顺序,值越小有限级越高
     * @return
     */
    @Override
    public int getOrder() {
        return -1;
    }
}

7.过滤器执行顺序

  • 每一个过滤器都必须指定一个int类型的order值,order值越小,优先级越高,执行顺序越靠前
  • GlobalFilter通过实现Orderd接口,或者添加@Order注解来指定order值,由我们自己指定
  • 路由过滤器和defaultFilter由Spring指定,默认是按照声明顺序从1递增
  • 当过滤器的order值一样时,会按照defaultFilter > 路由过滤器 > GlobalFilter的顺序执行

8.Gateway允许浏览器跨域设置,在application.yml配置文件添加以下内容

spring.cloud.gateway.globalcors:	#全局的跨域处理
	add-to-simple-url-handler-mapping: true #解决options请求被拦截的问题
	corsConfiguration:
		'[/**]':
			allowedOrigins:	#设置允许跨域的网站
				- "http://localhost:8090"
				- "http://www.leyou.com"
			allowedMethods: #允许跨域订单请求方式
				- "GET"
				- "POST"
				- "DELETE"
				- "PUT"
				- "OPTIONS"
			allowedHeaders: "*" #允许在请求中携带的头信息
			allowCredentials: true #是否允许携带cookie
			maxAge: 360000 #本次跨域检测的有效期为一个小时
 类似资料: