Serlvet 處理http請求並保持長連接
一.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?
- import java.io.IOException;
- import java.io.PrintWriter;
- import java.util.Date;
- import javax.servlet.AsyncContext;
- import javax.servlet.AsyncEvent;
- import javax.servlet.AsyncListener;
- import javax.servlet.ServletException;
- import javax.servlet.annotation.WebServlet;
- import javax.servlet.http.HttpServlet;
- import javax.servlet.http.HttpServletRequest;
- import javax.servlet.http.HttpServletResponse;
- @WebServlet(urlPatterns="/demo", asyncSupported=true)
- public class AsynServlet extends HttpServlet {
- private static final long serialVersionUID = -8016328059808092454L;
- /* (non-Javadoc)
- * @see javax.servlet.http.HttpServlet#service(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse)
- */
- @Override
- protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
- resp.setContentType("text/html;charset=UTF-8");
- PrintWriter out = resp.getWriter();
- out.println("進入Servlet的時間:" + new Date() + ".");
- out.flush();
- //在子線程中執行業務調用,並由其負責輸出響應,主線程退出
- final AsyncContext ctx = req.startAsync();
- ctx.setTimeout(200000);
- new Work(ctx).start();
- out.println("結束Servlet的時間:" + new Date() + ".");
- out.flush();
- }
- }
- class Work extends Thread{
- private AsyncContext context;
- public Work(AsyncContext context){
- this.context = context;
- }
- @Override
- public void run() {
- try {
- Thread.sleep(2000);//讓線程休眠2s鐘模擬超時操作
- PrintWriter wirter = context.getResponse().getWriter();
- wirter.write("延遲輸出");
- wirter.flush();
- context.complete();
- } catch (InterruptedException e) {
- } catch (IOException e) {
- }
- }
- }
有些時候,我們可能需要客戶端和服務器保持長連接的時候,我們可以使用這個特性,讓服務器長時間保持客戶端的請求以及對客戶端的響應,做法如下:
對於異步執行,我們可以添加一個監聽器,監聽異步執行的狀態。
[java] view plain copy print?- ctx.addListener(new AsyncListener() {
- @Override
- public void onTimeout(AsyncEvent arg0) throws IOException {
- // TODO Auto-generated method stub
- }
- @Override
- public void onStartAsync(AsyncEvent arg0) throws IOException {
- // TODO Auto-generated method stub
- }
- @Override
- public void onError(AsyncEvent arg0) throws IOException {
- // TODO Auto-generated method stub
- }
- @Override
- public void onComplete(AsyncEvent arg0) throws IOException {
- // TODO Auto-generated method stub
- }
- });
在Servlet返回之前,我們可以把持有request和response對象的AsyncContext對象放置到一個全局可訪問的靜態容器中
map.put("id",ctx);
如果連接出錯或者連接完的時候我們可以在onError以及onComplete方法中移除掉對應連接的AsyncContext
map.remove("id",ctx);
在超時的回調方法onTimeout中,我們可以往瀏覽器發送指定的信息,讓客戶端重新發起請求,這樣就可以保持客戶端和服務器的長久連接。
如下服務器和客戶端之間數據交互的模型圖
Serlvet 處理http請求並保持長連接