Spring Cloud zuul扩展能力设计和心得

news2024/11/17 3:45:19

前言

实际上Spring Cloud已经废弃zuul了，改用gateway，但是webflux的技术并没在实际项目大规模普及，还有很多servlet NIO的应用，所以zuul还是很有必要改造的，实测zuul调优（调节转发的连接池）跟gateway性能上差不多，所以研究了下zuul，发现设计理念很不错。

核心理念

zuul的原理，笔者的上一章已经大致说过，参考Spring Cloud zuul与CloseableHttpClient连接池，TLS证书认证_fenglllle的博客-CSDN博客

说了连接池部分，包括是怎么关闭的，但是zuul的数据怎么传递的呢 

zuul的核心理念实际上是线程变量的传递，threadlocal，所以如果需要子线程或者其他线程池，那么需要对传递的变量进行改造，使用

InheritableThreadLocal

简单翻译 

请求上下文保存请求、响应、状态信息和数据，供ZuulFilters访问和共享。RequestContext在请求的持续时间内存在，并且是ThreadLocal。
可以通过设置contextClass来替换RequestContext的扩展。这里大多数方法都是方便扩展的方法; RequestContext是ConcurrentHashMap的扩展（继承）

 如果自定义线程池，那么需要InheritableThreadLocal，实际上Spring和日志框架都是定制的，threadlocal需要注意自己管理生命周期，线程结束必须clear，否则会造成内存泄漏，有点C++编程的思维。

扩展route

zuul提供全局配置和每个route的配置，全局配置根据自己需要定制，但是全局生效，适合明确的需求，相对而言扩展自定义route更加灵活，自定义route的解析

org.springframework.cloud.netflix.zuul.filters.pre.PreDecorationFilter

在pre的filter中解析，SpringCloud的zuul starter自带

只需要对org.springframework.cloud.netflix.zuul.filters.Route和org.springframework.cloud.netflix.zuul.filters.ZuulProperties.ZuulRoute加入自定义的属性即可，Spring cloud会自定载入属性

这种实现思路来源于8. Router and Filter: Zuul

Spring cloud官方文档，Spring cloud对于Cookies and Sensitive Headers 的设计

zuul:
  routes:
    users:
      path: /myusers/**
      sensitiveHeaders: Cookie,Set-Cookie,Authorization
      url: https://downstream

扩展filter

扩展filter，实际上非常简单，继承zuulfilter即可，但是建议所有的filter放在PreDecorationFilter之后，PreDecorationFilter的order为5，order越小优先级越高

因为PreDecorationFilter有很多前置的条件判断，不过使用if else判断的，而且route的解析也在这里

	public Object run() {
        //上下文设计，threadlocal，后面的结果设计就是这个传递的数据回写的
		RequestContext ctx = RequestContext.getCurrentContext();
		final String requestURI = this.urlPathHelper
				.getPathWithinApplication(ctx.getRequest());
		if (insecurePath(requestURI)) {
			throw new InsecureRequestPathException(requestURI);
		}
        //解析route，刚刚写的自定义属性可以在这里使用，同时SpringCloud的敏感header也是这里配置的
		Route route = this.routeLocator.getMatchingRoute(requestURI);
		if (route != null) {
			String location = route.getLocation(); //目标地址
            //这里的设计理念，根据关键字匹配，类似重定向 转发等等
			if (location != null) {
				ctx.put(REQUEST_URI_KEY, route.getPath());
				ctx.put(PROXY_KEY, route.getId());
				if (!route.isCustomSensitiveHeaders()) {
					this.proxyRequestHelper.addIgnoredHeaders(
							this.properties.getSensitiveHeaders().toArray(new String[0]));
				}
				else {
					this.proxyRequestHelper.addIgnoredHeaders(
							route.getSensitiveHeaders().toArray(new String[0]));
				}

				if (route.getRetryable() != null) {
					ctx.put(RETRYABLE_KEY, route.getRetryable());
				}
                //HTTP转发，HTTPS同理
				if (location.startsWith(HTTP_SCHEME + ":")
						|| location.startsWith(HTTPS_SCHEME + ":")) {
					ctx.setRouteHost(getUrl(location));
					ctx.addOriginResponseHeader(SERVICE_HEADER, location);
				}//forward转发，可以根据这个设计，设计mock能力
				else if (location.startsWith(FORWARD_LOCATION_PREFIX)) {
					ctx.set(FORWARD_TO_KEY,
							StringUtils.cleanPath(
									location.substring(FORWARD_LOCATION_PREFIX.length())
											+ route.getPath()));
					ctx.setRouteHost(null);
					return null;
				}
				else {
					// set serviceId for use in filters.route.RibbonRequest
					ctx.set(SERVICE_ID_KEY, location);
					ctx.setRouteHost(null);
					ctx.addOriginResponseHeader(SERVICE_ID_HEADER, location);
				}
				if (this.properties.isAddProxyHeaders()) {
					addProxyHeaders(ctx, route);
					String xforwardedfor = ctx.getRequest()
							.getHeader(X_FORWARDED_FOR_HEADER);
					String remoteAddr = ctx.getRequest().getRemoteAddr();
					if (xforwardedfor == null) {
						xforwardedfor = remoteAddr;
					}
					else if (!xforwardedfor.contains(remoteAddr)) { // Prevent duplicates
						xforwardedfor += ", " + remoteAddr;
					}
					ctx.addZuulRequestHeader(X_FORWARDED_FOR_HEADER, xforwardedfor);
				}
				if (this.properties.isAddHostHeader()) {
					ctx.addZuulRequestHeader(HttpHeaders.HOST,
							toHostHeader(ctx.getRequest()));
				}
			}
		}
		else {
			log.warn("No route found for uri: " + requestURI);
			String forwardURI = getForwardUri(requestURI);

			ctx.set(FORWARD_TO_KEY, forwardURI);
		}
		return null;
	}

比如可以根据forward转发的设计，设计mock能力，可以在数据库、配置中心等配置返回结果，也可以通过流量的录制，录制返回结果 ，比如bpf录制。

mock response

那么设计一个初步的mock response能力

pre filter设计

修改PreDecorationFilter，要是PreDecorationFilter提供扩展能力就好了，直接扩展，但是PreDecorationFilter写的if else，可以重构代码，把if else变成SPI，实现自定义扩展。

简单写了，其中

ctx.setRouteHost(null);

极为关键，比如HTTP(S)转发的filter，就是根据Host判断的，但是Host就是一个信号量，如果明确信号量的概念，并且抽象，那么代码就更明晰了。

post filter设计

设计mock，需要根据现有的返回数据逻辑，可以看到post filter根据servlet response回写的方式

那么这个response哪里初始化的呢，zuulrunner里面，通过包装类实现的

手写route filter实现mock

package org.springframework.cloud.netflix.zuul.filters.route;

import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.springframework.cloud.netflix.zuul.filters.ProxyRequestHelper;

import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.ROUTE_TYPE;

public class MockHostRoutingFilter extends ZuulFilter {

    private ProxyRequestHelper helper;

    public MockHostRoutingFilter(ProxyRequestHelper helper) {
        this.helper = helper;
    }

    @Override
    public String filterType() {
        return ROUTE_TYPE;
    }

    @Override
    public int filterOrder() {
        return 0;//自定义
    }

    @Override
    public boolean shouldFilter() {
        //可以在PreDecorationFilter埋点设计
        //同时在@Bean，可以通过conditional on properties开启mock的bean
        return RequestContext.getCurrentContext().get("mock.path") != null;
    }

    @Override
    public Object run() throws ZuulException {
        String fullPath = RequestContext.getCurrentContext().get("mock.path") != null;
        // 自定义实现，取http code；body；headers
        return this.helper.setResponse(statusCode(),
                responseBody(),
                headers());
    }
}

总结

SpringCloud实际上是链式设计，通过threadlocal连接数据，基于servlet逻辑，那么整个链路就可以自定义，实际上应该设计比较完善的filter，通过filter的基础上扩展，比如SPI的方式，可以提供各种能力比较方便，不过Spring Cloud zuul通过filter扩展也不错，但是需要threadlocal设置各种数据，尤其是标签数据，在

PreDecorationFilter

中，这个filter尤其重要，如果做成SPI模式就更好了。zuul相对简单，而且贴合servlet，如果使用gateway，那么需要使用webflux技术（netty异步能力），通信原理就是NIO和AIO的区别，数据传递就复杂很多，线程之间传递数据，使用

InheritableThreadLocal

不过，不需要太多的调优，使用角度会简单一些，但是定制化过程难度会增加，取舍而已，如果不定制，那么gateway是比较优的选择，如果追求极致性能，那么这2者都不建议，建议使用nginx+lua的方案，性能会强很多，而且可定制。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1063429.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【算法挨揍日记】day11——852. 山脉数组的峰顶索引、162. 寻找峰值

【算法挨揍日记】day11——852. 山脉数组的峰顶索引、162. 寻找峰值

852. 山脉数组的峰顶索引 852. 山脉数组的峰顶索引 题目描述&#xff1a; 符合下列属性的数组 arr 称为 山脉数组 &#xff1a; arr.length > 3存在 i&#xff08;0 < i < arr.length - 1&#xff09;使得&#xff1a; arr[0] < arr[1] < ... arr[i-1] < …
阅读更多...
数据结构：二叉树（超详解析）

数据结构：二叉树（超详解析）

目录​​​​​​​ 1.树概念及结构 1.1树的概念 1.2树的相关概念 1.3树的表示 1.3.1孩子兄弟表示法&#xff1a; 1.3.2双亲表示法&#xff1a;只存储双亲的下标或指针 两节点不在同一树上&#xff1a; 2.二叉树概念及结构 2.1.概念 2.2.特殊的二叉树&#xff1a; 2…
阅读更多...
掌握交易时机！

掌握交易时机！

“您是否知道您选择购买和出售加密货币的时间会产生很大的影响&#xff1f;当然&#xff0c;大多数交易者都知道高价卖出和低价买入的基本知识。然而&#xff0c;在选择交易加密货币的最佳时机时&#xff0c;还需要考虑许多其他小细节。加密货币市场分析表明&#xff0c;一天中…
阅读更多...
【MyBatis-Plus】快速精通Mybatis-plus框架—核心功能

【MyBatis-Plus】快速精通Mybatis-plus框架—核心功能

刚才的案例中都是以id为条件的简单CRUD&#xff0c;一些复杂条件的SQL语句就要用到一些更高级的功能了。 1.条件构造器 除了新增以外&#xff0c;修改、删除、查询的SQL语句都需要指定where条件。因此BaseMapper中提供的相关方法除了以id作为where条件以外&#xff0c;还支持…
阅读更多...
ES 关于 remote_cluster 的一记小坑

ES 关于 remote_cluster 的一记小坑

最近有小伙伴找到我们说 Kibana 上添加不了 Remote Cluster&#xff0c;填完信息点 Save 直接跳回原界面了。具体页面&#xff0c;就和没添加前一样。 我们和小伙伴虽然隔着网线但还是进行了深入、详细的交流&#xff0c;梳理出来了如下信息&#xff1a; 两个集群&#xff1a;…
阅读更多...
Java常见API---split()

Java常见API---split()

package daysreplace;public class SplitTest {public static void main(String[] args) {String str"武汉市|孝感市|长沙市|北京市|上海市";String[] array str.split("\\|");System.out.println(array[0]);System.out.println(array[1]);System.out.pri…
阅读更多...
[黑马程序员TypeScript笔记]------一篇就够了

[黑马程序员TypeScript笔记]------一篇就够了

目录&#xff1a; TypeScript 介绍 TypeScript 是什么&#xff1f;TypeScript 为什么要为 JS 添加类型支持&#xff1f;TypeScript 相比 JS 的优势TypeScript 初体验 安装编译 TS 的工具包 编译并运行 TS 代码 简化运行 TS 的步骤 TypeScript 常用类型 概述类型注解常用基础…
阅读更多...
​“债务飙升！美国一天内增加2750亿美元，金融震荡的前奏已拉开帷幕！”

​“债务飙升！美国一天内增加2750亿美元，金融震荡的前奏已拉开帷幕！”

2023年10月4日&#xff0c;美国政府向美国债务追加2750亿美元&#xff0c;相当于现在比特币&#xff08;BTC&#xff09;总市值的一半还多。 有人会说:多一点、少一点&#xff0c;没什么区别.....确实&#xff0c;当你看美国债务时&#xff0c;2750亿美元并没有什么意义&#x…
阅读更多...
oringin的x轴(按x轴规定值)绘制不规律的横坐标

oringin的x轴(按x轴规定值)绘制不规律的横坐标

1.双击x轴 2.选择刻度线标签 3.选择刻度
阅读更多...
【数据结构】排序算法（二）—＞冒泡排序、快速排序、归并排序、计数排序

【数据结构】排序算法（二）—＞冒泡排序、快速排序、归并排序、计数排序

&#x1f440;樊梓慕&#xff1a;个人主页 &#x1f3a5;个人专栏&#xff1a;《C语言》《数据结构》《蓝桥杯试题》《LeetCode刷题笔记》《实训项目》 &#x1f31d;每一个不曾起舞的日子&#xff0c;都是对生命的辜负 目录 前言 1.冒泡排序 2.快速排序 2.1Hoare版 2.2占…
阅读更多...
二叉树的初步认识

二叉树的初步认识

二叉树是这么一种树状结构&#xff1a;每个节点最多有两个孩子&#xff0c;左孩子和右孩子 重要的二叉树结构 完全二叉树&#xff08;complete binary tree&#xff09;是一种二叉树结构&#xff0c;除最后一层以外&#xff0c;每一层都必须填满&#xff0c;填充时要遵从先左后…
阅读更多...
YOLOv5报错：TypeError: load() missing 1 required positional argument: ‘Loader‘

YOLOv5报错：TypeError: load() missing 1 required positional argument: ‘Loader‘

报错信息 报错位置 解决办法 将 self.update(yaml.load(fo.read())) 改为&#xff1a; self.update(yaml.safe_load(fo.read()))
阅读更多...
信息学 学习/复习 抽签器（附源码）

信息学 学习/复习 抽签器（附源码）

问你一个问题&#xff0c;你考试前怎么复习呀&#xff1f; 效果图 以下是源代码&#xff0c;可自行修改 [C] #include<bits/stdc.h> #include<windows.h> using namespace std; vector<string>item; int main(void) {item.push_back("Manacher"…
阅读更多...
谁“动”了我的信息？

谁“动”了我的信息？

通信公司“内鬼” 批量提供手机卡 超6万张手机卡用来发涉赌短信 2023年10月2日&#xff0c;据报道2022年12月&#xff0c;湖北省公安厅“雷火”打击整治治安突出问题专项行动指挥部研判发现&#xff0c;有人在湖北随州利用虚拟拨号设备GOIP发出大量赌博短信。随州市公安局研判…
阅读更多...
第一课数组、链表、栈、队列

第一课数组、链表、栈、队列

第一课数组、链表、栈、队列 acwing136 邻值查找---中等题目描述代码展示 lc20.有效的括号--简单题目描述代码展示 lc25.K 个一组翻转链表--困难题目描述代码展示 lc26.删除有序数组中的重复项--简单题目描述代码展示 lc88.合并两个有序数组--简单题目描述代码展示 lc141.环形链…
阅读更多...
Flink--9、双流联结（窗口联结、间隔联结）

Flink--9、双流联结（窗口联结、间隔联结）

星光下的赶路人star的个人主页 我还有改变的可能性&#xff0c;一想起这点&#xff0c;我就心潮澎湃 文章目录 1、基于时间的合流——双流联结&#xff08;Join&#xff09;1.1 窗口联结&#xff08;Window Join&#xff09;1.2 间隔联结&#xff08;Interval Join&#xff09;…
阅读更多...
【数据恢复篇】浅谈FTK Imager数据恢复功能

【数据恢复篇】浅谈FTK Imager数据恢复功能

【数据恢复篇】浅谈FTK Imager数据恢复功能 日常取证工作中&#xff0c;常用FTK Imager制作磁盘镜像、挂载镜像等&#xff0c;但FTK Imager的数据恢复功能也是非常强大的&#xff0c;某些数据的恢复效果不输专业的数据恢复软件&#xff0c;甚至略胜一筹—【蘇小沐】 文章目录 …
阅读更多...
项目设计：YOLOv5目标检测+机构光相机（intel d455和d435i）测距

项目设计：YOLOv5目标检测+机构光相机（intel d455和d435i）测距

1.介绍 1.1 Intel D455 Intel D455 是一款基于结构光&#xff08;Structured Light&#xff09;技术的深度相机。 与ToF相机不同&#xff0c;结构光相机使用另一种方法来获取物体的深度信息。它通过投射可视光谱中的红外结构光图案&#xff0c;然后从被拍摄物体表面反射回来…
阅读更多...
【C++】：类和对象（2）

【C++】：类和对象（2）

朋友们、伙计们&#xff0c;我们又见面了&#xff0c;本期来给大家解读一下有关Linux的基础知识点&#xff0c;如果看完之后对你有一定的启发&#xff0c;那么请留下你的三连&#xff0c;祝大家心想事成&#xff01; C 语 言 专 栏&#xff1a;C语言&#xff1a;从入门到精通 数…
阅读更多...
投资理财：利率下行时代应该怎样存钱？

投资理财：利率下行时代应该怎样存钱？

大家好&#xff0c;我是财富智星&#xff0c;今天跟大家分享一下当下利率下行的时代&#xff0c;钱应该怎样存&#xff0c;存哪里的问题。 一、 银行利率下行 在过去的三十年里&#xff0c;您已经逐渐适应了不断下降的利率&#xff0c;从10%到现在的1.65%。而在未来&#xff0c…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023