快捷導(dǎo)航

Gateway網(wǎng)關(guān)源碼解析

更新時(shí)間：2022年07月29日 10:16:12 作者：kaico2018

這篇文章主要介紹了Gateway微服務(wù)網(wǎng)關(guān)，負(fù)載均衡，熔斷和限流，本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

工作原理

客戶(hù)端向 Spring Cloud Gateway 發(fā)出請(qǐng)求。如果網(wǎng)關(guān)處理程序映射確定請(qǐng)求與路由匹配，則將其發(fā)送到網(wǎng)關(guān) Web 處理程序。此處理程序通過(guò)特定于請(qǐng)求的過(guò)濾器鏈運(yùn)行請(qǐng)求。過(guò)濾器用虛線劃分的原因是過(guò)濾器可以在發(fā)送代理請(qǐng)求之前和之后運(yùn)行邏輯。執(zhí)行所有“預(yù)”過(guò)濾器邏輯。然后發(fā)出代理請(qǐng)求。發(fā)出代理請(qǐng)求后，將運(yùn)行“發(fā)布”過(guò)濾器邏輯。

配置類(lèi)分析

jar包中加載的配置類(lèi)，會(huì)注入到IOC容器中。

1、GatewayClassPathWarningAutoConfiguration 檢查是否有正確的配置webflux

檢查是否有 org.springframework.web.servlet.DispatcherServlet類(lèi)，也就是是否引入了springweb的依賴(lài)。

2、GatewayAutoConfiguration 核心配置類(lèi)

配置了很多bean，加載了gateway 需要注入的類(lèi)。

配置了很多謂詞想的的bean

3、GatewayLoadBalancerClientAutoConfiguration 網(wǎng)關(guān)需要使用的負(fù)載均衡

該過(guò)濾器實(shí)現(xiàn)了負(fù)載均衡的功能，通過(guò)責(zé)任鏈的設(shè)計(jì)模式。

4、GatewayRedisAutoConfiguration 網(wǎng)關(guān)整合Redis整合Lua實(shí)現(xiàn)限流

5、GatewayDiscoveryClientAutoConfiguration 把網(wǎng)關(guān)服務(wù)注冊(cè)到注冊(cè)中心中去，服務(wù)注冊(cè)與發(fā)現(xiàn)功能

路由模式源碼分析

網(wǎng)關(guān)的請(qǐng)求入口在 DispatcherHandler類(lèi)里面的 handler 方法。

查找handler方法中，子類(lèi)會(huì)查找路由策略，循環(huán)查找路由策略，第一個(gè)匹配的策略會(huì)返回了。

執(zhí)行的handler

webHandler去執(zhí)行

執(zhí)行的是 filter 的 handler，gateway 默認(rèn)有7個(gè)filter，分別實(shí)現(xiàn)了不同的功能：負(fù)載均衡、請(qǐng)求轉(zhuǎn)發(fā)等功能。各個(gè)filter通過(guò)責(zé)任鏈模式循環(huán)執(zhí)行。

解決前后端的跨域問(wèn)題

微服務(wù)中跨域的問(wèn)題，不屬于前端解決 jsonp ，只能支持get請(qǐng)求。

核心點(diǎn)就是在我們后端。

解決跨域的問(wèn)題

HttpClient轉(zhuǎn)發(fā)
使用過(guò)濾器允許接口可以跨域響應(yīng)頭設(shè)置
Jsonp 不支持我們的post 屬于前端解決
Nginx解決跨域的問(wèn)題保持我們域名和端口一致性
Nginx也是通過(guò)配置文件解決跨域的問(wèn)題
基于微服務(wù)網(wǎng)關(guān)解決跨域問(wèn)題，需要保持域名和端口一致性
使用網(wǎng)關(guān)代碼允許所有的服務(wù)可以跨域的問(wèn)題
使用SpringBoot注解形式@CrossOrigin

gateway解決跨域問(wèn)題：增加過(guò)濾器，給請(qǐng)求頭增加參數(shù)。

@Component
public class CrossOriginFilter implements GlobalFilter {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
        ServerHttpResponse response = exchange.getResponse();
        HttpHeaders headers = response.getHeaders();
        headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN, "*");
        headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_METHODS, "POST, GET, PUT, OPTIONS, DELETE, PATCH");
        headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_CREDENTIALS, "true");
        headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_HEADERS, "*");
        headers.add(HttpHeaders.ACCESS_CONTROL_EXPOSE_HEADERS, "*");
        return chain.filter(exchange);
    }
}

以上就是Gateway網(wǎng)關(guān)源碼解析的詳細(xì)內(nèi)容，更多關(guān)于Gateway網(wǎng)關(guān)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: