Реализация длинного опроса в асинхронном режиме - PullRequest
Новая
       0

Реализация длинного опроса в асинхронном режиме

6 голосов
/ 10 ноября 2011

Можно ли убрать HTTPServletRequest из его потока, растворить этот поток (т.е. вернуть его в пул), но сохранить работающее соединение с браузером, пока я не получу результаты от длительной операции ( скажем, обработка изображения)? Когда возвращаемые данные обрабатываются, другой метод должен вызываться асинхронно и получать запрос, а также данные в качестве параметров.

Обычно функции длинного пула довольно блокируют, когда текущий поток не растворяется, что снижает масштабируемость серверного приложения с точки зрения одновременных соединений.

Ответы [ 2 ]

5 голосов
/ 11 ноября 2011

Да, вы можете сделать это с Servlet 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);
}
}

Ниже приведен пример записи на основе события. Должен быть реализован alertManager, который уведомляет AlertNotificationHandler, когда клиент должен быть предупрежден. 

@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
                         }
                   }
        });
  }
}
2 голосов
/ 10 ноября 2011

Да, это возможно, используя Servlet spec ver. 3.0. Реализация, которую я могу порекомендовать, это сервер Jetty. Смотрите здесь .

...