[Java知识库]Servlet 的线程安全问题

Servlet 的线程安全问题

• 在 Servlet 中使用的是多线程方式来执行 service()方法处理请求，所以我们在使用 Servlet 时需要考虑到线程安全问题，在多线程中对于对象中的成员变量是最不安全的，所以不要在 Servlet 中通过成员变量的方式来存放数据，如果一定要使用成员变量存储数据，在对数据 进行操作时需要使用线程同步的方式来解决线程安全问题，避免出现数据张冠李戴现象。

• 案例：线程1浏览器中传入参数aaa，然后线程2浏览器中传入参数bbb，这样的运行结果中，线程1无法收到响应，而线程2收到的响应是aaa。

• 原因：在线程1运行到 Thread.sleep(5000) ，进入线程等待时，线程2运行到 pw=resp.getWriter() ,抢占了 PrintWriter 对象，导致线程1在输出时，PrintWriter对象的输出指针变成了线程2浏览器，这样一来线程1浏览器就没有内容输出，线程2浏览器的输出了线程1浏览器传入的参数。

解决方案1

方案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 代码块结束
    }
}

解决方案2

方案详解2

/**
 * 不使用任何成员变量，各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();
        }
    }
}