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

相关文章

售价599元起! 华为路由器X1/Pro发布 配置与区别一览

《售价599元起!华为路由器X1/Pro发布配置与区别一览》华为路由器X1/Pro发布,有朋友留言问华为路由X1和X1Pro怎么选择,关于这个问题,本期图文将对这二款路由器做了期参数对比,大家看... 华为路由 X1 系列已经正式发布并开启预售,将在 4 月 25 日 10:08 正式开售,两款产品分别为华

kali linux 无法登录root的问题及解决方法

《kalilinux无法登录root的问题及解决方法》:本文主要介绍kalilinux无法登录root的问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,... 目录kali linux 无法登录root1、问题描述1.1、本地登录root1.2、ssh远程登录root2、

SQL server配置管理器找不到如何打开它

《SQLserver配置管理器找不到如何打开它》最近遇到了SQLserver配置管理器打不开的问题,尝试在开始菜单栏搜SQLServerManager无果,于是将自己找到的方法总结分享给大家,对SQ... 目录方法一:桌面图标进入方法二:运行窗口进入方法三:查找文件路径方法四:检查 SQL Server 安

SpringMVC获取请求参数的方法

《SpringMVC获取请求参数的方法》:本文主要介绍SpringMVC获取请求参数的方法,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下... 目录1、通过ServletAPI获取2、通过控制器方法的形参获取请求参数3、@RequestParam4、@

SpringBoot应用中出现的Full GC问题的场景与解决

《SpringBoot应用中出现的FullGC问题的场景与解决》这篇文章主要为大家详细介绍了SpringBoot应用中出现的FullGC问题的场景与解决方法,文中的示例代码讲解详细,感兴趣的小伙伴可... 目录Full GC的原理与触发条件原理触发条件对Spring Boot应用的影响示例代码优化建议结论F

MySQL 中查询 VARCHAR 类型 JSON 数据的问题记录

《MySQL中查询VARCHAR类型JSON数据的问题记录》在数据库设计中,有时我们会将JSON数据存储在VARCHAR或TEXT类型字段中,本文将详细介绍如何在MySQL中有效查询存储为V... 目录一、问题背景二、mysql jsON 函数2.1 常用 JSON 函数三、查询示例3.1 基本查询3.2

Pyserial设置缓冲区大小失败的问题解决

《Pyserial设置缓冲区大小失败的问题解决》本文主要介绍了Pyserial设置缓冲区大小失败的问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录问题描述原因分析解决方案问题描述使用set_buffer_size()设置缓冲区大小后,buf

resultMap如何处理复杂映射问题

《resultMap如何处理复杂映射问题》:本文主要介绍resultMap如何处理复杂映射问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录resultMap复杂映射问题Ⅰ 多对一查询:学生——老师Ⅱ 一对多查询:老师——学生总结resultMap复杂映射问题

利用Python快速搭建Markdown笔记发布系统

《利用Python快速搭建Markdown笔记发布系统》这篇文章主要为大家详细介绍了使用Python生态的成熟工具,在30分钟内搭建一个支持Markdown渲染、分类标签、全文搜索的私有化知识发布系统... 目录引言:为什么要自建知识博客一、技术选型:极简主义开发栈二、系统架构设计三、核心代码实现(分步解析

Python获取C++中返回的char*字段的两种思路

《Python获取C++中返回的char*字段的两种思路》有时候需要获取C++函数中返回来的不定长的char*字符串,本文小编为大家找到了两种解决问题的思路,感兴趣的小伙伴可以跟随小编一起学习一下... 有时候需要获取C++函数中返回来的不定长的char*字符串,目前我找到两种解决问题的思路,具体实现如下: