Implementazione di polling lungo in modo asincrono

Question

È possibile rimuovere un HTTPServletRequest dal thread, dissolvere questo thread (cioè riportarlo nel pool), ma mantenere funzionante la connessione sottostante con il browser, finché non ottengo i risultati da un'operazione che richiede tempo (ad esempio, l'elaborazione di un'immagine)? Quando i dati di ritorno vengono elaborati, un altro metodo dovrebbe essere chiamato in modo asincrono e ricevere la richiesta e i dati come parametri.

In genere, il pooling lungo funziona in modo piuttosto bloccante, in cui il thread corrente non viene risolto, riducendo la scalabilità dell'app lato server, in termini di connessioni simultanee.

Answer 1

Sì, è possibile utilizzando le specifiche servlet ver. 3.0. L'implementazione che posso raccomandare è il server Jetty. Vedi here.

Answer 2

Sì, è possibile farlo con Servlet 3.0

Di seguito è riportato l'esempio di scrivere l'avviso ogni 30 secondi (non testato).

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

Di seguito è riportato l'esempio da scrivere in base a un evento. È necessario implementare l'alertManager che notifica AlertNotificationHandler quando il client deve essere avvisato.

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