SpringMVC在多线程下请求头获取失败问题的解决方案

public static HttpServletRequest getRequest() {
    HttpServletRequest httpServletRequest = null;
    try {
        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
        if (requestAttributes instanceof ServletRequestAttributes) {
            ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) requestAttributes;
            httpServletRequest = servletRequestAttributes.getRequest();
        }
    } catch (Exception e) {
        // 记录异常，但不向外抛出，以避免可能的业务逻辑中断
        log.error("获取HttpServletRequest时发生异常：", e);
    }
    // 返回获取到的请求对象，如果失败则返回null
    return httpServletRequest;
}

@RestController
@RequestMapping("/test")
@Slf4j
public class TestController {
    @GetMapping("/missing-request-header")
    public String getMissingRequestHeader() {
        // 主线程获取请求头信息
        String mainThreadLanguages = ServletUtils.getLanguagesExistProblem();
        log.info("主线程获取请求头信息：{}", mainThreadLanguages);
        new Thread(() -> {
            // 子线程获取请求头信息
            String subThreadLanguages = ServletUtils.getLanguagesExistProblem();
            log.info("子线程获取请求头信息：{}", subThreadLanguages);
        }).start();
        return "success";
    }
}

@Slf4j
public class ServletUtils {

    private final static String X_CLIENT_LANG = "X-CLIENT-LANG";

    public static String  getLanguagesExistProblem() {
        HttpServletRequest request = getRequest();
        Assert.notNull(request);
        String lang =  request.getHeader(X_CLIENT_LANG);
        if (StrUtil.isNotBlank(lang)) {
            return lang;
        }
        return "zh-cn";
    }
}

public static void setRequestAttributes(@Nullable RequestAttributes attributes, boolean inheritable) {
   if (attributes == null) {
      resetRequestAttributes();
   }
   else {
      if (inheritable) {
         inheritableRequestAttributesHolder.set(attributes);
         requestAttributesHolder.remove();
      }
      else {
         requestAttributesHolder.set(attributes);
         inheritableRequestAttributesHolder.remove();
      }
   }
}

@GetMapping("/get-request-header-in-thread")
    public String getRequestHeaderInThread() {
        // 主线程获取请求头信息
        String mainThreadLanguages = ServletUtils.getLanguages();
        log.info("主线程获取请求头信息：{}", mainThreadLanguages);
        new Thread(() -> {
            try {
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            // 子线程获取请求头信息
            String subThreadLanguages = ServletUtils.getLanguages();
            log.info("子线程获取请求头信息：{}", subThreadLanguages);
        }).start();
        return "success";
    }

@GetMapping("/get-request-header-in-thread")
public String getRequestHeaderInThread() {
    // 主线程获取请求头信息
    String mainThreadLanguages = ServletUtils.getLanguages();
    CountDownLatch latch = new CountDownLatch(1);
    log.info("主线程获取请求头信息：{}", mainThreadLanguages);
    new Thread(() -> {
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        // 子线程获取请求头信息
        String subThreadLanguages = ServletUtils.getLanguages();
        log.info("子线程获取请求头信息：{}", subThreadLanguages);
        latch.countDown();
    }).start();
    // 等待计数器变为零
    try {
        latch.await();
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
    log.info("确保父子线程全部执行完毕");
    return "success";
}

@GetMapping("/get-request-header-in-async-thread/{isJoin}")
    public String getRequestHeaderInThread() {
        // 主线程获取请求头信息
        String mainThreadLanguages = ServletUtils.getLanguages();
        log.info("主线程获取请求头信息：{}", mainThreadLanguages);
        // 获取当前servletRequestAttributes对象
        ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        new Thread(() -> {
        // 将servletRequestAttributes设定到子线程中
        RequestContextHolder.setRequestAttributes(servletRequestAttributes);
            try {
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            // 子线程获取请求头信息
            String subThreadLanguages = ServletUtils.getLanguages();
            log.info("子线程获取请求头信息：{}", subThreadLanguages);
        }).start();
        return "success";
    }