基于蓝绿发布的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

相关文章

C#实现获取电脑中的端口号和硬件信息

《C#实现获取电脑中的端口号和硬件信息》这篇文章主要为大家详细介绍了C#实现获取电脑中的端口号和硬件信息的相关方法,文中的示例代码讲解详细,有需要的小伙伴可以参考一下... 我们经常在使用一个串口软件的时候,发现软件中的端口号并不是普通的COM1,而是带有硬件信息的。那么如果我们使用C#编写软件时候,如

numpy求解线性代数相关问题

《numpy求解线性代数相关问题》本文主要介绍了numpy求解线性代数相关问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 在numpy中有numpy.array类型和numpy.mat类型,前者是数组类型,后者是矩阵类型。数组

解决systemctl reload nginx重启Nginx服务报错:Job for nginx.service invalid问题

《解决systemctlreloadnginx重启Nginx服务报错:Jobfornginx.serviceinvalid问题》文章描述了通过`systemctlstatusnginx.se... 目录systemctl reload nginx重启Nginx服务报错:Job for nginx.javas

C#实现WinForm控件焦点的获取与失去

《C#实现WinForm控件焦点的获取与失去》在一个数据输入表单中,当用户从一个文本框切换到另一个文本框时,需要准确地判断焦点的转移,以便进行数据验证、提示信息显示等操作,本文将探讨Winform控件... 目录前言获取焦点改变TabIndex属性值调用Focus方法失去焦点总结最后前言在一个数据输入表单

Redis缓存问题与缓存更新机制详解

《Redis缓存问题与缓存更新机制详解》本文主要介绍了缓存问题及其解决方案,包括缓存穿透、缓存击穿、缓存雪崩等问题的成因以及相应的预防和解决方法,同时,还详细探讨了缓存更新机制,包括不同情况下的缓存更... 目录一、缓存问题1.1 缓存穿透1.1.1 问题来源1.1.2 解决方案1.2 缓存击穿1.2.1

五大特性引领创新! 深度操作系统 deepin 25 Preview预览版发布

《五大特性引领创新!深度操作系统deepin25Preview预览版发布》今日,深度操作系统正式推出deepin25Preview版本,该版本集成了五大核心特性:磐石系统、全新DDE、Tr... 深度操作系统今日发布了 deepin 25 Preview,新版本囊括五大特性:磐石系统、全新 DDE、Tree

通过C#获取PDF中指定文本或所有文本的字体信息

《通过C#获取PDF中指定文本或所有文本的字体信息》在设计和出版行业中,字体的选择和使用对最终作品的质量有着重要影响,然而,有时我们可能会遇到包含未知字体的PDF文件,这使得我们无法准确地复制或修改文... 目录引言C# 获取PDF中指定文本的字体信息C# 获取PDF文档中用到的所有字体信息引言在设计和出

python中os.stat().st_size、os.path.getsize()获取文件大小

《python中os.stat().st_size、os.path.getsize()获取文件大小》本文介绍了使用os.stat()和os.path.getsize()函数获取文件大小,文中通过示例代... 目录一、os.stat().st_size二、os.path.getsize()三、函数封装一、os

vue解决子组件样式覆盖问题scoped deep

《vue解决子组件样式覆盖问题scopeddeep》文章主要介绍了在Vue项目中处理全局样式和局部样式的方法,包括使用scoped属性和深度选择器(/deep/)来覆盖子组件的样式,作者建议所有组件... 目录前言scoped分析deep分析使用总结所有组件必须加scoped父组件覆盖子组件使用deep前言

解决Cron定时任务中Pytest脚本无法发送邮件的问题

《解决Cron定时任务中Pytest脚本无法发送邮件的问题》文章探讨解决在Cron定时任务中运行Pytest脚本时邮件发送失败的问题,先优化环境变量,再检查Pytest邮件配置,接着配置文件确保SMT... 目录引言1. 环境变量优化:确保Cron任务可以正确执行解决方案:1.1. 创建一个脚本1.2. 修