首页 > 编程入门 文章详情

SpringCloud中级(二) ——Gateway新一代网关

编程入门 行业动态 更新时间:2024-10-25 04:19:34

SpringCloud中级(二) ——Gateway<a href=https://www.elefans.com/category/jswz/34/1766273.html style=新一代网关"/>

SpringCloud中级(二) ——Gateway新一代网关

目录

    • 概述简介
      • 概述
      • 有了Zuul了怎么又出来了gateway
      • 模型比较
      • 三大核心概念
      • Gateway工作流程
    • 入门配置
      • 测试
    • Gateway网关路由有两种配置方式
      • 第一种：在配置文件yml中配置
      • 第二种：代码中注入RouteLocator的Bean
    • 通过微服务名实现动态路由
      • 示例
        • 代码中注入RouteLocator的Bean
    • Predicate断言的使用
      • 是什么
      • 常用的Route Predicate
        • After Route Predicate
        • Cookie Route Predicate
        • Header Route Predicate
        • Host Route Predicate
        • Method Route Predicate
        • Path Route Predicate
        • Query Route Predicate
        • 小总结
    • Filter的使用
      • 是什么
        • 自定义全局GlobalFilter
    • 网关统一配置跨域

概述简介

官网：

.2.3.RELEASE/reference/html/

概述



一句话：Spring Cloud Gateway 使用的Webflux中的reactor-netty响应式编程组件，底层使用了Netty通讯框架

能干嘛？

  • 路由
  • 鉴权
  • 流量控制
  • 熔断
  • 日志监控
  • 过滤
    。。。

微服务架构中网关在哪里？
服务提供者和消费者都是微服务。
服务提供者：被其他微服务调用的微服务
服务消费者：调用的其他微服务的微服务

有了Zuul了怎么又出来了gateway

1.neflix不太靠谱，zuul2.0一直跳票,迟迟不发布

2.SpringCloud Gateway具有如下特性

3.Gateway与Zuul的区别

模型比较

Zuul1.x模型：


GateWay模型

gateway基于webflux,而webflux基于netty,netty的I/O操作时异步的，netty模型是同步非阻塞

三大核心概念

  • Route(路由)
    路由是构建网关的基本模块，它由ID，目标URI，一系列的断言和过滤器组成，如果断言为true则匹配该路由
  • Predicate（断言）
    参考的是java8的java.util.function.Predicate开发人员可以匹配HTTP请求中的所有内容（例如请求头或请求参数），如果请求与断言相匹配则进行路由
  • Filter(过滤)
    指的是Spring框架中GatewayFilter的实例，使用过滤器，可以在请求被路由前或者之后对请求进行修改。

Gateway工作流程



核心逻辑：路由转发+执行过滤器链

入门配置

新建一个子模块cloud-gateway-gateway9527
依赖：

 <!--gateway-->
<!--        springcloud版本要为Hoxton.SR6 gateway为2.2.3会报下面的异常-->
<!--        Correct the classpath of your application so that it contains a single, compatible version of reactorty.resources.ConnectionProvider-->
<!--        把springcloud版本改成Hoxton.SR1--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency>

启动类：

@SpringBootApplication
@EnableEurekaClient
public class GateWayMain9527 {public static void main(String[] args) {SpringApplication.run( GateWayMain9527.class,args);}
}

9527网关如何做路由映射？？？
看看服务提供者8001的controller的访问地址，我们目前不想暴露8001端口，希望在8001外面套一层9527
配置文件：

server:port: 9527
spring:application:name: cloud-gatewaycloud:gateway:routes:- id: payment_routh #路由的ID，没有固定规则但要求唯一，建议配合服务名uri: http://localhost:8001   #匹配后提供服务的路由地址predicates:- Path=/payment/get/**   #断言,路径相匹配的进行路由- id: payment_routh2uri: http://localhost:8001predicates:- Path=/payment/lb/**   #断言,路径相匹配的进行路由
eureka:instance:hostname: cloud-gateway-serviceclient:service-url:register-with-eureka: truefetch-registry: truedefaultZone: :7001/eureka

测试

启动Eureka,服务提供者8001，网关9527
访问：
直接访问提供者的接口：
http://localhost:8001/payment/get/1
再通过网关访问，效果一样
http://localhost:9527/payment/get/1

Gateway网关路由有两种配置方式

第一种：在配置文件yml中配置

见前面步骤

第二种：代码中注入RouteLocator的Bean

官网案例：

示例：通过9527网关访问到外网的百度新闻网址（）

编码：

@Configuration
public class GateWayConfig {@Beanpublic RouteLocator customRouteLocator(RouteLocatorBuilder routeLocatorBuilder) {RouteLocatorBuilder.Builder routes = routeLocatorBuilder.routes();//id->path_rote_atguigu  相当于配置文件里配的id//第二个地址表示localhost:9527/guonei,将转发到地址.route("path_rote_atguigu",r -> r.path("/guonei").uri("")).build();routes.route("path_rote_atguigu1",r -> r.path("/game").uri("")).build();return routes.build();}
}

启动：Eureka以及网关模块。
访问：
http://localhost:9527/game
http://localhost:9527/guonei
均能转发成功。

通过微服务名实现动态路由

上面的案例做完，有一些问题。
第一，地址写死，如：localhost:8001 。
第二，服务提供者不可能只有一台机器，所以要实现负载均衡。

以前：

现在：架构还是那个架构，但是不再使用ribbon做负载均衡，而是使用网关，对外暴露统一的服务接口，就是9527网关服务端口，由网关实现负载均衡

示例

默认情况下Gateway会根据注册中心的服务列表，以注册中心上微服务名为路径创建动态路由进行转发，从而实现动态路由的功能。
启动：一个eureka7001+两个服务提供者8001/8002

配置：
1.开启从注册中心动态创建路由的功能，利用微服务名进行路由
2.将写死的地址，改成从配置中心获取，lb，表示启用Gateway的负载均衡功能。

server:port: 9527
spring:application:name: cloud-gatewaycloud:gateway:discovery:locator:enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由routes:- id: payment_routh #路由的ID，没有固定规则但要求唯一，建议配合服务名
#          uri: http://localhost:8001   #匹配后提供服务的路由地址uri: lb://cloud-payment-service  #需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。predicates:- Path=/payment/get/**   #断言,路径相匹配的进行路由- id: payment_routh2
#          uri: http://localhost:8001uri: lb://cloud-payment-service  #需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。predicates:- Path=/payment/lb/**   #断言,路径相匹配的进行路由
eureka:instance:hostname: cloud-gateway-serviceclient:service-url:register-with-eureka: truefetch-registry: truedefaultZone: :7001/eureka

测试：
发现实现了负载均衡的功能。

http://localhost:9527/payment/lb



解决了地址写死的问题，也解决了负载均衡的问题。
需要说明gateway的负载均衡底层使用的就是ribbon。

代码中注入RouteLocator的Bean

上面的是使用配置文件的方式，现在展示一下使用硬编码的方式

@Configuration
public class GateWayConfig {@Beanpublic RouteLocator customRouteLocator(RouteLocatorBuilder routeLocatorBuilder) {RouteLocatorBuilder.Builder routes = routeLocatorBuilder.routes();routes.route("payment_routh",r -> r.path("/payment/get/** ").uri("lb://cloud-payment-service")).build();routes.route("payment_routh2",r -> r.path("/payment/lb/**").uri("lb://cloud-payment-service")).build();return routes.build();}
}

配置文件：

spring:application:name: cloud-gatewaycloud:gateway:discovery:locator:enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由

Predicate断言的使用

是什么

通过路由断言判断路由是否可用,匹配成功进行下一步处理，否则则失败。
启动网关子模块。

Route Predicate Factories这个是什么东东？

常用的Route Predicate

After Route Predicate

意思要在指定时间之后，路由才生效

获取当前时间时区：

public class ZonedDateTimeDemo {public static void main(String[] args) {//默认时区ZonedDateTime zonedDateTime=ZonedDateTime.now();System.out.println(zonedDateTime);//2020-07-05T12:19:02.779+08:00[Asia/Shanghai]}
}

测试：
加上 - After=2020-07-05T13:19:02.779+08:00[Asia/Shanghai]

spring:cloud:gateway:discovery:locator:enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由routes:- id: payment_routh #路由的ID，没有固定规则但要求唯一，建议配合服务名
#          uri: http://localhost:8001   #匹配后提供服务的路由地址uri: lb://cloud-payment-service  #需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。predicates:- Path=/payment/get/**   #断言,路径相匹配的进行路由- After=2020-07-05T12:19:02.779+08:00[Asia/Shanghai] #将当前时间，意思要在当前时间之后，访问path中的请求才有效- id: payment_routh2
#          uri: http://localhost:8001uri: lb://cloud-payment-service  #需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。predicates:- Path=/payment/lb/**   #断言,路径相匹配的进行路由- After=2020-07-05T12:19:02.779+08:00[Asia/Shanghai] #将当前时间，意思要在当前时间之后，访问path中的请求才有效

因为当前是时间，已经过去了，所以按照预期，重启服务，肯定能访问接口lb和get。
重启网关。
访问http://localhost:9527/payment/lb

把lb接口对应的-After时间调后一小时：- After=2020-07-05T13:19:02.779+08:00[Asia/Shanghai]
按照预期应该是访问不了改接口了

同理断言Before Route Predicate，Between Route Predicate用法是和After Route Predicate一样的。

- After=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]
- Before=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]
- Between=2020-03-08T10:59:34.102+08:00[Asia/Shanghai] ,  2020-03-08T10:59:34.102+08:00[Asia/Shanghai]
Cookie Route Predicate

断言Cookie，满足指定的cookie，才能访问路由

示例
配置：
添加 - Cookie=username,liuzhihui #断言Cookie key=username value=liuzhihui 满足这个断言才能访问

spring:cloud:gateway:discovery:locator:enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由routes:- id: payment_routh #路由的ID，没有固定规则但要求唯一，建议配合服务名
#          uri: http://localhost:8001   #匹配后提供服务的路由地址uri: lb://cloud-payment-service  #需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。predicates:- Path=/payment/get/**   #断言,路径相匹配的进行路由- After=2020-07-05T12:19:02.779+08:00[Asia/Shanghai] #将当前时间，意思要在当前时间之后，访问path中的请求才有效- id: payment_routh2
#          uri: http://localhost:8001uri: lb://cloud-payment-service  #需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。predicates:- Path=/payment/lb/**   #断言,路径相匹配的进行路由- After=2020-07-05T12:19:02.779+08:00[Asia/Shanghai] #将当前时间，意思要在当前时间之后，访问path中的请求才有效- Cookie=username,liuzhihui #断言Cookie key=username value=liuzhihui 满足这个断言，才能访问路由

测试：接口http://localhost:9527/payment/lb，现在这个接口要能成功访问必须满足两个条件。
第一在指定的时间之后访问；
第二要带上指定的Cookie；

使用curl来测试，curl就是postman底层操作，postman只不过是图形界面操作。
首先，不带cookie访问：curl http://localhost:9527/payment/lb 直接报错了。注意这个属于get请求

然后，带上cookie访问：curl http://localhost:9527/payment/lb --cookie "username=liuzhihui"

加入curl返回中文乱码：

Header Route Predicate

请求头断言，满足指定的请求头，才能访问路由。

示例：

- Header=X-Request-Id, \d+   #请求头中要有X-Request-Id属性并且值为整数的正则表达式


重启网关。
测试：curl http://localhost:9527/payment/lb --cookie "username=liuzhihui" -H "X-Request-Id:123"

Host Route Predicate

host断言

示例：
只要请求头host满足： - Host=**.atguigu,**.liuzhihui，即可转发路由

spring:cloud:gateway:discovery:locator:enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由routes:- id: payment_routh #路由的ID，没有固定规则但要求唯一，建议配合服务名
#          uri: http://localhost:8001   #匹配后提供服务的路由地址uri: lb://cloud-payment-service  #需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。predicates:- Path=/payment/get/**   #断言,路径相匹配的进行路由- After=2020-07-05T12:19:02.779+08:00[Asia/Shanghai] #将当前时间，意思要在当前时间之后，访问path中的请求才有效- id: payment_routh2
#          uri: http://localhost:8001uri: lb://cloud-payment-service  #需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。predicates:- Path=/payment/lb/**   #断言,路径相匹配的进行路由- After=2020-07-05T12:19:02.779+08:00[Asia/Shanghai] #将当前时间，意思要在当前时间之后，访问path中的请求才有效- Cookie=username,liuzhihui    #断言Cookie key=username value=liuzhihui 满足这个断言才能访问- Header=X-Request-Id, \d+   #请求头中要有X-Request-Id属性并且值为整数的正则表达式- Host=**.atguigu,**.liuzhihui

测试：

curl http://localhost:9527/payment/lb --cookie "username=liuzhihui" -H "X-Request-Id:1"  -H  "Host: aaa.liuzhihui"
curl http://localhost:9527/payment/lb --cookie "username=liuzhihui" -H "X-Request-Id:1"  -H  "Host: www.liuzhihui"
curl http://localhost:9527/payment/lb --cookie "username=liuzhihui" -H "X-Request-Id:1"  -H  "Host: www.atguigu"

Method Route Predicate

接口的请求方式：Get,Post
示例：是get请求，才能进行路由转发

- Method=GET #接口的请求方式

测试：

curl http://localhost:9527/payment/lb -X GET  --cookie "username=liuzhihui" -H "X-Request-Id:1"  -H  "Host: www.atguigu"
curl http://localhost:9527/payment/lb -X POST --cookie "username=liuzhihui" -H "X-Request-Id:1"  -H  "Host: www.atguigu"

Path Route Predicate

请求路径正则匹配指定值。没啥好说的一直都在用。

- Path=/payment/get/**   #断言,路径相匹配的进行路由
Query Route Predicate

查询参数断言

- Query=username, \d+ #要有参数名称并且是正整数才能路由

测试：

predicates:- Path=/payment/lb/**   #断言,路径相匹配的进行路由- After=2020-07-05T12:19:02.779+08:00[Asia/Shanghai] #将当前时间，意思要在当前时间之后，访问path中的请求才有效- Cookie=username,liuzhihui    #断言Cookie key=username value=liuzhihui 满足这个断言才能访问- Header=X-Request-Id, \d+   #请求头中要有X-Request-Id属性并且值为整数的正则表达式- Host=**.atguigu,**.liuzhihui- Method=GET #接口的请求方式- Query=username, \d+ #要有参数名称并且是正整数才能路由- Query=age, \d+ #要有参数名称并且是正整数才能路由

curl "http://localhost:9527/payment/lb?username=1&age=1" -X GET  --cookie "username=liuzhihui" -H "X-Request-Id:1"  -H  "Host: www.atguigu"

小总结

说白了，Predicate就是为了实现一组匹配规则，让请求过来找到对应的Route进行处理。
更多的路由请参考官网：

.2.3.RELEASE/reference/html/#gateway-request-predicates-factories

Filter的使用

是什么

路由过滤器可用于修改进入Http的请求和返回的Http响应，路由过滤器只能指定路由进行使用。spring Cloud Gateway内置了多种路由过滤器，他们都由GatewayFilter的工厂类来产生。

官网：

.2.3.RELEASE/reference/html/#gatewayfilter-factories

生命周期：在业务逻辑之pre；在业务逻辑之后post
种类：GatewayFilter单一过滤器 GlobalFilter全局过滤器

例如：
该路由的意思是，前端发送请过来，如果路径包含/api/xxx，则符合断言规则，然后经过过滤器，将路径改为/renren-fast/xxx

  - id: admin_routeuri: lb://renren-fastpredicates:- Path=/api/**filters:##路径重写- RewritePath=/api/(?<segment>.*),/renren-fast/$\{segment}

实际工作中内置的过滤器用的并不多，用的更多的是自定义过滤器。

自定义全局GlobalFilter

首先要实现两接口impiemerts GlobalFilter ，Ordered
能干嘛？
全局日志记录
统一网关鉴权
。。。。

案例：
网关子模块里，新建一个过滤器包

@Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter,Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("*********come in MyLogGateWayFilter: "+new Date());String username = exchange.getRequest().getQueryParams().getFirst("username");if(StringUtils.isEmpty(username)){log.info("*****用户名为Null 非法用户,(┬＿┬)");exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);//给人家一个回应return exchange.getResponse().setComplete();}return chain.filter(exchange);}@Overridepublic int getOrder() {return 0;}
}

配置文件：
将之前的断言注释了，只留- Path 避免干扰

          predicates:- Path=/payment/lb/**   #断言,路径相匹配的进行路由
#            - After=2020-07-05T12:19:02.779+08:00[Asia/Shanghai] #将当前时间，意思要在当前时间之后，访问path中的请求才有效
#            - Cookie=username,liuzhihui    #断言Cookie key=username value=liuzhihui 满足这个断言才能访问
#            - Header=X-Request-Id, \d+   #请求头中要有X-Request-Id属性并且值为整数的正则表达式
#            - Host=**.atguigu,**.liuzhihui
#            - Method=GET #接口的请求方式
#            - Query=username, \d+ #要有参数名称并且是正整数才能路由
#            - Query=age, \d+ #要有参数名称并且是正整数才能路由

重启网关。
正确的访问：http://localhost:9527/payment/lb?username=z3

错误的访问：

http://localhost:9527/payment/lb

网关统一配置跨域

什么是跨域?
跨域：指的是浏览器不能执行其他网站的脚本。它是由浏览器的同源策略造成的，是浏览器对javascript施加的安全限制。
同源策略：是指协议，域名，端口都要相同，其中有一个不同都会产生跨域；

跨域流程？
非简单请求(put,delete)等，需要先发送预检请求，询问是否允许跨域。

跨域问题：如下图所示

解决跨域的方式一：
跨域的根本原因，目标网站跟想要发远程请求的网站不在同一域；
用nginx把它们转化为同一域；
具体做法：比如有一台nginx服务器，将前端项目也部署到里面，后台的网关也让nginx代理
能行，但是太麻烦了

解决跨域的方式二：
网关统一配置跨域，在网关处添加一个过滤器，所有请求过来，我都给它配置允许跨域。

@Configuration
public class GulimallCorsConfiguration {/*** springboot提供了跨域的过滤器CorsWebFilter* @return*/@Beanpublic CorsWebFilter corsWebFilter(){UrlBasedCorsConfigurationSource urlBasedCorsConfigurationSource = new UrlBasedCorsConfigurationSource();CorsConfiguration corsConfiguration = new CorsConfiguration();//配置跨域//允许哪些都跨域corsConfiguration.addAllowedHeader("*");//允许哪些请求方式跨域corsConfiguration.addAllowedMethod("*");//允许哪些请求来源跨域corsConfiguration.addAllowedOrigin("*");//是否允许携带cookies跨域corsConfiguration.setAllowCredentials(true);//注册跨域配置urlBasedCorsConfigurationSource.registerCorsConfiguration("/**",corsConfiguration);return new CorsWebFilter(urlBasedCorsConfigurationSource);}
}

再次测试需要跨域的接口：
发现会有两次请求，其中一次是预检请求，并且发现请求头添加上了配置的跨域信息，但是是不携带数据的；
另一个就是真实的请求了，携带有真实的数据

更多推荐

SpringCloud中级(二) ——Gateway新一代网关

本文发布于:2024-03-13 01:41:49，感谢您对本站的认可！
本文链接:https://www.elefans.com/category/jswz/34/1732901.html
版权声明:本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系，我们将在24小时内删除。
本文标签：新一代   网关   SpringCloud   Gateway

发布评论

评论列表 （有 0 条评论）

最近发表

草根站长

>www.elefans.com

编程频道|电子爱好者 - 技术资讯及电子产品介绍！

热门文章

标签列表