OpenFeign 服务调用过程中实现 header 数据透传 | Java Debug笔记

简介: OpenFeign 服务调用过程中实现 header 数据透传 | Java Debug笔记

一、问题描述


在通过 OpenFeign 进行服务调用的过程中,我们需要将用户的 user-tokenlang 等信息放入请求 header 中。在分布式系统中,往往一个业务接口内部会发生多次 RPC 调用。


在这个过程中,我们需要继续将用户请求头中的数据保持传递,方便底层服务获取用户登陆状态, 本地化参数 等数据。


针对这样的场景,我们就需要在 OpenFeign 调用过程中对当前请求中的 header 数据进行 RPC 调用过程中进行透传。


二、解决方案


1、创建自定义 feign.RequestInterceptor 拦截器 RequestInterceptor,将当前 HttpServletRequest 中的请求头信息传递给 Feign 请求所使用的 RequestTemplate 对象。代码如下:


注意:我们在 Spring MVC 项目中任意代码位置获取 HttpServletRequest 对象可以借助  RequestContextHolder 来获取, 具体的调用方法见下面的代码块。


public class FeignRequestInterceptor implements RequestInterceptor {
    @Override
    public void apply(RequestTemplate template) {
        Map<String, String> headers = getHeaders();
        headers.forEach(template::header);
    }
    /**
     * 获取 request 中的所有的 header 值
     *
     * @return
     */
    private Map<String, String> getHeaders() {
        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
        Map<String, String> map = new LinkedHashMap<>();
        Enumeration<String> headerNames = request.getHeaderNames();
        while (headerNames.hasMoreElements()) {
            String key = headerNames.nextElement();
            String value = request.getHeader(key);
            map.put(key, value);
        }
        return map;
    }
}


2、注册拦截器到 Spring 容器中(需要注意保证配置类 FeignSupportHeaderConfig 能够被在Spring 容器启动的过程中被扫描到)。代码如下:


@Configuration
public class FeignSupportHeaderConfig {
    @Bean
    public RequestInterceptor getRequestInterceptor() {
        return new FeignRequestInterceptor();
    }
}


3、如果有使用 hystrix 需要设置为 SEMAPHORE 模式。配置如下:


一般 spring-cloud 2.x 以后建议使用 org.springframework.cloud:spring-cloud-starter-circuitbreaker-resilience4j 它是 Spring 官方长期支持/维护的组件


# To set thread isolation to SEMAPHORE
hystrix:
  command:
    default:
      execution:
        isolation:
          strategy: SEMAPHORE


三、问题总结


我们在解决请求头数据,透传的过程中首先需要先对中间件使用流程和原理有一定的了解,然后再针对具体的问题处理。在目前我们在项目中使用 hystrix 逐渐变少了,更多的是使用 Spring Retryresilience4j 作为 circuitbreaker


如果我们需要获取客户端的语言,本地化(国际化 i18n)参数,我们可以借助 Spring 提供的 LocaleContextHolder API 进行获取,比如: 1、获取语言:LocaleContextHolder.getLocale().getLanguage()2、获取时区:LocaleContextHolder.getLocale().getTimeZone() 等等。


参考文档



相关文章
|
17天前
|
前端开发 JavaScript Java
java常用数据判空、比较和类型转换
本文介绍了Java开发中常见的数据处理技巧,包括数据判空、数据比较和类型转换。详细讲解了字符串、Integer、对象、List、Map、Set及数组的判空方法,推荐使用工具类如StringUtils、Objects等。同时,讨论了基本数据类型与引用数据类型的比较方法,以及自动类型转换和强制类型转换的规则。最后,提供了数值类型与字符串互相转换的具体示例。
|
19天前
|
安全 Java 编译器
Kotlin教程笔记(27) -Kotlin 与 Java 共存(二)
Kotlin教程笔记(27) -Kotlin 与 Java 共存(二)
|
19天前
|
Java 开发工具 Android开发
Kotlin教程笔记(26) -Kotlin 与 Java 共存(一)
Kotlin教程笔记(26) -Kotlin 与 Java 共存(一)
|
24天前
|
JSON Java 程序员
Java|如何用一个统一结构接收成员名称不固定的数据
本文介绍了一种 Java 中如何用一个统一结构接收成员名称不固定的数据的方法。
25 3
|
26天前
|
Java 编译器 Android开发
Kotlin教程笔记(28) -Kotlin 与 Java 混编
Kotlin教程笔记(28) -Kotlin 与 Java 混编
30 2
|
1月前
|
Java 程序员 容器
Java中的变量和常量:数据的‘小盒子’和‘铁盒子’有啥不一样?
在Java中,变量是一个可以随时改变的数据容器,类似于一个可以反复打开的小盒子。定义变量时需指定数据类型和名称。例如:`int age = 25;` 表示定义一个整数类型的变量 `age`,初始值为25。 常量则是不可改变的数据容器,类似于一个锁死的铁盒子,定义时使用 `final` 关键字。例如:`final int MAX_SPEED = 120;` 表示定义一个名为 `MAX_SPEED` 的常量,值为120,且不能修改。 变量和常量的主要区别在于变量的数据可以随时修改,而常量的数据一旦确定就不能改变。常量主要用于防止意外修改、提高代码可读性和便于维护。
|
1月前
|
存储 缓存 安全
在 Java 编程中,创建临时文件用于存储临时数据或进行临时操作非常常见
在 Java 编程中,创建临时文件用于存储临时数据或进行临时操作非常常见。本文介绍了使用 `File.createTempFile` 方法和自定义创建临时文件的两种方式,详细探讨了它们的使用场景和注意事项,包括数据缓存、文件上传下载和日志记录等。强调了清理临时文件、确保文件名唯一性和合理设置文件权限的重要性。
72 2
|
1月前
|
Java
Java 8 引入的 Streams 功能强大,提供了一种简洁高效的处理数据集合的方式
Java 8 引入的 Streams 功能强大,提供了一种简洁高效的处理数据集合的方式。本文介绍了 Streams 的基本概念和使用方法,包括创建 Streams、中间操作和终端操作,并通过多个案例详细解析了过滤、映射、归并、排序、分组和并行处理等操作,帮助读者更好地理解和掌握这一重要特性。
31 2
|
19天前
|
Java 数据库连接 编译器
Kotlin教程笔记(29) -Kotlin 兼容 Java 遇到的最大的“坑”
Kotlin教程笔记(29) -Kotlin 兼容 Java 遇到的最大的“坑”
36 0
|
1月前
|
存储 分布式计算 Java
存算分离与计算向数据移动:深度解析与Java实现
【11月更文挑战第10天】随着大数据时代的到来,数据量的激增给传统的数据处理架构带来了巨大的挑战。传统的“存算一体”架构,即计算资源与存储资源紧密耦合,在处理海量数据时逐渐显露出其局限性。为了应对这些挑战,存算分离(Disaggregated Storage and Compute Architecture)和计算向数据移动(Compute Moves to Data)两种架构应运而生,成为大数据处理领域的热门技术。
62 2