基于蓝绿发布的Bg-Gray头部改造中Feign中获取不到头部问题

2024-02-02 09:59

本文主要是介绍基于蓝绿发布的Bg-Gray头部改造中Feign中获取不到头部问题,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

概要:在做蓝绿发布头部改造的时候,大家的策略基本都是修改@FeignClient配置类configuration里的SignatureInterceptor,在SignatureInterceptor里通过RequestContextHolder .getRequestAttributes()获取前端传过来的user_id,从而确定Bg-Gray的值,为什么不行呢
部门产品对接mop基本都是通过Feign进行mop接口调用
在这里插入图片描述
在做蓝绿发布头部改造的时候,大家的策略基本都是修改@FeignClient配置类configuration里的SignatureInterceptor,在SignatureInterceptor里通过RequestContextHolder .getRequestAttributes()获取前端传过来的user_id,从而确定Bg-Gray的值

但是,经过测试可以知道通过RequestContextHolder .getRequestAttributes()并不能获取到前端传输的user_id,获取到的requestAttributes为null值
在这里插入图片描述

具体什么原因呢?通过查阅相关资料可得知

在执行spring的过滤器chain之前会把当前的ServletRequestAttributes保存在当前线程的ThreadLocal里,所以后面要想获取ServletRequestAttributes必须在同一个线程里通过RequestContextHolder.getRequestAttributes()才能获取到

在这里插入图片描述

大家知道,在使用Feign进行接口调用的时候,会使用到Hystrix进行资源隔离,隔离方式包含线程池隔离和信号量Seamphore隔离,而默认是使用线程池隔离的,所以在使用Feign进行接口调用时,会在新的线程里进行Feign接口调用操作,故而无法通过RequestContextHolder.getRequestAttributes()获取前一个线程里设置的attribute,所以原来的实现方式不可行,从上面的解释中可以得知,只要是在同一个线程里就可以获取到线程里设置的attribute,恰好信号量Seamphore隔离就是在同一个线程里,于是就有了第一个解决方案。

通过信号量Seamphore隔离实现user_id的header传递
只需要在配置文件里增加信号量Seamphore隔离的配置,就可以获取到线程里配置的attribute

hystrix.command.default.execution.isolation.strategy=SEMAPHORE

具体为什么呢?

原来增加了信号量Seamphore隔离的配置后,会直接在当前线程里执行mop接口调用的后续流程

在这里插入图片描述

所以在信号量隔离的模式下,接收请求和执行下游依赖在同一个线程内完成,不存在线程上下文切换所带来的性能开销,但是也存在问题,在调用线程上执行下游依赖程序,并发请求受信号量限制Hystrix官方不推荐这种做法。
Thread or Semaphore
The default, and the recommended setting, is to run HystrixCommands using thread isolation (THREAD) and HystrixObservableCommands using semaphore isolation (SEMAPHORE).
Commands executed in threads have an extra layer of protection against latencies beyond what network timeouts can offer.
Generally the only time you should use semaphore isolation for HystrixCommands is when the call is so high volume (hundreds per second, per instance) that the overhead of separate threads is too high; this typically only applies to non-network calls.

那么为什么使用线程池隔离就无法在下游Feign接口调用执行中,获取到线程里配置的attribute呢,大家看下上图的蓝色部分可知。

原来使用线程池隔离,下游Feign接口调用会被调度到Hystrix线程池中新的线程里,所以通过在新的线程中通过RequestContextHolder.getRequestAttributes()获取上一个ThreadLocal里的值肯定无法得到attribute,那么怎么才能在下游的线程里获取到上游线程中配置的attribute呢?于是就有了第二个方案

Hystrix跨线程传递数据
首先我们在上游服务里保存前端传输过来的request信息,在这里,我使用拦截器进行request的处理

在这里插入图片描述

通过HystrixRequestContext.initializeContext()在当前线程中创建HystrixRequestContext,并把他保存在当前线程的ThreadLocal 里。

通过REQUEST.set(request)把request信息保存到上述当前线程创建的HystrixRequestContext的state里。

前面我们知道,使用线程池隔离下游的服务会在新的线程里执行
在这里插入图片描述

其中 1为在进入下游的线程之前获取上游刚才保存的HystrixRequestContext,命名为parentThreadState

     2为下游线程中的HystrixRequestContext,命名为existingState,为后面恢复现场做准备  3为设置下游线程的HystrixRequestContext为parentThreadState ,这样就实现了Hystrix跨线程传递数据  4为处理结束恢复现场

通过这种方式便实现了Hystrix跨线程传递数据,使得即使通过Hystrix的线程隔离也一样可以获得前端传过来的user_id

那如果我既想使用方法1里的RequestContextHolder .getRequestAttributes()获取user_id,又想使用方法2的线程池隔离,有没有什么方法呢?

这就是下一个方法

重定义WrappedCallable实现Hystrix跨线程传递数据
在上图中,如果我在1的地方获取上游线程的RequestAttributes,并把他传到wrapCallable里,是的下游可以获取到上游的RequestAttributes不是一样可以在下游获取上游前端传过来header里的user_id吗?

还真有这个实现,我们编写一个类,让其继承HystrixConcurrencyStrategy ,并重写wrapCallable 方法即可
在这里插入图片描述

我们把上游获取到的RequestAttributes通过1传入新定义的wrapCallable中

在2处即在下游线程里,通过RequestContextHolder.setRequestAttributes把上游传过来的RequestAttributes保存在下游的ThreadLocal,注意:在此处inheritable=true,实际上是保存到了子inheritableRequestAttributesHolder里

在3处继续执行后续下游的mop接口调用服务,如果需要通过RequestContextHolder .getRequestAttributes()获取attribute,那么肯定可以获取到,并且是上游传过来的。这里源码里RequestContextHolder获取attribute是这样的

在这里插入图片描述

1 先从requestAttributesHolder获取

2 获取不到的时候再从inheritableRequestAttributesHolder中获取,即从上面保存的地方获取到attribute

结束:

以前使用Feign的使用,没有过多关注Hystrix隔离机制,于是认为在Feign里可以通过RequestContextHolder .getRequestAttributes()直接获取前端传过来的request信息,但是测试中确啥也获取不到,通过查看相关文档以及源码,才慢慢定位出原因。让我想起在做zuul网关的时候,也遇到过类似的问题,前端传过来的header通过zuul传到下游服务的时候,header信息已经不是原来的header了,所以在下游无法获取前端传来的信息,具体什么原因,有时间可以给大家在讲下。

这篇关于基于蓝绿发布的Bg-Gray头部改造中Feign中获取不到头部问题的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/670349

相关文章

好题——hdu2522(小数问题:求1/n的第一个循环节)

好喜欢这题,第一次做小数问题,一开始真心没思路,然后参考了网上的一些资料。 知识点***********************************无限不循环小数即无理数,不能写作两整数之比*****************************(一开始没想到,小学没学好) 此题1/n肯定是一个有限循环小数,了解这些后就能做此题了。 按照除法的机制,用一个函数表示出来就可以了,代码如下

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

高效+灵活,万博智云全球发布AWS无代理跨云容灾方案!

摘要 近日,万博智云推出了基于AWS的无代理跨云容灾解决方案,并与拉丁美洲,中东,亚洲的合作伙伴面向全球开展了联合发布。这一方案以AWS应用环境为基础,将HyperBDR平台的高效、灵活和成本效益优势与无代理功能相结合,为全球企业带来实现了更便捷、经济的数据保护。 一、全球联合发布 9月2日,万博智云CEO Michael Wong在线上平台发布AWS无代理跨云容灾解决方案的阐述视频,介绍了

购买磨轮平衡机时应该注意什么问题和技巧

在购买磨轮平衡机时,您应该注意以下几个关键点: 平衡精度 平衡精度是衡量平衡机性能的核心指标,直接影响到不平衡量的检测与校准的准确性,从而决定磨轮的振动和噪声水平。高精度的平衡机能显著减少振动和噪声,提高磨削加工的精度。 转速范围 宽广的转速范围意味着平衡机能够处理更多种类的磨轮,适应不同的工作条件和规格要求。 振动监测能力 振动监测能力是评估平衡机性能的重要因素。通过传感器实时监

缓存雪崩问题

缓存雪崩是缓存中大量key失效后当高并发到来时导致大量请求到数据库,瞬间耗尽数据库资源,导致数据库无法使用。 解决方案: 1、使用锁进行控制 2、对同一类型信息的key设置不同的过期时间 3、缓存预热 1. 什么是缓存雪崩 缓存雪崩是指在短时间内,大量缓存数据同时失效,导致所有请求直接涌向数据库,瞬间增加数据库的负载压力,可能导致数据库性能下降甚至崩溃。这种情况往往发生在缓存中大量 k

6.1.数据结构-c/c++堆详解下篇(堆排序,TopK问题)

上篇:6.1.数据结构-c/c++模拟实现堆上篇(向下,上调整算法,建堆,增删数据)-CSDN博客 本章重点 1.使用堆来完成堆排序 2.使用堆解决TopK问题 目录 一.堆排序 1.1 思路 1.2 代码 1.3 简单测试 二.TopK问题 2.1 思路(求最小): 2.2 C语言代码(手写堆) 2.3 C++代码(使用优先级队列 priority_queue)

Vue3项目开发——新闻发布管理系统(六)

文章目录 八、首页设计开发1、页面设计2、登录访问拦截实现3、用户基本信息显示①封装用户基本信息获取接口②用户基本信息存储③用户基本信息调用④用户基本信息动态渲染 4、退出功能实现①注册点击事件②添加退出功能③数据清理 5、代码下载 八、首页设计开发 登录成功后,系统就进入了首页。接下来,也就进行首页的开发了。 1、页面设计 系统页面主要分为三部分,左侧为系统的菜单栏,右侧

【VUE】跨域问题的概念,以及解决方法。

目录 1.跨域概念 2.解决方法 2.1 配置网络请求代理 2.2 使用@CrossOrigin 注解 2.3 通过配置文件实现跨域 2.4 添加 CorsWebFilter 来解决跨域问题 1.跨域概念 跨域问题是由于浏览器实施了同源策略,该策略要求请求的域名、协议和端口必须与提供资源的服务相同。如果不相同,则需要服务器显式地允许这种跨域请求。一般在springbo

题目1254:N皇后问题

题目1254:N皇后问题 时间限制:1 秒 内存限制:128 兆 特殊判题:否 题目描述: N皇后问题,即在N*N的方格棋盘内放置了N个皇后,使得它们不相互攻击(即任意2个皇后不允许处在同一排,同一列,也不允许处在同一斜线上。因为皇后可以直走,横走和斜走如下图)。 你的任务是,对于给定的N,求出有多少种合法的放置方法。输出N皇后问题所有不同的摆放情况个数。 输入

vscode中文乱码问题,注释,终端,调试乱码一劳永逸版

忘记咋回事突然出现了乱码问题,很多方法都试了,注释乱码解决了,终端又乱码,调试窗口也乱码,最后经过本人不懈努力,终于全部解决了,现在分享给大家我的方法。 乱码的原因是各个地方用的编码格式不统一,所以把他们设成统一的utf8. 1.电脑的编码格式 开始-设置-时间和语言-语言和区域 管理语言设置-更改系统区域设置-勾选Bata版:使用utf8-确定-然后按指示重启 2.vscode