Wdrażanie długiego sondowania w asynchronicznej modzie

Question

Czy można odjąć HTTPServletRequest od jego wątku, rozpuścić ten wątek (np. Przywrócić go do puli), ale utrzymywać podstawowe połączenie z przeglądarką, dopóki nie otrzymam wyników od czasochłonnej operacji (powiedzmy, przetwarzania obrazu)? Kiedy przetwarzane są dane zwracane, inna metoda powinna być wywołana asynchronicznie i otrzymać żądanie, a także dane jako parametry.

Zwykle długie funkcje łączenia w ładny sposób blokowania, w którym bieżący wątek nie jest rozpuszczany, co zmniejsza skalowalność aplikacji po stronie serwera pod względem równoczesnych połączeń.

Answer 1

Tak, jest to możliwe za pomocą Servlet spec ver. 3.0. Wdrożenie Mogę polecić serwer Jetty. Zobacz here.

Answer 2

Tak, można to zrobić z Servlet 3.0

Poniżej próbka napisać alert co 30 sek (nie testowane).

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

Poniżej znajduje się próbka do napisania na podstawie zdarzenia. Należy zaimplementować alertManager, który powiadamia AlertNotificationHandler, gdy klient musi być ostrzeżony.

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