
Servlet 的线程安全问题
Servlet 的线程安全问题
在 Servlet 中使用的是多线程方式来执行 service()方法处理请求,所以我们在使用 Servlet 时需要考虑到线程安全问题,在多线程中对于对象中的成员变量是最不安全的,所以不要在 Servlet 中通过成员变量的方式来存放数据,如果一定要使用成员变量存储数据,在对数据 进行操作时需要使用线程同步的方式来解决线程安全问题,避免出现数据张冠李戴现象。
案例
线程1浏览器中传入参数Jack,然后线程2浏览器中传入参数Rose,这样的运行结果中,线程1浏览器无法收到响应,而线程2浏览器收到的响应是Jack。
public class SafeThreadServlet extends HttpServlet {
//把PrintWriter定义为成员变量(这个servlet的不同线程将访问这同一个PrintWriter)
private PrintWriter pw;
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
this.doPost(req, resp);
}
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String name = req.getParameter("name");
//因为PrintWriter对象是成员变量,是多线程共有的
//所以同时运行的Servlet线程会抢占PrintWriter对象
pw = resp.getWriter();
try{
Thread.sleep(5000);
pw.println(name);
pw.flush();
pw.close();
}catch (Exception e){
e.printStackTrace();
}
}
}
原因:在线程1运行到 Thread.sleep(5000) ,进入线程等待时,线程2运行到 pw=resp.getWriter() ,抢占了 PrintWriter 对象,导致线程1在输出时,PrintWriter对象的输出指针变成了线程2浏览器,这样一来线程1浏览器就没有内容输出,线程2浏览器的输出了线程1浏览器传入的参数。
解决方案一
/**
* 通过 Synchronized 锁来保证线程安全
*/
public class SafeThreadServlet extends HttpServlet {
//把PrintWriter定义为成员变量(这个servlet的不同线程将访问这同一个PrintWriter)
private PrintWriter pw;
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
this.doPost(req, resp);
}
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String name = req.getParameter("name");
//因为PrintWriter对象是成员变量,是多线程共有的
//所以同时运行的Servlet线程会抢占PrintWriter对象
//在 getWriter() 之前加上 synchronized 代码块
//可以保证在第一个Servlet线程在使用完PrintWriter之前,第二个Servlet线程不会抢占PrintWriter
synchronized (this){
pw = resp.getWriter();
try{
Thread.sleep(5000);
pw.println(name);
pw.flush();
pw.close();
}catch (Exception e){
e.printStackTrace();
}
} //synchronized 代码块结束
}
}
解决方案二
/**
* 不使用任何成员变量,各Servlet线程中独立创建新的对象
* 这样高并发时虽然会造成更高的内存占用,但是线程之间是安全的
*/
public class SafeThreadServlet1 extends HttpServlet {
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
this.doPost(req, resp);
}
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String name = req.getParameter("name");
PrintWriter pw;
pw = resp.getWriter();
try {
Thread.sleep(5000);
pw.println(name);
pw.flush();
pw.close();
}catch (Exception e){
e.printStackTrace();
}
}
}
本文是原创文章,采用 CC BY-NC-ND 4.0 协议,完整转载请注明来自 倾雨小窝
评论
隐私政策
你无需删除空行,直接评论以获取最佳展示效果