正常的开启子线程的时候,存在一个问题。

即 子线程并不具有父线程的请求上下文环境,比如说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接口的类
Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐