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();
        }
    }
}