解决子线程不共有父线程的请求上下文环境
正常的开启子线程的时候,存在一个问题。即 子线程并不具有父线程的请求上下文环境,比如说session,子线程在请求服务器的时候是没有session的,于是服务器随机生成一个session赋给他,这就导致一个问题。比如说微服务开发的时候,需要在子线程通过feign调用其他服务的接口,而这些被调用的接口一般都需要验证是否具有权限,此时,通过子线程访问接口就会抛出401或者403的权限错误。
·
正常的开启子线程的时候,存在一个问题。
即 子线程并不具有父线程的请求上下文环境,比如说session,子线程在请求服务器的时候是没有session的,于是服务器随机生成一个session赋给他,这就导致一个问题。比如说微服务开发的时候,需要在子线程通过feign调用其他服务的接口,而这些被调用的接口一般都需要验证是否具有权限,此时,通过子线程访问接口就会抛出401或者403的权限错误。
解决思路很简单,即开启子线程的时候,确保子线程共有父线程的请求上下文环境。只需要在启动线程之前加上如下代码即可。
/**
* 生成日报表
* @param日期
* */
@POST
@Path(value = "/generateDayreport")
@Operation(code = 301,desc = "生成")
public String lookDayreport(@RequestBody String req) throws BusinessAccessException{
ExecutorService threadPool = Executors.newFixedThreadPool(5);
Map<String, String> map = new HashMap<>();
JSONObject jsonObject = JSONObject.parseObject(req);
String date = jsonObject.getString("date");
RequestAttributes requestAttributes = RequestContextHolder.currentRequestAttributes();
System.out.println("=ui==="+requestAttributes.getSessionId());
RequestContextHolder.setRequestAttributes(requestAttributes, true);//子线程继承主线程的上下文
try {
service.insertDayreport(date, "1", "true");
map.put("code", "1");
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
map.put("code", "2");
}
GenerateDayReport generateDayReport = new GenerateDayReport(date);
threadPool.execute(generateDayReport);
threadPool.shutdown();
return JSONObject.toJSONString(map);
}
GenerateDayReport是实现Runable接口的类
更多推荐
已为社区贡献1条内容
所有评论(0)