我们可以通过把对象设计成不可变对象来躲避并发,我们还可以通过使用线程封闭来实现线程安全,所谓线程封闭
就是将数据都封装到一个线程里,不让其他线程访问。
- Ad-hoc 线程封闭程序控制实现,比较脆弱,尽量少用
- 堆栈封闭:局部变量,无并发问题,在项目中使用最多,简单说就是局部变量,方法的变量都拷贝到线程的堆栈中,只有这个线程能访问到。尽量少使用全局变量(变量不是常量)
- ThreadLocal 线程封闭:比较好的封闭方法
ThreadLocal 维护的是一个 map 这个 map 是线程的名称多为 key 我们所有封闭的值作为 value。
我们做使用 Filter 做登录操作都做过,我们现在来使用 ThreadLoad 来存储一下用户信息。
public class RequestHolder {private final static ThreadLocal<Long> requestHolder = new ThreadLocal<>();
public static void add(Long id) {requestHolder.set(id);
}
public static Long getId() {return requestHolder.get();
}
public static void remove() {requestHolder.remove();
}
}
声明一个 ThreadLoad 对象用来存储 ThreadLoad 信息。
@Slf4j
public class HttpFilter implements Filter {
@Override
public void init(FilterConfig filterConfig) throws ServletException { }
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {HttpServletRequest request = (HttpServletRequest) servletRequest;
log.info("do filter, {}, {}", Thread.currentThread().getId(), request.getServletPath());
RequestHolder.add(Thread.currentThread().getId());
filterChain.doFilter(servletRequest, servletResponse);
}
@Override
public void destroy() {}
@Slf4j
public class HttpInterceptor extends HandlerInterceptorAdapter {
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {log.info("preHandle");
return true;
}
@Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {RequestHolder.remove();
log.info("afterCompletion");
return;
}
}
定义 filter 的内容,我们在 filter 中将线程 id 加入到 ThreadLoad 中,然后在 controller 中获取,看看能不能获取的到。在线程执行完之后将 ThreadLoad 中的数据清空防止内存溢出。
@Controller
@RequestMapping("/threadLocal")
public class ThreadLocalController {@RequestMapping("/test")
@ResponseBody
public Long test() {return RequestHolder.getId();
}
}
最后我们用 postman 测试发现打印了线程 id,ThreadLoad 中变量值只要是一个线程中不管在哪个类中都是共享的。