Thực hiện bỏ phiếu dài theo cách không đồng bộ

Question

Có thể lấy HTTPServletRequest ra khỏi chuỗi của nó, giải thể luồng này (nghĩa là đưa nó trở lại hồ bơi), nhưng giữ kết nối cơ bản với trình duyệt đang hoạt động, cho đến khi tôi nhận được kết quả từ một hoạt động tốn thời gian (nói, xử lý một hình ảnh)? Khi dữ liệu trả về được xử lý, một phương thức khác sẽ được gọi là không đồng bộ và được cung cấp yêu cầu cũng như dữ liệu dưới dạng tham số.

Thông thường, các chức năng tổng hợp dài theo kiểu bị chặn khá tốt, trong đó luồng hiện tại không bị giải thể, làm giảm khả năng mở rộng của ứng dụng phía máy chủ, về các kết nối đồng thời.

Answer 1

Có, có thể sử dụng thông số kỹ thuật Servlet ver. 3.0. Thực hiện tôi có thể đề nghị là máy chủ Jetty. Xem here.

Answer 2

Có, bạn có thể thực hiện việc này với Servlet 3.0

Dưới đây là mẫu để viết cảnh báo sau mỗi 30 giây (không được kiểm tra).

@WebServlet(async =“true”) 
public class AsyncServlet extends HttpServlet { 

Timer timer = new Timer("ClientNotifier"); 

public void doGet(HttpServletRequest req, HttpServletResponse res) { 

    AsyncContext aCtx = request.startAsync(req, res); 
    // Suspend request for 30 Secs 
    timer.schedule(new TimerTask(aCtx) { 

     public void run() { 
      try{ 
        //read unread alerts count 
       int unreadAlertCount = alertManager.getUnreadAlerts(username); 
        // write unread alerts count 
    response.write(unreadAlertCount); 
      } 
      catch(Exception e){ 
       aCtx.complete(); 
      } 
     } 
    }, 30000); 
} 
} 

Dưới đây là mẫu viết dựa trên sự kiện. AlertManager phải được thực hiện để thông báo cho AlertNotificationHandler khi máy khách phải được cảnh báo.

@WebServlet(async=“true”) 
public class AsyncServlet extends HttpServlet { 
public void doGet(HttpServletRequest req, HttpServletResponse res) { 
     final AsyncContext asyncCtx = request.startAsync(req, res); 
     alertManager.register(new AlertNotificationHandler() { 
        public void onNewAlert() { // Notified on new alerts 
         try { 
           int unreadAlertCount = 
             alertManager.getUnreadAlerts(); 
           ServletResponse response = asyncCtx.getResponse(); 
           writeResponse(response, unreadAlertCount); 
           // Write unread alerts count 
         } catch (Exception ex) { 
           asyncCtx.complete(); 
           // Closes the response 
         } 
        } 
     }); 
    } 
}