网关能做什么#xff1f;

图片原文#xff1a;http://t.csdnimg.cn/SvUJh

核心概念

Router路由路由时构建网关的基本模块它由ID目标URI一系列的断言和过滤器组成如果断言为true则匹配该路由。

Predicate断言断言说简单点就是请求匹配条件。

断言是定义匹配条件如果请求符合条件则该请求匹配断言所属的路由。

Filter

!--网关jar--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-gateway/artifactIdversion${spring-cloud-alibaba-version}/version/dependency!--引入nacos--dependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-starter-alibaba-nacos-discovery/artifactIdversion${spring-cloud-alibaba-version}/version/dependency!--注意我这里没有引入父工程而是springboot父启动依赖也不要引入web依赖而是webflux--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-webflux/artifactId/dependencySpring

Cloud

支持的话需要导入spring-boot-starter-webflux而不是spring-boot-start-web

应用启动类添加注解

cloud:nacos:discovery:server-addr:

127.0.0.1:3333

#注册服务到nacos注意nacos的端口号配置gateway:discovery:locator:enabled:

true

#表明gateway开启服务注册和发现的功能gateway为每一个服务创建了一个router这个router将以服务名开头的请求路径转发到对应的服务。

lower-case-service-id:

true

http://127.0.0.1:8070/alibaba-user-consumer-8090/user/findUserById?id3

自定义路由

cloud:nacos:discovery:server-addr:

127.0.0.1:3333

#注册服务到nacos注意nacos的端口号配置gateway:discovery:locator:enabled:

false

#表明gateway开启服务注册和发现的功能gateway为每一个服务创建了一个router这个router将以服务名开头的请求路径转发到对应的服务。

lower-case-service-id:

true

或lb://alibaba-user-consumer-8090

断言-

http://127.0.0.1:8070/ts/user/findUserById?id3

客户端请求先找到路由路由匹配时经过过滤器层层筛选最终访问到微服务。

在yml中配置相关信息

有时候SpringCloudGateWay提供的过滤器工厂不能满足自己的要求。

yml配置如图

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

import

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

import

org.springframework.http.HttpStatus;

import

org.springframework.web.server.ServerWebExchange;

import

reactor.core.publisher.Mono;/***

Author

tokenexchange.getRequest().getHeaders().getFirst(token);System.out.println(token1token);if

chain.filter(exchange);}System.out.println(错误不放行);exchange.getResponse().setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);return

exchange.getResponse().setComplete();}

数值越大优先级越低

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.stereotype.Component;

import

org.springframework.web.server.ServerWebExchange;

import

reactor.core.publisher.Mono;/***

Author

spring:cloud:gateway:globalcors:

全局的跨域配置add-to-simple-url-handler-mapping:

true

在maxAge设置的时间范围内不去询问统统允许跨域corsConfigurations:[/**]:allowedOrigins:

http://localhost:8090allowedMethods:

GET-

使用SpringMvc自带的跨域检测工具类判断当前请求是否跨域if

(!CorsUtils.isCorsRequest(request))

{return

requestHeaders.getAccessControlRequestMethod();

获取请求方式对象HttpHeaders

获取响应头headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN,requestHeaders.getOrigin());

把请求头中的请求源协议ip端口添加到响应头中相当于yml中的allowedOrigins)headers.addAll(HttpHeaders.ACCESS_CONTROL_ALLOW_HEADERS,requestHeaders.getAccessControlRequestHeaders());if

(requestMethod

{headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_METHODS,requestMethod.name());

允许被响应的方法GET/POST等相当于yml中的allowedMethods)}headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_CREDENTIALS,

true);//

允许在请求中携带cookie相当于yml中的allowCredentialsheaders.add(HttpHeaders.ACCESS_CONTROL_EXPOSE_HEADERS,

*);//

允许在请求中携带的头信息相当于yml中的allowedHeadersheaders.add(HttpHeaders.ACCESS_CONTROL_MAX_AGE,

MAX_AGE);//

本次跨域检测的有效期(单位毫秒相当于yml中的maxAge)if

(request.getMethod()

直接给option请求反回结果response.setStatusCode(HttpStatus.OK);return

Mono.empty();}return

网关可以做很多的事情比如限流当我们的系统被频繁的请求的时候就有可能将系统压垮所以为了解决这个问题需要在每一个微服务中做限流操作但是如果有了网关那么就可以在网关系统做限流因为所有的请求都需要先通过网关系统才能路由到微服务中。

桶设置最大的放置令牌限制当桶满时、新添加的令牌就被丢弃或者拒绝

请求达到后首先要获取令牌桶中的令牌拿着令牌才可以进行其他的业务逻辑处理完业务逻辑之后将令牌直接删除

令牌桶有最低限额当桶中的令牌达到最低限额的时候请求处理完之后将不会删除令牌以此保证足够的限流

网关限流代码实现

限流--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-redis-reactive/artifactIdversion2.1.3.RELEASE/version/dependency

KeyResolver

Mono.just(exchange.getRequest().getRemoteAddress().getHostName());}};}

routes:-

http://127.0.0.1:7780predicates:

断言-

对象redis-rate-limiter.replenishRate:

#令牌桶每秒填充平均速率redis-rate-limiter.burstCapacity:

burstCapacity