踩坑日记（异步线程异常消失 & RequestContextHolder）

灰太狼 2023-07-04 14:12 12阅读 0赞

在一个SpringMVC项目里，通常我们可以使用如下代码来获取和当前线程绑定的HttpServletRequest对象：

HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.currentRequestAttributes()).getRequest();

最近在公司的项目开发中，模块A负责统计业务数据并发送邮件，其接口，提供给一个调度器模块通过定时任务去调用。调度器模块那边，要求被调度模块的接口“立即返回”。也就是说，当满足触发条件，调度器发起对模块A的调用，模块A应立即做出响应，并以异步的方式执行任务，在任务执行完后，再通过一个回调接口，告知调度器某某任务已完成。

一开始我没有注意需要“立即返回”，接口的处理采用的是同步的方式，于是，在调用模块A的数据统计接口时，非常耗时，调度器迟迟收不到模块A的响应，于是认为此次任务失败，并触发了失败重试，不断地对模块A的数据统计接口发出调用。最后导致模块A的数据统计接口被调用多次。

后来我改为异步处理，将数据统计的耗时操作放在`CompletableFuture.runAsync`中。接着出现了错误，数据报表的邮件没有发送出来，看日志也没有任何错误记录。最后在本地调试时，一步一步debug，发现程序在一个获取上下文Request对象的地方，戛然而止。就是下面这行代码。在程序执行到这段代码时，就停止了，之后的代码也没有被执行，日志也没有错误信息输出。

HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.currentRequestAttributes()).getRequest();

我打开debug模式，跟到这个方法的内部，发现获取不到当前上下文的Request对象，并走到了抛出异常的代码块

/** RequestContextHolder.class**/
    public static RequestAttributes currentRequestAttributes() throws IllegalStateException { 
            RequestAttributes attributes = getRequestAttributes();
            if (attributes == null) { 
                if (jsfPresent) { 
                    attributes = RequestContextHolder.FacesRequestAttributesFactory.getFacesRequestAttributes();
                }
    
                if (attributes == null) { 
                    throw new IllegalStateException("No thread-bound request found: Are you referring to request attributes outside of an actual web request, or processing a request outside of the originally receiving thread? If you are actually operating within a web request and still receive this message, your code is probably running outside of DispatcherServlet/DispatcherPortlet: In this case, use RequestContextListener or RequestContextFilter to expose the current request.");
                }
            }
    
            return attributes;
        }

按理说这个运行时异常被抛了出来，JVM应该会捕捉到并打印出其错误信息，但是这个异常并没有被捕捉到，查找资料了解到大概因为是发生在子线程中出现的异常，不会被向上抛给主线程。但是主线程中的运行时异常会由JVM捕捉并处理。可以尝试一下如下代码：

public static void main(String[] args) throws InterruptedException { 
            CompletableFuture.runAsync(() -> { 
               System.out.println("start"); 
               String a = null;
               String[] split = a.split(",");
               System.out.println("end");
            });
            System.out.println("wait");
        	//这里主线程睡眠2s以保证异步线程得到执行
            Thread.sleep(2000);
            System.out.println("exit");
        }

本应报NPE的异步代码块，执行后却没有在控制台看到任何信息。

另外，注意`RequestContextHolder.currentRequestAttributes()`这一句获取的Request上下文，是与线程绑定的，具体的逻辑在`FrameworkServlet`中的`processRequest`方法，SpringMVC中的DispatcherServlet继承自FrameworkServlet，一个Request请求到来时，触发`service()`方法，在`FrameworkServlet`中，会先调用`processRequest`，在这个方法内，使用ThreadLocal将当前的上下文环境保存到`RequestContextHolder`的ThreadLocal变量中。而在异步代码块里，运行的线程，很明显和处理Request请求的线程不是同一个，故无法获取到Request上下文。

异步代码块中出现运行时异常，要如何处理，有待进一步研究。  
初步的解决方案是在异步代码块内部，用一个try-catch包裹住，并在catch子句中进行异常处理。  
或者用CompletableFuture执行异步任务时，用Future变量将该任务的执行保存下来，后调用get方法，能够使得异步块中的异常被扔到主线程中

2020/2/17 更新  
可以使用`CompletableFuture.runAsync().exceptionally()` 在exceptionally方法中将异常信息记录到日志就可以了