springboot项目异步(子线程)处理获取不到header中的token

controller方法中调用service的方法service方法上Async代表异步执行这个方法此时方法中如果获取请求头中的token是获取不到的获取方式如下RequestAttributes requestAttributes RequestContextHolder.getRequestAttributes(); ServletRequestAttributes servletRequestAttributes (ServletRequestAttributes) requestAttributes; HttpServletRequest request servletRequestAttributes.getRequest(); String tokenValue request.getHeader(tokenHeaderKey);具体原因public static RequestAttributes getRequestAttributes() { RequestAttributes attributes (RequestAttributes)requestAttributesHolder.get(); if (attributes null) { attributes (RequestAttributes)inheritableRequestAttributesHolder.get(); } return attributes; } private static final ThreadLocalRequestAttributes requestAttributesHolder new NamedThreadLocal(Request attributes); private static final ThreadLocalRequestAttributes inheritableRequestAttributesHolder new NamedInheritableThreadLocal(Request context);可以看到采用的ThreadLocal存储的request对象所以子线程魂总获取不到主线程的request。解决办法重新创建request对象传参给service中异步方法。首先自定义request对象package com.erbaoge.common.utils; import javax.servlet.*; import javax.servlet.http.*; import java.io.BufferedReader; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.security.Principal; import java.util.*; /** * 实现 javax.servlet.http.HttpServletRequest 方法主要用于在子线程中获取参数 * 目前只实现headers 和 parameters 其他属性可自定义 * since 2025/9/15 15:44 */ public class ServletRequestCustom implements HttpServletRequest { private MapString, VectorString headersMap; private MapString, String[] paraMap; public ServletRequestCustom() { headersMap new HashMap(); paraMap new HashMap(); } public ServletRequestCustom(HttpServletRequest request){ this(); setHeaders(request); setParameters(request); } private void setParameters(HttpServletRequest request) { EnumerationString parameterNames request.getParameterNames(); while (parameterNames.hasMoreElements()){ String key parameterNames.nextElement(); paraMap.put(key, request.getParameterValues(key)); } } private void setHeaders(HttpServletRequest request) { EnumerationString headerNames request.getHeaderNames(); while (headerNames.hasMoreElements()) { String key headerNames.nextElement(); EnumerationString headers request.getHeaders(key); VectorString vector new Vector(); while (headers.hasMoreElements()) { vector.add(headers.nextElement()); } headersMap.put(key, vector); } } Override public String getAuthType() { return ; } Override public Cookie[] getCookies() { return new Cookie[0]; } Override public long getDateHeader(String s) { return 0; } Override public String getHeader(String s) { VectorString vector headersMap.get(s); return vector.isEmpty() ? null : vector.get(0); } Override public EnumerationString getHeaders(String s) { return headersMap.get(s.toLowerCase()).elements(); } Override public EnumerationString getHeaderNames() { IteratorString iterator headersMap.keySet().iterator(); return new EnumerationString() { Override public boolean hasMoreElements() { return iterator.hasNext(); } Override public String nextElement() { return iterator.next(); } }; } Override public int getIntHeader(String s) { return 0; } Override public String getMethod() { return ; } Override public String getPathInfo() { return ; } Override public String getPathTranslated() { return ; } Override public String getContextPath() { return ; } Override public String getQueryString() { return ; } Override public String getRemoteUser() { return ; } Override public boolean isUserInRole(String s) { return false; } Override public Principal getUserPrincipal() { return null; } Override public String getRequestedSessionId() { return ; } Override public String getRequestURI() { return ; } Override public StringBuffer getRequestURL() { return null; } Override public String getServletPath() { return ; } Override public HttpSession getSession(boolean b) { return null; } Override public HttpSession getSession() { return null; } Override public String changeSessionId() { return ; } Override public boolean isRequestedSessionIdValid() { return false; } Override public boolean isRequestedSessionIdFromCookie() { return false; } Override public boolean isRequestedSessionIdFromURL() { return false; } Override public boolean isRequestedSessionIdFromUrl() { return false; } Override public boolean authenticate(HttpServletResponse httpServletResponse) throws IOException, ServletException { return false; } Override public void login(String s, String s1) throws ServletException { } Override public void logout() throws ServletException { } Override public CollectionPart getParts() throws IOException, ServletException { return Collections.emptyList(); } Override public Part getPart(String s) throws IOException, ServletException { return null; } Override public T extends HttpUpgradeHandler T upgrade(ClassT aClass) throws IOException, ServletException { return null; } Override public Object getAttribute(String s) { return null; } Override public EnumerationString getAttributeNames() { return null; } Override public String getCharacterEncoding() { return ; } Override public void setCharacterEncoding(String s) throws UnsupportedEncodingException { } Override public int getContentLength() { return 0; } Override public long getContentLengthLong() { return 0; } Override public String getContentType() { return ; } Override public ServletInputStream getInputStream() throws IOException { return null; } Override public String getParameter(String s) { String[] values paraMap.get(s); return values.length 0 ? values[0] : null; } Override public EnumerationString getParameterNames() { final IteratorString iterator paraMap.keySet().iterator(); return new EnumerationString() { Override public boolean hasMoreElements() { return iterator.hasNext(); } Override public String nextElement() { return iterator.next(); } }; } Override public String[] getParameterValues(String s) { return paraMap.get(s); } Override public MapString, String[] getParameterMap() { return new HashMap(paraMap); } Override public String getProtocol() { return ; } Override public String getScheme() { return ; } Override public String getServerName() { return ; } Override public int getServerPort() { return 0; } Override public BufferedReader getReader() throws IOException { return null; } Override public String getRemoteAddr() { return ; } Override public String getRemoteHost() { return ; } Override public void setAttribute(String s, Object o) { } Override public void removeAttribute(String s) { } Override public Locale getLocale() { return null; } Override public EnumerationLocale getLocales() { return null; } Override public boolean isSecure() { return false; } Override public RequestDispatcher getRequestDispatcher(String s) { return null; } Override public String getRealPath(String s) { return ; } Override public int getRemotePort() { return 0; } Override public String getLocalName() { return ; } Override public String getLocalAddr() { return ; } Override public int getLocalPort() { return 0; } Override public ServletContext getServletContext() { return null; } Override public AsyncContext startAsync() throws IllegalStateException { return null; } Override public AsyncContext startAsync(ServletRequest servletRequest, ServletResponse servletResponse) throws IllegalStateException { return null; } Override public boolean isAsyncStarted() { return false; } Override public boolean isAsyncSupported() { return false; } Override public AsyncContext getAsyncContext() { return null; } Override public DispatcherType getDispatcherType() { return null; } }contoller中方法注入HttpServletRequest对象并创建自定义request对象GetMapping(/test) public Result? test (HttpServletRequest request) { ServletRequestCustom servletRequestCustom new ServletRequestCustom(request); lotteryService.test(servletRequestCustom); return Result.success(); }service中异步方法需要将request放入Async Override public void test(HttpServletRequest request) { RequestContextHolder.setRequestAttributes(new ServletRequestAttributes(request)); try { ...... } finally { RequestContextHolder.resetRequestAttributes(); } }上述方法是spring的异步执行方法方法中就能成功使用开始的那种方式获取到token。两点疑问为什么不直接传参从controller中注入的request对象为什么不在controller线程中获取ServletRequestAttributes后再放入子线程获取参数传参true。使用代码RequestContextHolder.setRequestAttributes(new ServletRequestAttributes(request), true);答案是以上两种方式都不能成功在异步方法中获取token详细原因还未深究。类似文章【问题】spring boot中是Java8 parallelStream 造成的RequestContextHolder.getRequestAttributes()为null-CSDN博客