Gateway服务网关 (入门到使用)（）

2023-03-22 16:12:18 分类：java 阅读()

　　本篇文章为你整理了Gateway服务网关 (入门到使用)（）的详细内容，包含有 Gateway服务网关 (入门到使用)，希望能帮助你了解 Gateway服务网关 (入门到使用)。

　　 Spring Cloud Gateway 是 Spring Cloud 的一个全新项目，该项目是基于 Spring 5.0，Spring Boot 2.0 和 Project Reactor 等响应式编程和事件流技术开发的网关，它旨在为微服务架构提供一种简单有效的统一的 API 路由管理方式。① 身份认证和权限校验。一切请求要先经过网关，再到微服务。请求来了，我需要验证你是谁？验证通过才放行到对应的微服务。② 服务路由、负载均衡。③ 请求限流。例如每个微服务限制的请求是500个，现在来了2000个，那么网关就会控制这些请求，进行限制。

　　
Zuul也是网关但比较老是一种阻塞式编程；Spring Cloud Gateway 是 Spring Cloud 的一个全新项目，该项目是基于 Spring 5.0，Spring Boot 2.0 和 Project Reactor 等响应式编程和事件流技术开发的网关，它旨在为微服务架构提供一种简单有效的统一的 API 路由管理方式。

　　在SpringCloud中网关的实现包括两种：

　　gateway

　　Zuul是基于Servlet的实现，属于阻塞式编程。而SpringCloudGateway则是基于Spring5中提供的WebFlux，属于响应式编程的实现，具备更好的性能。

　　Gateway网关是我们服务的守门神，所有微服务的统一入口。

　　网关的核心功能特性：

　　请求路由 ：就是发送请求到相应的微服务

　　架构图：

　　权限控制：网关作为微服务入口，需要校验用户是是否有请求资格，如果没有则进行拦截。

　　路由和负载均衡：一切请求都必须先经过gateway，但网关不处理业务，而是根据某种规则，把请求转发到某个微服务，这个过程叫做路由。当然路由的目标服务有多个时，还需要做负载均衡。

　　限流：当请求流量过高时，在网关中按照下流的微服务能够接受的速度来放行请求，避免服务压力过大。

　　网关路由流程图：

　　使用网关步骤

　　1） 创建gateway微服务，导入依赖

　　

 !--网关--

 

　　 dependency

　　 groupId org.springframework.cloud /groupId

　　 artifactId spring-cloud-starter-gateway /artifactId

　　 /dependency

　　 !--nacos服务发现依赖 自己也要注册到nacos--

　　 dependency

　　 groupId com.alibaba.cloud /groupId

　　 artifactId spring-cloud-starter-alibaba-nacos-discovery /artifactId

　　 /dependency

　　

 

　　2） 编写启动类

　　

@SpringBootApplication

 

　　public class GatewayApplication {

　　 public static void main(String[] args) {

　　 SpringApplication.run(GatewayApplication.class, args);

　　

 

　　3）编写基础配置和路由规则

　　路由配置包括：

　　
- Path=/user/**

　　 - After=2021-01-20T17:42:47.789-07:00[America/Denver] #断言：只有在这个事件后发送的请求才可以

　　 - id: user-service # 路由id，自定义，只要唯一即可

　　 # uri: http://127.0.0.1:8081 # 路由的目标地址 http就是固定地址

　　 uri: lb://userservice # 路由的目标地址 lb就是负载均衡，后面跟服务名称

　　 predicates: # 路由断言，也就是判断请求是否符合路由规则的条件

　　 - Path=/user/** # 这个是按照路径匹配，只要以/user/开头就符合要求

　　 filters: # 过滤器（当前过滤器写在userservice路由下，因此仅仅对访问userservice的请求有效）

　　 - AddRequestHeader=Conan, isMe! # 添加请求头

　　 default-filters: # 默认过滤项（对所有路由都有效）

　　 - AddRequestHeader=Truth, Itcast is freaking awesome!

　　

 

 

　　我们将符合Path 规则的一切请求，都代理到 uri参数指定的地址。

　　本例中，我们将 /user/**开头的请求，代理到lb://userservice，lb是负载均衡，根据服务名拉取服务列表，实现负载均衡。

　　重启网关，访问http://localhost:10010/user/1时，符合/user/**规则，请求转发到uri：http://userservice/user/1，得到了结果：

　　4） 自定义全局过滤器

　　可有可无，在需要做一些复杂的过滤情况时使用，如：只允许authorization=admin的用户发送请求

　　在gateway中定义一个全局过滤器：

　　

package cn.itcast.gateway.filters;

 

　　import org.springframework.cloud.gateway.filter.GatewayFilterChain;

　　import org.springframework.cloud.gateway.filter.GlobalFilter;

　　import org.springframework.core.annotation.Order;

　　import org.springframework.http.HttpStatus;

　　import org.springframework.stereotype.Component;

　　import org.springframework.web.server.ServerWebExchange;

　　import reactor.core.publisher.Mono;

　　@Order(-1)

　　@Component

　　public class AuthorizeFilter implements GlobalFilter {

　　 @Override

　　 public Mono Void filter(ServerWebExchange exchange, GatewayFilterChain chain) {

　　 // 1.获取请求参数

　　 MultiValueMap String, String params = exchange.getRequest().getQueryParams();

　　 // 2.获取authorization参数

　　 String auth = params.getFirst("authorization");

　　 // 3.校验

　　 if ("admin".equals(auth)) {

　　 // 放行

　　 return chain.filter(exchange);

　　 // 4.拦截

　　 // 4.1.禁止访问，设置状态码

　　 exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);

　　 // 4.2.结束处理

　　 return exchange.getResponse().setComplete();

　　

 

　　5） 解决跨域问题

　　

spring:

 

　　 cloud:

　　 gateway:

　　 #解决跨域问题

　　 globalcors: # 全局的跨域处理

　　 add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题

　　 corsConfigurations:

　　 [/**]: # /**是说拦截所有请求

　　 allowedOrigins: # 允许哪些网站的跨域请求

　　 - "http://localhost:8090"

　　 allowedMethods: # 允许的跨域ajax的请求方式

　　 - "GET"

　　 - "POST"

　　 - "DELETE"

　　 - "PUT"

　　 - "OPTIONS"

　　 allowedHeaders: "*" # 允许在请求中携带的头信息

　　 allowCredentials: true # 是否允许携带cookie

　　 maxAge: 360000 # 这次跨域检测的有效期

　　

 

　　断言更像是一种对请求做限制条件，只有符合的请求才能成功访问请求

　　我们在配置文件中写的断言规则只是字符串，这些字符串会被Predicate Factory读取并处理，转变为路由判断的条件

　　例如Path=/user/**是按照路径匹配，这个规则是由

　　org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory类来

　　处理的，像这样的断言工厂在SpringCloudGateway还有十几个: 【需要时要哪个再学着用哪个】

　　
是某两个时间点之前的请求

　　- Between=2037-01-20T17:42:47.789-07:00[America/Denver], 2037-01-21T17:42:47.789-07:00[America/Denver]

　　
这里的过滤器不是springMVC的过滤器，而是对进来的请求进行加工处理。

　　过滤器作用：

　　① 对路由的请求或响应做加工处理，比如添加请求头

　　② 配置在路由下的过滤器只对当前路由的请求生效

　　GatewayFilter是网关中提供的一种过滤器，可以对进入网关的请求和微服务返回的响应做处理：

　　路由过滤器的种类

　　Spring提供了31种不同的路由过滤器工厂。例如：如下举例五种

　　
需求：给所有进入userservice的请求添加一个请求头：Truth=itcast is freaking awesome!

　　AddRequestHeader= Truth, Itcast is freaking awesome! 逗号前面是key，后面是value

　　只需要修改gateway服务的application.yml文件，添加路由过滤即可：

　　

spring:

 

　　 cloud:

　　 gateway:

　　 routes:

　　 - id: user-service

　　 uri: lb://userservice

　　 predicates:

　　 - Path=/user/**

　　 filters: # 过滤器

　　 - AddRequestHeader=Truth, Itcast is freaking awesome! # 添加请求头

　　

 

　　当前过滤器写在userservice路由下，因此仅仅对访问userservice的请求有效。

　　默认过滤器

　　如果要对所有的路由都生效，则可以将过滤器工厂写到default下。格式如下：

　　

spring:

 

　　 cloud:

　　 gateway:

　　 routes:

　　 - id: user-service

　　 uri: lb://userservice

　　 predicates:

　　 - Path=/user/**

　　 default-filters: # 默认过滤项

　　 - AddRequestHeader=Truth, Itcast is freaking awesome!

　　

 

　　全局过滤器

　　网关提供了31种，但每一种过滤器的作用都是固定的。如果我们希望拦截请求，做自己的业务逻辑则没办法实现。

　　全局过滤器作用

　　全局过滤器的作用也是处理一切进入网关的请求和微服务响应，与GatewayFilter的作用一样。区别在于GatewayFilter通过配置定义，处理逻辑是固定的；而GlobalFilter的逻辑需要自己写代码实现。

　　定义方式是实现GlobalFilter接口。

　　

public interface GlobalFilter {

 

　　 * 处理当前请求，有必要的话通过{@link GatewayFilterChain}将请求交给下一个过滤器处理

　　 * @param exchange 请求上下文，里面可以获取Request、Response等信息

　　 * @param chain 用来把请求委托给下一个过滤器

　　 * @return {@code Mono Void } 返回标示当前过滤器业务结束

　　 Mono Void filter(ServerWebExchange exchange, GatewayFilterChain chain);

　　

 

　　在filter中编写自定义逻辑，可以实现下列功能：

　　登录状态判断

　　请求限流等

　　自定义全局过滤器

　　需求：定义全局过滤器，拦截请求，判断请求的参数是否满足下面条件：

　　
import org.springframework.cloud.gateway.filter.GatewayFilterChain;

　　import org.springframework.cloud.gateway.filter.GlobalFilter;

　　import org.springframework.core.annotation.Order;

　　import org.springframework.http.HttpStatus;

　　import org.springframework.stereotype.Component;

　　import org.springframework.web.server.ServerWebExchange;

　　import reactor.core.publisher.Mono;

　　@Order(-1)

　　@Component

　　public class AuthorizeFilter implements GlobalFilter {

　　 @Override

　　 public Mono Void filter(ServerWebExchange exchange, GatewayFilterChain chain) {

　　 // 1.获取请求参数

　　 MultiValueMap String, String params = exchange.getRequest().getQueryParams();

　　 // 2.获取authorization参数

　　 String auth = params.getFirst("authorization");

　　 // 3.校验

　　 if ("admin".equals(auth)) {

　　 // 放行

　　 return chain.filter(exchange);

　　 // 4.拦截

　　 // 4.1.禁止访问，设置状态码

　　 exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);

　　 // 4.2.结束处理

　　 return exchange.getResponse().setComplete();

　　

 

 

　　过滤器执行顺序【重要】

　　请求进入网关会碰到三类过滤器：当前路由的过滤器、DefaultFilter、GlobalFilter

　　请求路由后，会将当前路由过滤器和DefaultFilter、GlobalFilter，合并到一个过滤器链（集合）中，排序后依次执行每个过滤器：

　　排序的规则是什么呢？

　　每一个过滤器都必须指定一个int类型的order值，order值越小，优先级越高，执行顺序越靠前。

　　GlobalFilter通过实现Ordered接口，或者添加@Order(1) 注解来指定order值，由我们自己指定

　　路由过滤器和defaultFilter的order由Spring指定，默认是按照声明顺序从1递增。

　　当过滤器的order值一样时，会按照 defaultFilter 路由过滤器 GlobalFilter的顺序执行。

　　详细内容，可以查看源码：

　　org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator#getFilters()方法是先加载defaultFilters，然后再加载某个route的filters，然后合并。

　　org.springframework.cloud.gateway.handler.FilteringWebHandler#handle()方法会加载全局过滤器，与前面的过滤器合并后根据order排序，组织过滤器链

　　什么是跨域问题

　　跨域：域名不一致就是跨域，主要包括：

　　
跨域问题：浏览器禁止请求的发起者与服务端发生跨域ajax请求，请求被浏览器拦截的问题

　　所以只是单纯的服务之间的请求是没有ajax请求所以不会出现跨域问题，但前端发送请求就有ajax，此时需要考虑跨域问题。

　　解决方案：CORS，这个以前应该学习过，这里不再赘述了。不知道的小伙伴可以查看https://www.ruanyifeng.com/blog/2016/04/cors.html

　　模拟跨域问题

　　找到课前资料的页面文件：

　　放入tomcat或者nginx这样的web服务器中，启动并访问。

　　可以在浏览器控制台看到下面的错误：

　　从localhost:8090访问localhost:10010，端口不同，显然是跨域的请求。

　　解决跨域问题

　　在gateway服务的application.yml文件中，添加下面的配置：

　　

spring:

 

　　 cloud:

　　 gateway:

　　 #解决跨域问题

　　 globalcors: # 全局的跨域处理

　　 add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题

　　 corsConfigurations:

　　 [/**]:

　　 allowedOrigins: # 允许哪些网站的跨域请求

　　 - "http://localhost:8090"

　　 allowedMethods: # 允许的跨域ajax的请求方式

　　 - "GET"

　　 - "POST"

　　 - "DELETE"

　　 - "PUT"

　　 - "OPTIONS"

　　 allowedHeaders: "*" # 允许在请求中携带的头信息

　　 allowCredentials: true # 是否允许携带cookie

　　 maxAge: 360000 # 这次跨域检测的有效期

　　

 

　　以上就是Gateway服务网关 (入门到使用)（）的详细内容，想要了解更多 Gateway服务网关 (入门到使用)的内容，请持续关注盛行IT软件开发工作室。

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

标签： java

相关文章阅读

  • java Springboot集成mybatis-plus的方法是什么
  • 浅谈几种Java自定义异常处理方式
  • Java Map所有的值转为String类型
  • java代码中格式化金额 java格式化小数
  • java计算器源代码资源 java计算器简单代码
  • 【java】（一）SpringBoot 源码解析——SpringApplication 初始化（）
  • Spring学习笔记（spring教程 csdn）
  • HDFS Architecture Guide（）
  • 哈工大软件构造Lab3（2022）（哈工大软件构造lab3）
  • nginx基础（nginx基础教程）
  • Java 中HashMap详解(含HashTable, ConcurrentHashMap)（java hashmap使用方法）
  • Java 线程池之Jetty 线程池学习总结（java线程池的使用方法）
  • java线程基础（java 线程教程）
  • 聊聊 Netty 那些事儿之 Reactor 在 Netty 中的实现(创建篇)（）
  • nginx（nginx负载均衡）
    • 留言与评论（共有 条评论）
       
    验证码：