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

相关文章

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》:本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因(调度随机、变量修改、非原子操作、内存可见性、指令重排序)及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操

Redis出现中文乱码的问题及解决

《Redis出现中文乱码的问题及解决》:本文主要介绍Redis出现中文乱码的问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 问题的产生2China编程. 问题的解决redihttp://www.chinasem.cns数据进制问题的解决中文乱码问题解决总结

MySQL 获取字符串长度及注意事项

《MySQL获取字符串长度及注意事项》本文通过实例代码给大家介绍MySQL获取字符串长度及注意事项,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录mysql 获取字符串长度详解 核心长度函数对比⚠️ 六大关键注意事项1. 字符编码决定字节长度2

全面解析MySQL索引长度限制问题与解决方案

《全面解析MySQL索引长度限制问题与解决方案》MySQL对索引长度设限是为了保持高效的数据检索性能,这个限制不是MySQL的缺陷,而是数据库设计中的权衡结果,下面我们就来看看如何解决这一问题吧... 目录引言:为什么会有索引键长度问题?一、问题根源深度解析mysql索引长度限制原理实际场景示例二、五大解决

Springboot如何正确使用AOP问题

《Springboot如何正确使用AOP问题》:本文主要介绍Springboot如何正确使用AOP问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录​一、AOP概念二、切点表达式​execution表达式案例三、AOP通知四、springboot中使用AOP导出

Python中Tensorflow无法调用GPU问题的解决方法

《Python中Tensorflow无法调用GPU问题的解决方法》文章详解如何解决TensorFlow在Windows无法识别GPU的问题,需降级至2.10版本,安装匹配CUDA11.2和cuDNN... 当用以下代码查看GPU数量时,gpuspython返回的是一个空列表,说明tensorflow没有找到

解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘问题

《解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘问题》:本文主要介绍解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4... 目录未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘打开pom.XM

IDEA Maven提示:未解析的依赖项的问题及解决

《IDEAMaven提示:未解析的依赖项的问题及解决》:本文主要介绍IDEAMaven提示:未解析的依赖项的问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝... 目录IDEA Maven提示:未解析的依编程赖项例如总结IDEA Maven提示:未解析的依赖项例如

python3如何找到字典的下标index、获取list中指定元素的位置索引

《python3如何找到字典的下标index、获取list中指定元素的位置索引》:本文主要介绍python3如何找到字典的下标index、获取list中指定元素的位置索引问题,具有很好的参考价值,... 目录enumerate()找到字典的下标 index获取list中指定元素的位置索引总结enumerat