1. 程式人生 > >Serlvet 處理http請求並保持長連接

Serlvet 處理http請求並保持長連接

數據 http print htm boa out eth 3.0 cte

一.Servlet,一個請求在容器中是如何處理的

Servlet規定的,相應客戶請求訪問特定Servlet流程如下:

1.客戶端發出請求。

2.Servlet容器接收客戶請求解析。

3.Servlet容器創建一個ServletRequest對象。

其中包含客戶請求信息及其他關於客戶的信息如請求頭,請求正文,客戶機的IP等。

4.容器創建一個ServletResponse對象。

5.容器調用客戶請求的Servlet的service方法,並且把ServletRequest和ServletResponse作為參數傳入。

6.Servlet從客戶參數中獲得客戶請求信息,並調用對應的doGet或doPost處理。

7.Servlet利用ServletResponse對象來生產相應結果。

8.Servlet容器把Servlet生成的結果發給客戶。

二.Servlet3.0長連接

servlet3.0規範中添加了異步處理,即一部分操作處理完成之後,先行把數據返回來,對於另一部分比較耗時的操作可以放置到另外一個線程中進行處理,該線程保留有連接的請求和響應對象,在處理完成之後可以把處理的結果通知到客戶端,實例代碼如下:

[java] view plain copy print?
  1. import java.io.IOException;
  2. import java.io.PrintWriter;
  3. import java.util.Date;
  4. import javax.servlet.AsyncContext;
  5. import javax.servlet.AsyncEvent;
  6. import javax.servlet.AsyncListener;
  7. import javax.servlet.ServletException;
  8. import javax.servlet.annotation.WebServlet;
  9. import javax.servlet.http.HttpServlet;
  10. import javax.servlet.http.HttpServletRequest;
  11. import javax.servlet.http.HttpServletResponse;
  12. @WebServlet(urlPatterns="/demo", asyncSupported=true)
  13. public class AsynServlet extends HttpServlet {
  14. private static final long serialVersionUID = -8016328059808092454L;
  15. /* (non-Javadoc)
  16. * @see javax.servlet.http.HttpServlet#service(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse)
  17. */
  18. @Override
  19. protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  20. resp.setContentType("text/html;charset=UTF-8");
  21. PrintWriter out = resp.getWriter();
  22. out.println("進入Servlet的時間:" + new Date() + ".");
  23. out.flush();
  24. //在子線程中執行業務調用,並由其負責輸出響應,主線程退出
  25. final AsyncContext ctx = req.startAsync();
  26. ctx.setTimeout(200000);
  27. new Work(ctx).start();
  28. out.println("結束Servlet的時間:" + new Date() + ".");
  29. out.flush();
  30. }
  31. }
  32. class Work extends Thread{
  33. private AsyncContext context;
  34. public Work(AsyncContext context){
  35. this.context = context;
  36. }
  37. @Override
  38. public void run() {
  39. try {
  40. Thread.sleep(2000);//讓線程休眠2s鐘模擬超時操作
  41. PrintWriter wirter = context.getResponse().getWriter();
  42. wirter.write("延遲輸出");
  43. wirter.flush();
  44. context.complete();
  45. } catch (InterruptedException e) {
  46. } catch (IOException e) {
  47. }
  48. }
  49. }

有些時候,我們可能需要客戶端和服務器保持長連接的時候,我們可以使用這個特性,讓服務器長時間保持客戶端的請求以及對客戶端的響應,做法如下:

對於異步執行,我們可以添加一個監聽器,監聽異步執行的狀態。

[java] view plain copy print?
  1. ctx.addListener(new AsyncListener() {
  2. @Override
  3. public void onTimeout(AsyncEvent arg0) throws IOException {
  4. // TODO Auto-generated method stub
  5. }
  6. @Override
  7. public void onStartAsync(AsyncEvent arg0) throws IOException {
  8. // TODO Auto-generated method stub
  9. }
  10. @Override
  11. public void onError(AsyncEvent arg0) throws IOException {
  12. // TODO Auto-generated method stub
  13. }
  14. @Override
  15. public void onComplete(AsyncEvent arg0) throws IOException {
  16. // TODO Auto-generated method stub
  17. }
  18. });

在Servlet返回之前,我們可以把持有request和response對象的AsyncContext對象放置到一個全局可訪問的靜態容器中

map.put("id",ctx);

如果連接出錯或者連接完的時候我們可以在onError以及onComplete方法中移除掉對應連接的AsyncContext

map.remove("id",ctx);

在超時的回調方法onTimeout中,我們可以往瀏覽器發送指定的信息,讓客戶端重新發起請求,這樣就可以保持客戶端和服務器的長久連接。

如下服務器和客戶端之間數據交互的模型圖

技術分享

Serlvet 處理http請求並保持長連接