摘要：異步模式處理請求時，提供支持和的。服務(wù)方法首先通過調(diào)用請求對象的方法將請求置于異步模式，這是使用非阻塞所必需的。

應(yīng)用程序的web容器通常為每一個客戶端請求分配一個服務(wù)端線程。開發(fā)可擴展的web應(yīng)用，你必須確保關(guān)聯(lián)請求的線程是沒有空閑的，不需要等待一個阻塞操作完成。異步處理提供了在一個新線程處理阻塞操作的機制，把關(guān)聯(lián)請求的線程返回給容器。即使你所有的阻塞操作都在service方法中異步執(zhí)行，關(guān)聯(lián)客戶端請求的線程基于input/output也可能出于暫時空閑狀態(tài)。
例如，如果一個客戶端在一個很慢的網(wǎng)絡(luò)連接上提交一個大的HTTP POST請求，server讀取請求的速度比客戶端上傳的速度快很多。使用TIO，容器關(guān)聯(lián)請求的線程有時會出于空閑狀態(tài)，因為要等待客戶端的請求的其余部分。
JAVA EE異步模式處理請求時，提供支持servlet和filter的NIO。下面的步驟總結(jié)了在service方法中如何使用NIO處理請求和寫出響應(yīng)：

1. 如 Asynchronous Processing章節(jié)描述，把請求設(shè)置為異步模式  
2. 在service方法中從請求和響應(yīng)對象中獲得一個請求流或一個響應(yīng)流
3. 分配給請求流一個監(jiān)聽器或者分配給響應(yīng)流一個監(jiān)聽器 
4. 在監(jiān)聽器的回調(diào)方法中處理請求和響應(yīng)

方法簽名：void setReadListener(ReadListener rl)
描述：將輸入流與包含回調(diào)方法的監(jiān)聽器對象關(guān)聯(lián)，以異步讀取數(shù)據(jù)。提供的監(jiān)聽器對象可以是一個匿名類或者使用其他的機制給監(jiān)聽器對象傳入輸入流。
方法簽名：boolean isReady()
方法描述：如果數(shù)據(jù)可以無阻塞讀取，返回true
方法簽名：boolean isFinished()
方法描述：當(dāng)所有數(shù)據(jù)讀取完畢后，返回true

方法簽名：void setWriteListener(WriteListener wl)
方法描述：將此輸出流與包含回調(diào)方法的偵聽器對象關(guān)聯(lián)，以異步寫入數(shù)據(jù)。
您將寫入偵聽器對象提供為匿名類，或使用其他機制將輸出流傳遞給寫入偵聽器對象。
方法簽名：boolean isReady()
方法描述：如果數(shù)據(jù)可以無阻塞寫入，返回true

接口名稱：ReadListener
接口方法：void onDataAvailable()、void onAllDataRead()、void onError(Throwable t)
描述：ServletInputStream當(dāng)數(shù)據(jù)可以有效讀取、當(dāng)數(shù)據(jù)讀取完畢、當(dāng)發(fā)生一個錯誤時調(diào)用監(jiān)聽器的這些方法。
接口名稱：WriteListener
接口方法：void onWritePossible()、void onError(Throwable t)
描述：ServletOutputStream當(dāng)數(shù)據(jù)可以無阻塞讀取、當(dāng)發(fā)生一個錯誤時調(diào)用監(jiān)聽器的這些方法。

本節(jié)代碼展示了在servlet對象中怎么讀取一個大的HTTP POST數(shù)據(jù)，通過把請求放入異步模式中并使用NIO功能。

@WebServlet(urlPatterns={"/asyncioservlet"}, asyncSupported=true)
public class AsyncIOServlet extends HttpServlet {
   @Override
   public void doPost(HttpServletRequest request, 
                      HttpServletResponse response)
                      throws IOException {
      final AsyncContext acontext = request.startAsync();
      final ServletInputStream input = request.getInputStream();
      
      input.setReadListener(new ReadListener() {
         byte buffer[] = new byte[4*1024];
         StringBuilder sbuilder = new StringBuilder();
         @Override
         public void onDataAvailable() {
            try {
               do {
                  int length = input.read(buffer);
                  sbuilder.append(new String(buffer, 0, length));
               } while(input.isReady());
            } catch (IOException ex) { ... }
         }
         @Override
         public void onAllDataRead() {
            try {
               acontext.getResponse().getWriter()
                                     .write("...the response...");
            } catch (IOException ex) { ... }
            acontext.complete();
         }
         @Override
         public void onError(Throwable t) { ... }
      });
   }
}

此示例使用@WebServlet批注參數(shù)asyncSupported = true聲明具有異步支持的Web Servlet。服務(wù)方法首先通過調(diào)用請求對象的startAsync（）方法將請求置于異步模式，這是使用非阻塞I / O所必需的。然后，服務(wù)方法獲得與請求相關(guān)聯(lián)的輸入流，并分配定義為內(nèi)部類的讀取偵聽器。偵聽器在可用時讀取部分請求，然后在完成讀取請求時將一些響應(yīng)寫入客戶端。