当前位置：首页 > article >正文

CompletableFuture异步业务默认ForkJoinPool 导致类加载器加载类失败

article 2025/3/11 3:29:47

1、Bug案发现场

2、捉虫过程过程

3、解决方案与代码

4、成果展现与总结编辑

5、参考文章

1、Bug案发现场

最近参与帮助以前同事实际业务开发中业务，在一个业务场景之中；使用H5页面通过二维码收集小微企业/个体工商户贷款业务需求。其中在获得用户输入企业名称后，获得企业或者个体工商户信用代码后，使用CompletableFuture的.supplyAsync方法实现异步保存企业基本信息到数据库之中；但是此异步操作类默认使用的ForkJoinPool 作为线程池。于是发生一个奇怪的Bug，在测试环境（test）【阿里云的ECS Docker JDK21+MySQL8.0.36+Redis 7.0.5】可以很正常实现数据保存；但是在正式环境部署到山东某市客户服务器上【Docker JDK21+Redis 7.0.5+MySQL5.7.44】死活无法保存基本公司信息到数据库里面。

具体出错问题就是下面这行代码

redisTemplate.boundValueOps(CACHE_KEY_PREFIX + key).get()

非法参数异常，未找到类对应的类。具体错误信息如下所示：

+---[39.81% 0.872861ms ] vip.xiaonuo.common.cache.CommonCacheOperator:get() #203 [throws Exception]
        `---throw:java.lang.IllegalArgumentException #881 [org.springframework.data.redis.core.BoundValueOperations referenced from a method is not visible from class loader: 'app']

2、捉虫过程过程

我们在这个过程之中，怀疑过JDK21版本问题，退回到JDK17；怀疑过Redis问题也搭建相同的版本；所有的验证都是徒劳的。并且比较奇怪的Test环境一切正常。生产环境就是报错。从业务角度来说也是需要使用异步的方式来分开处理业务需求。甚至网上找到github上一篇类似文章。

https://github.com/spring-projects/spring-data-redis/issues/2772 【国内可能无法打开上有截图】

最后思考后继续寻找异常关键词语

throw:java.lang.IllegalArgumentException #881 [org.springframework.data.redis.core.BoundValueOperations referenced from a method is not visible from class loader

于是SegmentFault 思否网站上找一篇类似文章，有相关异常描述。最后定位并确定就是因为以前使用 CompletableFuture.supplyAsync() 异步方法，默认使用的 ForkJoinPool 作为线程池所导致的。

在有上述思路后，今天去开发现场，使用自己定义线程池；替换了默认ForkJoinPool线程池；时间这个困扰1周左右的问题。并且实现了基本公司信息正确正常入库。

3、解决方案与代码

自定义线程池

@Configuration
public class ThreadPoolConfig {
    // 核心线程数
    private int corePoolSize = 5;
    // 最大线程数
    private int maxPoolSize = 10;
    // 队列大小
    private int queueSize = 40;
    // 线程最大空闲时间
    private int keepAliveSeconds = 40;
    /**
     * 自定义消费队列线程池
     * CallerRunsPolicy 这个策略重试添加当前的任务，他会自动重复调用 execute() 方法，直到成功。
     * AbortPolicy 对拒绝任务抛弃处理，并且抛出异常。
     * DiscardPolicy 对拒绝任务直接无声抛弃，没有异常信息。
     * DiscardOldestPolicy 对拒绝任务不抛弃，而是抛弃队列里面等待最久的一个线程，然后把拒绝任务加到队列。
     * @return
     */

    @Bean(value = "customAsyncTaskThreadPool")
    public ThreadPoolTaskExecutor buildCustomAsyncTaskThreadPool() {
        ThreadPoolTaskExecutor threadPool = new ThreadPoolTaskExecutor();
        threadPool.setCorePoolSize(corePoolSize);
        threadPool.setMaxPoolSize(maxPoolSize);
        threadPool.setQueueCapacity(queueSize);
        threadPool.setThreadNamePrefix("customAsyncTaskThreadPool-");
        threadPool.setKeepAliveSeconds(keepAliveSeconds);
        threadPool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //如果@Bean 就不需手动，会自动InitializingBean的afterPropertiesSet来调initialize
        //threadPool.initialize();
        return threadPool;
    }

@Resource
@Qualifier("customAsyncTaskThreadPool")
private Executor asyncTaskThreadPoolExecutor;


private void saveCompanyBasicInfo(CompanyLoanDemandCreateParam companyLoanDemandCreateParam) {
        CompletableFuture.supplyAsync(() -> {
            try {
                String uscc = companyLoanDemandCreateParam.getUscc();
                String key = String.format(BusinessConstant.WE_COMPANY_CACHE_KEY, uscc);
                log.error("key  "+key);
                Object data =null;
                try {
                     data =commonCacheOperator.get(key);
                } catch (Exception e) {
                    log.error(e.toString());
                }
                if (ObjectUtils.isEmpty(data)) {
                    //处理业务内容
                }
            } catch (ParseException e) {
                log.error("saveCompanyBasicInfo error", e);
            }
            return null;
        },asyncTaskThreadPoolExecutor);

4、成果展现与总结

通过解决困扰我同事与我这个问题；让我明白一个道理，如同最近在看《毛选--->实践论与矛盾论》要解决实际问题只有深入实践并且注意矛盾的特殊性；因为每个开发场景可能与网上文章有相似【矛盾的普遍性】但是又有其自己开发与运行环境的【特殊性】；只有抓住特殊性并结合普遍性才能够找到解决问题的主要矛盾；并使得获得有效的方法论去解决实际问题。