Spring 5.x 环境下如何通用清理存储用户权限的ThreadLocal条目

你遇到的问题本质是Spring MVC异步请求场景下，业务逻辑运行在独立的异步线程池线程中，原生的Servlet过滤器、Spring MVC拦截器都运行在Servlet IO线程，跨线程无法操作到业务线程的ThreadLocal。以下是两种可直接落地的通用实现方案：

方案1：使用Spring MVC提供的CallableProcessingInterceptor（适配当前场景的最优解） #

这个拦截器是Spring专门为异步Callable请求设计的，回调逻辑直接运行在执行业务的异步线程中，能精准处理业务线程的ThreadLocal。

• 第一步：实现拦截器

public class ThreadLocalCleanupCallableInterceptor implements CallableProcessingInterceptor {
    @Override
    public <T> void afterCompletion(NativeWebRequest request, Callable<T> task, Exception ex) throws Exception {
        // 替换为你项目中@Repository类下的静态ThreadLocal实例的remove方法
        YourPermissionRepository.PERMISSION_THREAD_LOCAL.remove();
    }
}

• 第二步：注册到Spring MVC配置中

@Configuration
public class WebMvcConfig implements WebMvcConfigurer {
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addCallableInterceptor(new ThreadLocalCleanupCallableInterceptor());
    }
}

该方案不管请求是正常返回、抛出异常，都会触发afterCompletion回调，100%保证清理逻辑执行。

方案2：异步线程池加任务装饰器（更通用，覆盖所有异步线程场景） #

如果你的项目中还有其他@Async异步任务也用到了这个ThreadLocal，可以通过给异步线程池配置任务装饰器，在所有异步任务执行完毕后统一清理。

• 自定义任务装饰器

public class ThreadLocalCleanupTaskDecorator implements TaskDecorator {
    @Override
    public Runnable decorate(Runnable runnable) {
        return () -> {
            try {
                runnable.run();
            } finally {
                // 清理ThreadLocal
                YourPermissionRepository.PERMISSION_THREAD_LOCAL.remove();
            }
        };
    }
}

• 配置Spring MVC异步线程池，绑定装饰器

@Configuration
public class AsyncConfig implements WebMvcConfigurer {
    @Override
    public void configureAsyncSupport(AsyncSupportConfigurer configurer) {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(50);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("mvc-async-");
        // 绑定自定义装饰器
        executor.setTaskDecorator(new ThreadLocalCleanupTaskDecorator());
        executor.initialize();
        configurer.setTaskExecutor(executor);
    }
}

补充说明 #

如果后续你还有跨线程传递ThreadLocal的需求，可以替换静态ThreadLocal为TransmittableThreadLocal，配合其提供的线程池包装工具，能解决异步场景下ThreadLocal传递+自动清理的问题，适配性更强。

内容的提问来源于stack exchange，提问作者Viv