在Java8中使用HttpServletRequest和ParallelStream

Question

我有一个简单的应用程序，它将公开一个名为'GET AllDeviceData'的RESTFul GETendpoint，它将简单地从DB中的device表返回所有设备的提取数据列表。

对于每个请求，我通过验证HttpServletRequest.getUserPrincipal()方法来验证用户身份。为了加速这个过程，我使用了parallelStream和lambda表达式。

在ParallelStream中，我调用了另一个名为'Get DeviceData'的方法，在该方法中，我正在进行身份验证并从DB中提取数据。

问题是，当并行流进程调用getDeviceDat方法时，我得到一个NullPointer异常，无法完成并行steam。

问题是，HttpServletRequest.getUserPrincipal()在方法中为空。但它实际上存在于'get alldevicedata'（lambda表达式所在的位置）中。

如果我将“parallel stream()'替换为”stream()'（但在本例中不存在并行性质），则这不会产生任何问题。

@Override
@ResponseBody
@RequestMapping(value = "getAllDeviceData", method = RequestMethod.GET, consumes = "*")
public List<List<Data>> getAllDeviceData(    
        @RequestParam(value = "recordLimit", required = false) final Integer recordLimit,         
        final HttpServletRequest request) {

    final List<Device> deviceList = deviceService.getAllDevices();   
    final List<List<Data>> dataList = deviceList.parallelStream().map(device -> getDeviceData(recordLimit, device.getDeviceId(), request)).collect(Collectors.toList());

    return alerts;
}

private List<Data> getDeviceData(@RequestParam(value = "recordLimit", required = false) Integer recordLimit, String deviceId, HttpServletRequest request) {
    if(request.getUserPrincipal() == null){
        logger.info("User Principle Null - 1");
    }else {
        logger.info("User Principle Not Null - 1");
    }
    authService.doAuthenticate(request);

    // if authrnticated proceed with following...
    List<Data> deviceData = deviceService.getGetDeviceData(deviceId);
    return deviceData;
}

但是，我观察到了一些东西。

请看上述应用程序的以下日志（省略了不必要的部分）。

在它中，主线程（例如:http-nio-7070-exec-2等--这是应用程序服务器线程池的主线程）工作良好，因为它打印出“User Principal Not Null-1”，但在并行流的分解线程（如ForkJoinPool.CommonPool-Worker-2等）中，HttpServletRequest.GetUserPrincipal()变为Null。

2018-01-15 15:28:06,897 INFO [http-nio-7070-exec-2] User Principle Not Null - 1 
2018-01-15 15:28:06,897 INFO [ForkJoinPool.commonPool-worker-2] User Principle Null - 1 
2018-01-15 15:28:06,906 INFO [ForkJoinPool.commonPool-worker-3] User Principle Null - 1 

2018-01-15 15:28:06,955 INFO [ForkJoinPool.commonPool-worker-2] User Principle Null - 1 
2018-01-15 15:28:06,955 INFO [ForkJoinPool.commonPool-worker-1] User Principle Null - 1

2018-01-15 15:28:06,957 INFO [ForkJoinPool.commonPool-worker-2] User Principle Null - 1 
2018-01-15 15:28:06,959 INFO [ForkJoinPool.commonPool-worker-3] User Principle Null - 1
2018-01-15 15:28:07,064 INFO [ForkJoinPool.commonPool-worker-2] User Principle Null - 1 

2018-01-15 15:28:07,076 INFO [http-nio-7070-exec-2] User Principle Not Null -1

2018-01-15 15:28:07,078 INFO [ForkJoinPool.commonPool-worker-1] User Principle Null - 1

我对lambda表达式和并行流还是新手。请帮助我理解这里的问题是什么。

Java详细信息：

java version "1.8.0_121"
Java(TM) SE Runtime Environment (build 1.8.0_121-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.121-b13, mixed mode)

Answer 1

根本原因是Spring正在将SecurityContextHolderAwareRequestWrapper实例注入到您的方法中。调用equest.getUserPrincipal()时，此包装将调用以下行：

private Authentication getAuthentication() {
    Authentication auth = SecurityContextHolder.getContext().getAuthentication();

SecurityContextHolder有不同的策略。默认情况下，使用mode_threadlocal策略。这就是为什么在主线程中有用户原则，而在forkjoinpool线程中没有用户原则的原因。

-dspring.security.strategy=mode_inheritablethreadlocalVM选项是解决问题的一种方法。InheritableThreadLocal javadoc和InheritableThreadLocalSecurityContextHolderStrategy源代码可能会为理解带来额外的价值。