快捷導(dǎo)航

詳解Spring Cloud Zuul網(wǎng)關(guān)修改為短連接方法

更新時(shí)間：2022年04月17日 11:15:30 作者：王老獅

本文主要介紹了詳解Spring Cloud Zuul網(wǎng)關(guān)修改為短連接方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

一、問(wèn)題分析

之前在用zuul網(wǎng)關(guān)的時(shí)候，請(qǐng)求幾次然后連接就斷開(kāi)了。原因是因?yàn)閔ttp1.1之后，默認(rèn)走的都是connection=keep-alive 長(zhǎng)連接。但沒(méi)有心跳維持，顧1分鐘斷開(kāi)一次。但RestFul一般都是走短連接就行了。因此想著只要修改頭部connection屬性就行了.

就是在過(guò)濾器中修改Zuul的RequestContext ctx對(duì)象

        //設(shè)置請(qǐng)求為短連接
        ctx.addZuulRequestHeader("connection", "close");

再次請(qǐng)求之后發(fā)現(xiàn)

?納尼，怎么還是長(zhǎng)連接。那么說(shuō)明可能是我的設(shè)置沒(méi)有生效或者被覆蓋掉了。遇到問(wèn)題，除了度娘，跟著源碼走一遭也是最好的方式?；舜蟀胩鞎r(shí)間，終于讓我找到原因了。

原因是代理類(lèi)ProxyRequestHelper里面有段邏輯。

public boolean isIncludedHeader(String headerName) {
		String name = headerName.toLowerCase();
		RequestContext ctx = RequestContext.getCurrentContext();
		if (ctx.containsKey(IGNORED_HEADERS)) {
			Object object = ctx.get(IGNORED_HEADERS);
			if (object instanceof Collection && ((Collection<?>) object).contains(name)) {
				return false;
			}
		}
		switch (name) {
		case "host":
			if(addHostHeader) {
				return true;
			}
		case "connection":
		case "content-length":
		case "server":
		case "transfer-encoding":
		case "x-application-context":
			return false;
		default:
			return true;
		}
	}

如果頭部存在"connection": "content-length": "server": "transfer-encoding": "x-application-context"這些頭的話都被跳過(guò)。不會(huì)被設(shè)置成功。應(yīng)該是zuul自己的一個(gè)機(jī)制把。

二、解決方式

那么問(wèn)題找到了，該怎么修改呢？那么只能自定義路由了。繼承并重寫(xiě)這個(gè)類(lèi)。

1、實(shí)現(xiàn)自定義路由配置CustomZuulConfig

@Component
public class CustomZuulConfig {

    @Autowired
    ZuulProperties zuulProperties;

    @Value("${servletPath}")
    private String servletPath;

    @Bean
    public CustomRouteLocator routeLocator() {
        CustomRouteLocator routeLocator = new CustomRouteLocator(servletPath, this.zuulProperties);
        return routeLocator;
    }

}

2、實(shí)現(xiàn)自定義請(qǐng)求代理工具類(lèi) 重寫(xiě)isIncludedHeader方法。

public class CustomRequestHelper extends ProxyRequestHelper {
    @Override
    public boolean isIncludedHeader(String headerName) {
        String name = headerName.toLowerCase();
        RequestContext ctx = RequestContext.getCurrentContext();
        if (ctx.containsKey(IGNORED_HEADERS)) {
            Object object = ctx.get(IGNORED_HEADERS);
            if (object instanceof Collection && ((Collection<?>)object).contains(name)) {
                return false;
            }
        }
        switch (name) {
            case "content-length":
            case "host":
            case "server":
            case "transfer-encoding":
            case "x-application-context":
                return false;
            default:
                return true;
        }
    }
}

3、重寫(xiě)實(shí)現(xiàn)代理配置類(lèi)

@Configuration
@EnableZuulProxy
public class CustomZuulProxyConfig extends ZuulProxyAutoConfiguration {

    @Bean
    @Override
    public SimpleHostRoutingFilter simpleHostRoutingFilter(ProxyRequestHelper helper, ZuulProperties zuulProperties,
            ApacheHttpClientConnectionManagerFactory connectionManagerFactory,
            ApacheHttpClientFactory httpClientFactory) {
        CustomRequestHelper customRequestHelper = new CustomRequestHelper();
        return new SimpleHostRoutingFilter(customRequestHelper, zuulProperties, connectionManagerFactory,
                httpClientFactory);
    }

}

然后重新啟動(dòng)，查看請(qǐng)求頭。

?修改成功。所以說(shuō)，學(xué)會(huì)通過(guò)看源碼查問(wèn)題，還是很重要的哈~

到此這篇關(guān)于詳解Spring Cloud Zuul網(wǎng)關(guān)修改為短連接方法的文章就介紹到這了,更多相關(guān)Spring Cloud Zuul短連接內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: