专业建材网站建设,网站改关键词,单位微信公众号怎么创建,哈尔滨电子网站建设目录 GatewayWebFlux网关基本配置过滤器与断言工厂全局过滤器跨域处理 CORS Gateway WebFlux gateway 基于 webflux 构建 WebFlux 是基于反应式流概念的响应式编程框架#xff0c;用于构建异步非阻塞的 Web 应用程序。它支持响应式编程范式#xff0c;并提供了一种响应式的方… 目录 GatewayWebFlux网关基本配置过滤器与断言工厂全局过滤器跨域处理 CORS Gateway WebFlux gateway 基于 webflux 构建 WebFlux 是基于反应式流概念的响应式编程框架用于构建异步非阻塞的 Web 应用程序。它支持响应式编程范式并提供了一种响应式的方式来处理 Web 请求。
与传统的 Servlet API 相比WebFlux 采用了基于事件驱动的编程模型不依赖于传统的线程池模型。它使用少量的线程来处理大量的请求通过异步非阻塞的方式实现高吞吐量和低延迟。 WebFlux 提供了两种编程模型
响应式 Web 客户端用于发送 HTTP 请求并处理响应。它基于 Reactor 提供了一组操作符和方法可以以声明式的方式组装和处理 HTTP 请求支持异步和流式处理。响应式 Web 服务器提供了一个响应式的 Web 服务器用于处理传入的 HTTP 请求并生成响应。它基于 Reactor 提供了一组用于处理请求和生成响应的 API支持异步非阻塞的处理方式。可以使用注解或函数式编程的方式定义请求处理器处理器可以返回一个单独的响应也可以返回一个表示响应流的 Publisher 对象。 网关基本配置 Gateway 是一个在系统架构中充当入口点的服务器它接收来自客户端的请求并将其转发到后端的服务。网关的作用是在客户端和后端服务之间建立一个中间层用于路由请求等 新建 maven 项目 gateway
pom 添加 gateway 坐标以及负载均衡坐标
!--gateway网关依赖--
dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-gateway/artifactId
/dependency!--loadbalancer负载均衡对于高版本springboot需要额外添加此以来--
dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-loadbalancer/artifactId
/dependency编写入口文件 GatewayApplication.java
SpringBootApplication
public class GatewayApplication {public static void main(String[] args) {SpringApplication.run(GatewayApplication.class, args);}
}进行网关配置
routes 用于设置转发路由他是一个数组表示你可以设置多个转发规则但是各个转发规则的 id 不可以重复
server:port: 2333spring:application:name: gatewaycloud:nacos:server-addr: localhost:8848# 配置gatewaygateway:# 数组方式配置路由转发routes:# 转发id名字随便取但是不可以重复- id: user-service# 被转发的URI格式lb://被转发的服务器名uri: lb://userservice# 断言规则predicates:# 当请求路径是 /user/** 格式的自动转发到指定服务器- Path/user/**# 这是另一组被转发的服务器- id: order-serviceuri: lb://orderservicepredicates:- Path/order/**过滤器与断言工厂
predicates 断言配置属性可以使用以下 11 种 使用 filters 添加过滤器
下面为每个 user 请求都添加了一个名为“Truth”的请求头
gateway:routes:- id: user-serviceuri: lb://userservicepredicates:- Path/user/**# 设置过滤器filters:# 添加请求头格式[请求头名称],[请求头内容]- AddRequestHeaderTruth,shit oh my gods!如果你想一劳永逸的话可以使用 defaultFilters 为全部路由设置请求头
gateway:routes:- id: user-serviceuri: lb://userservicepredicates:- Path/user/**- id: order-serviceuri: lb://orderservicepredicates:- Path/order/**# 默认所有路由都有此路由器default-filters:- AddRequestHeaderTruth,shit oh my gods!全局过滤器
全局过滤器对所有路由转发同时生效
实现该过滤器需要两步
实现 GlobalFilter借助注解 Order 设置过滤器优先级
// order设置-1表示最高优先级
Order(-1)
Component
public class AuthFilter implements GlobalFilter {Overridepublic MonoVoid filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 取出参数并对参数进行校验ServerHttpRequest request exchange.getRequest();MultiValueMapString, String params request.getQueryParams();String auth params.getFirst(authorization);// 检查授权参数是否为 adminif (admin.equals(auth)) {// 授权通过继续传递请求到下一个过滤器或后端服务return chain.filter(exchange);}// 授权失败设置响应状态为 401 未授权exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);// 设置响应为完成状态结束请求-响应的处理return exchange.getResponse().setComplete();}
}三大过滤器路由过滤器、defaultFilter、GlobalFilter 执行优先级以及顺序 跨域处理 CORS
