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

程序员文章站 2023-12-28 12:03:58

...

在一个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方法，能够使得异步块中的异常被扔到主线程中