Hybris中FlexibleSearchService在ForkJoinPool下抛NPE问题求助

你遇到的空指针异常（NPE）核心原因是Hybris的Session上下文绑定到请求线程，而异步线程默认不会继承这个上下文，具体细节和解决方案如下：

为什么同步正常，异步就报错？ #

Hybris的Service Layer组件（比如你用到的FlexibleSearchService）内部严重依赖线程绑定的Session。在同步执行时，所有代码都运行在处理HTTP请求的主线程中，这个线程自带Hybris的Session上下文，所以flexibleSearchService.search()可以正常调用。

但当你用CompletableFuture.supplyAsync()或者parallelStream()时，任务会被提交到ForkJoinPool的线程池中执行。这些线程是Hybris容器外的线程池，没有初始化Hybris的Session上下文。当flexibleSearchService内部调用DefaultSessionService.executeInLocalView()时，找不到当前线程对应的Session，就会抛出空指针异常。

另外，你的代码还有个潜在的线程安全问题：priceErrorList是普通的ArrayList，多个异步任务同时调用priceErrorList::add会导致并发修改异常或者数据丢失，只是你还没触发这个问题而已。

解决方案 #

1. 为异步线程添加Hybris Session上下文 #

在PriceService的setPrice方法中，用SessionService的executeInLocalView()包裹数据库操作，它会自动为当前线程创建一个局部的Session上下文，并在任务完成后清理，完美适配异步场景：

@Autowired 
private FlexibleSearchService flexibleSearchService;
@Autowired
private SessionService sessionService;

public PriceError setPrice(Price data){ 
    // 用executeInLocalView包裹所有需要Session的操作
    return sessionService.executeInLocalView(() -> {
        // building query 
        // initialize map with params 
        return flexibleSearchService.search(query.toString(), params).getResult().get(0);
    });
}

2. 修复结果集合的线程安全问题 #

把ArrayList换成线程安全的集合，或者更优雅地用CompletableFuture.allOf()统一收集结果：

方式一：使用线程安全集合

final List<PriceError> priceErrorList = Collections.synchronizedList(new ArrayList<>());
final List<CompletableFuture<Void>> futures = new ArrayList<>();

for (final PriceData price : priceList.getPriceList()) {
    futures.add(CompletableFuture.supplyAsync(() -> priceService.setPrice(price))
            .thenAccept(priceErrorList::add));
}

// 等待所有任务完成
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();

方式二：统一收集结果（更推荐）

这种方式避免了并发修改集合的问题，代码更清晰：

// 先创建所有返回PriceError的Future
List<CompletableFuture<PriceError>> futures = priceList.getPriceList().stream()
        .map(price -> CompletableFuture.supplyAsync(() -> priceService.setPrice(price)))
        .collect(Collectors.toList());

// 等待所有任务完成
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();

// 统一收集结果
final List<PriceError> priceErrorList = futures.stream()
        .map(CompletableFuture::join)
        .collect(Collectors.toList());

3. 可选：传递原请求的Session属性（如果需要） #

如果你的业务需要继承原请求的Session属性（比如用户权限、语言设置），可以在主线程先获取Session数据，然后在异步任务中设置到新Session：

// 主线程中获取原Session属性
Map<String, Object> sessionAttributes = sessionService.getCurrentSession().getAttributes();

// 异步任务中设置
return sessionService.executeInLocalView(() -> {
    Session currentSession = sessionService.getCurrentSession();
    sessionAttributes.forEach(currentSession::setAttribute);
    // 执行数据库操作
    return flexibleSearchService.search(query.toString(), params).getResult().get(0);
});

这样修改后，异步调用就能正常工作，同时也解决了潜在的线程安全问题。

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