एक एसिंक्रोनस फैशन में लंबे मतदान को लागू करना

Question

क्या यह थ्रेड से HTTPServletRequest को दूर करना संभव है, इस धागे को भंग कर दें (यानी इसे वापस पूल में लाएं), लेकिन परिणाम प्राप्त होने तक ब्राउज़र के साथ अंतर्निहित कनेक्शन रखें एक समय लेने वाली ऑपरेशन से (कहें, एक छवि प्रसंस्करण)? जब रिटर्न डेटा संसाधित किया जाता है, तो दूसरी विधि को अतुल्यकालिक रूप से कहा जाना चाहिए, और अनुरोध के साथ-साथ पैरामीटर के रूप में डेटा दिया जाना चाहिए।

आमतौर पर, एक सुंदर अवरुद्ध फैशन में लंबे पूलिंग फ़ंक्शन, जहां वर्तमान धागा भंग नहीं होता है, जो समवर्ती कनेक्शन के संदर्भ में सर्वर-साइड ऐप की स्केलेबिलिटी को कम करता है।

Answer 1

हां, Servlet spec ver का उपयोग करना संभव है। 3.0। कार्यान्वयन मैं जेटी सर्वर की सिफारिश कर सकते हैं। here देखें। (परीक्षण नहीं)

Answer 2

हाँ, आप सर्वलेट 3.0

नीचे साथ ऐसा कर सकते नमूना चेतावनी हर 30 सेकेंड में लिखने के लिए है।

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

नीचे किसी ईवेंट के आधार पर लिखने के लिए नमूना है। चेतावनी प्रबंधक को कार्यान्वित किया जाना चाहिए जो क्लाइंट को सतर्क होने पर अलर्ट नॉटिफिकेशन हैंडलर को सूचित करता है।

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