。

那么作为客户端要如何去调用这么多的微服务呢?如果没有网关的存在#xff0c;我们只能在客户端记录每个微服务的地址#xff0c;然后分别去用。

大家都都知道在微服务架构中一个系统会被拆分为很多个微服务。

那么作为客户端要如何去调用这么多的微服务呢?如果没有网关的存在我们只能在客户端记录每个微服务的地址然后分别去用。

每个业务都会需要鉴权、限流、权限校验、跨域等逻辑如果每个业务都各自为战。

自己造轮子实现一遍会很蛋疼完全可以抽出来放到一个统一的地方去做。

如果业务量比较简单的话这种方式前期不会有什么问题但随着业务越来越复杂比如淘宝、亚马逊打开一个页面可能会涉及到数百个微服务协同工作如果每一个微辰务都分配一个域名的话一方面客户端代码会很难维护涉及到数百个域名另一方面是连接数的瓶颈想象一下你打开一个APP通过抓包发现涉及到了数百个远程调用这在移动端下会显得非常低效。

后期如果需要对微服务进行重构的话也会变的非常麻烦需要客户端配合你一起进行改造比如商品服务随着业务变的越来越复杂后期需要进行拆分成多个微服务这个时候对外提供的服务也需要拆分成多个同时需要客户端配合你进行改造非常蛋疼。

所谓的API网关就是指系统的统一入口它封装了应用程序的内部结构为客户说提供统一服务一些与业务本身功能天关的公共逻辑可以在这里实现。

诸如认证、鉴权、监控、路由转发等等,添加上API网关之后系统的架构图变成了如下所示:

Cloud

Clou官方推出的第二代网关框架定位于取代NeificZul。

相比Zul来说Spring

Reactor实现的响应式的API网关。

它不能在传统的servlet容器中工作也不能构建成war包。

Sping

Gateway旨在为微服务架构提供一种简单且有效的API路由的管理方式并基于Fiter的方式提供网关的基本功能例如说安全认证、监控、限流等等。

官网文档:

https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#gateway-request-predicates-factories

Spring

2.0进行构建;动态路由:能够匹配任何请求属性;支持路径重写;集成

Spring

;可以对路由指定易于编写的Predicate(断言和Filter

2、核心概念

路由是网关中最基础的部分路由信息包括一个ID、一个目的URI、一组断言工厂、一组Filter组成。

如果断言为真则说明请求的URL和配置的路由匹配。

断言(predicates)

Gateway中的断言函数类型是Sping5.0框架中的SeverieExctange。

断言函数允许开发者去定义匹酷t

SpringCloud

Gateway的工作原理跟Zuul的差不多最大的区别就是Gateway的Filter只有pre和post

客户端向Spring

Gateway发出请求如果请求与网关程序定义的路由匹配则该请求就会被发送到网关Web处理程序此时处理程序运行特定的请求过滤器链。

过滤器之间用虚线分开的原因是过滤器可能会在发送代理请求的前后执行逻辑。

所有pre过滤器逻辑先执行然后执行代理请求;代理请求完成后执行post过滤器逻辑。

二、Spring

注意:会和spring-webmvc的依赖冲突需要排除spring-webmvc

springcloud

开发--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-gateway/artifactId/dependency/dependencies设置配置文件

server:port:

gateway的配置cloud:gateway:routes:-

id:

http://localhost:8088/order-serve/order/add

路由到↓#

http://localhost:8020/order-serve/order/addfilters:-

StripPrefix1

http://localhost:8020/order/add#-

id:

stock_route访问http://localhost:8088/order-serve/order/add

2、集成Nacos

--dependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-starter-alibaba-nacos-discovery/artifactId/dependencyserver:port:

8088

gateway的配置cloud:gateway:routes:-

id:

http://localhost:8088/order-serve/order/add

路由到↓#

http://localhost:8020/order-serve/order/addfilters:-

StripPrefix1

http://localhost:8020/order/add#-

id:

配置Nacosnacos:discovery:server-addr:

nacospassword:

http://localhost:8088/order-service/order/add

设置约定集成nacos

gateway的配置gateway:discovery:locator:enabled:

true

#是否启动自动识别nacos服务#配置Nacosnacos:discovery:server-addr:

nacospassword:

访问服务名对应的地址http://localhost:8088/order-service/order/add

重新启动项目

访问http://localhost:8088/order/add

调整时间

http://localhost:8088/order/add

3、路由断言工厂Route

https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#gateway-request-predicates-factories

使用断言对请求进行匹配

Gateway包括许多内置的断言工厂,所有这些断言都与HTTP请求的不同属性匹配。

具体如下:

AfterRoutePredicateFactory:接收一个日期参数,

BeforeRoutePredicateFactory:接收-

BetweenRoutePredicateFactory:接收两个日期参数,判断请求日期是否在指定时间段内

After2023-10-19T09:07:00.66008:00[Asia/Shanghai]基于远程地址的断言工厂

RemoteAddrRoutePredicateFactory:接收一个IP地址段,判断请求主机地址是否在地址段中

RemoteAddr192.168.1.1/24基于Cookie的断言工厂

CookieRoutePredicateFactory:接收两个参数,

cookie

名字和一个正则表达式。

判断请求cookie是否具有给定名称且值与正则表达式匹配。

-Cookiechocolate,

HeaderRoutePredicateFactory:接收两个参数,标题名称和正则表达式。

判断请求Header是否具有给定名称且值与正则表达式匹配。

HeaderX-Request-Id,

HostRoutePredicateFactory:接收一个参数,

-Host**.testhost.org基于Method请求方法的断言工厂

MethodRoutePredicateFactory:接收一个参数

重新启动测试

Queryname,xushu|zhuge设置name的参数只能是xushu或者zhuge否则断言失败

发送请求报错

WeightRoutePredicateFactory:接收-个[组名

routes:-id:

自定义路由断言工厂需要继承AbstractRoutePredicateFactory类,重写apply方法的逻辑。

getRequest()倒ServerHttpRequest对象从而可以获取到请求的参数、请求方式、请求头等信息。

2、类必须加上RoutePredicateFactory作为结尾

3、必须继承AbstractRoutePredicateFactory

true

注意:命名需要以RoutePredicateFactory结尾

Component

CheckAuthRoutePredicateFactoryextends

AbstractRoutePredicateFactoryCheckAuthRoutePredicateFactory.Config

{public

CheckAuthRoutePredicateFactory()

{super(CheckAuthRoutePredicateFactory.Config.class);}Overridepublic

ListString

Arrays.asList(name);}Overridepublic

apply(CheckAuthRoutePredicateFactory.Config

config)

{if(config.getName().equals(xushu)){return

true;}return

访问http://localhost:8088/order/add

查询启动

http://localhost:8088/order/add

GatewayFilter

https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#gatewayilter-factories

5.1、添加请求头参数

AddRequestHeaderX-Request-color,redRequestMapping(/header)public

String

header(RequestHeader(X-Request-color)

String

http://localhost:8088/order/header

5.2、添加请求参数

AddRequestParametercolor,blueRequestMapping(/parameter)public

String

color;}http://localhost:8088/order/parameter

/mall-order-

#添加前缀对应微服务需要配置context-path重新启动两个项目

访问http://localhost:8088/order/add

现在访问http://localhost:8020/mall-order/order/add

然而访问8082必须携带前缀

http://localhost:8020/mall-order/order/add

5.4、配置重定向

https://www.baidu.com访问http://localhost:8088/order/add

5.5、自定义状态码

404访问http://localhost:8088/order/add

继承AbstractNameValueGatewayFilterFactory且我们的自定义名称必须要以GatewayFilterFactory结尾并交给spring管理。

创建CheckAuthGatewayFilterFactory

/****/

CheckAuthGatewayFilterFactoryextends

AbstractGatewayFilterFactoryCheckAuthGatewayFilterFactory.Config

{public

CheckAuthGatewayFilterFactory()

{super(Config.class);}Overridepublic

ListString

Arrays.asList(value);}Overridepublic

GatewayFilter

nameexchange.getRequest().getQueryParams().getFirst(name);if(StringUtils.isNotBlank(name)){if(config.getValue().equals(name)){return

{//

返回404exchange.getResponse().setStatusCode(HttpStatus.NOT_FOUND);return

exchange.getResponse().setComplete();}}//

正常请求return

chain.filter(exchange);}};}public

static

GlobalFilter接口和GatewayFilter有一样的接口定义

Component

LoggerFactory.getLogger(this.getClass());Overridepublic

MonoVoid

{log.info(exchange.getRequest().getPath().value());return

重新启动http://localhost:8088/order/add?namexushu

8、Reactor

-Dreactor.netty.http.server.accessLogEnabledtrue它必须是Java系统属性,而不是Spring

您可以将日志记录系统配置为具有单独的访问日志文件。

以下示例创建一个Logback配置:

appender

classch.qos.logback.core.FileAppenderfileaccess_log.log/fileencoderpattern%msg%n/pattern/encoder

/appenderappender

classch.qos.logback.classic.AsyncAppenderappender-ref

refaccessLog

namereactor.netty.http.server.AccessLog

levelINFO

https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#cors-configuration

globalcors:cors-configurations:[/**]:

GET-

charsetUTF-8titleTitle/titlescript

srchttp://apps.bdimg.com/libs/jquery/1.9.1/jquery.min.js/script

/head

border1theadtrthid/ththusername/ththage/th/tr/theadtbody

iduserlist/tbody/table/divinput

typebutton

{$.get(http://localhost:8088/order/add,function(data){alert(data)});}/script

/body

CorsConfiguration();config.addAllowedMethod(*);

//允许运行methodconfig.addAllowedOrigin(*);

//允许的来源config.addAllowedHeader(*);

允许访问的资源UrlBasedCorsConfigurationSource

source

UrlBasedCorsConfigurationSource(new

PathPatternParser());source.registerCorsConfiguration(/**,config);return

new