Продолжение, чтобы продолжить

• Возможность выполнить асинхронный запрос без отправки
• Поддержка упакованных запросов и ответов.
• Слушатели асинхронных событий
• Отправка асинхронных запросов в определенные контексты и / или ресурсы

• Завершение продолжения без возобновления.
• Поддержка упаковщиков ответов.
• Дополнительные слушатели для асинхронных событий.

Класс
фабрики ContinuationSupport можно использовать для получения экземпляра продолжения, связанного с запросом:

    Continuation continuation = ContinuationSupport.getContinuation(request);

Приостановить запрос, метод suspend вызывается на продолжение:

  void doGet(HttpServletRequest request, HttpServletResponse response)
  {
    ...
    continuation.suspend();
    ...
  }

После вызова этого метода жизненный цикл запроса будет расширен за пределы возврата в контейнер из вызовов метода Servlet.service (…) и вызовов Filter.doFilter (…). После того, как эти методы отправки вернутся к, поскольку приостановленный запрос не будет принят, и ответ не будет отправлен HTTP-клиенту.

    continuation.suspend(response);

Приостановка аналогична методу request.startAsync () сервлета 3.0. В отличие от продолжений Jetty-6, исключение не генерируется приостановкой, и метод должен возвращаться нормально. Это позволяет регистрировать продолжение после приостановки и устраняет необходимость в мьютексе. Если желательно исключение (для обхода кода, который не знает о продолжениях и может попытаться зафиксировать ответ), то может быть вызвано continueation.undispatch () для выхода из текущего потока из текущей диспетчеризации путем выброса
ContinuationThrowable .

Как только произошло асинхронное событие, продолжение можно возобновить:

  void myAsyncCallback(Object results)
  {
    continuation.setAttribute("results",results);
    continuation.resume();
  }

После продолжения продолжения запрос повторно отправляется в контейнер сервлета, почти как если бы запрос был получен снова. Однако во время повторной отправки метод continueation.isInitial () возвращает значение false, и все атрибуты, установленные асинхронным обработчиком, доступны.

В качестве альтернативы выполнению запроса асинхронный обработчик может написать сам ответ. После написания ответа обработчик должен указать, что обработка запроса завершена, вызвав метод complete:

  void myAsyncCallback(Object results)
  {
    writeResults(continuation.getServletResponse(),results);
    continuation.complete();
  }

После вызова завершения контейнер планирует ответ, который будет зафиксирован и очищен.

Приложение может отслеживать состояние продолжения, используя
ContinuationListener :

  void doGet(HttpServletRequest request, HttpServletResponse response)
  {
    ...
    
    Continuation continuation = ContinuationSupport.getContinuation(request);
    continuation.addContinuationListener(new ContinuationListener()
    {
      public void onTimeout(Continuation continuation) { ... }
      public void onComplete(Continuation continuation) { ... }
    });
    
    continuation.suspend();
    ...
  }

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

  void doGet(HttpServletRequest request, HttpServletResponse response)
  {
     // if we need to get asynchronous results
     Object results = request.getAttribute("results);
     if (results==null)
     {
       final Continuation continuation = ContinuationSupport.getContinuation(request);
       
       // if this is not a timeout
       if (continuation.isExpired())
       {
         sendMyTimeoutResponse(response);
         return;
       }
       
       // suspend the request
       continuation.suspend(); // always suspend before registration
       
       // register with async service.  The code here will depend on the
       // the service used (see Jetty HttpClient for example)
       myAsyncHandler.register(new MyHandler()
       {
          public void onMyEvent(Object result)
          {
            continuation.setAttribute("results",results);
            continuation.resume();
          }
       });
       return; // or continuation.undispatch();
     }
     
     // Send the results
     sendMyResultResponse(response,results);
   }    

Этот стиль очень хорош, когда ответу нужны средства контейнера сервлета (например, он использует веб-среду) или если одно событие может возобновить множество запросов, чтобы пул потоков контейнеров мог использоваться для обработки каждого из них.

The suspend/complete style is used when an asynchronous handler is used to generate the response:

  void doGet(HttpServletRequest request, HttpServletResponse response)
  {
     final Continuation continuation = ContinuationSupport.getContinuation(request);
     
     // if this is not a timeout
     if (continuation.isExpired())
     {
       sendMyTimeoutResponse(request,response);
       return;
     }
     
     // suspend the request
     continuation.suspend(response); // response may be wrapped.
     
     // register with async service.  The code here will depend on the
     // the service used (see Jetty HttpClient for example)
     myAsyncHandler.register(new MyHandler()
     {
       public void onMyEvent(Object result)
       {
         sendMyResultResponse(continuation.getServletResponse(),results);
         continuation.complete();
       }
     });
   }