updated

updated

Author: hmkcode

java-async-servlet/src/main/java/com/hmkcode/AsyncServlet.java

@@ -15,16 +15,25 @@
 @WebServlet(name="asyncServlet",value = {"/async"},asyncSupported = true)
 public class AsyncServlet extends HttpServlet 
 {
+	public static int index = 0;
+	
+	public AsyncServlet(){
+		System.out.println("AsyncServlet - "+index++);
+	}
 
 private static final long serialVersionUID = 1L;
 
+String param ="";
   @Override
 	protected void doGet(HttpServletRequest req, HttpServletResponse resp)
 		throws ServletException, IOException {
 
+	  
 	   final AsyncContext ctx = req.startAsync();
+	   param = ctx.getRequest().getParameter("seq");
+	  
 
-	   ctx.setTimeout(3000);
+	   ctx.setTimeout(0);
 
 	   ctx.addListener(new AsyncListener() {
 
@@ -49,19 +58,25 @@ public void onComplete(AsyncEvent arg0) throws IOException {
 			}
 	   });
 
-	   
 	   ctx.start(new Runnable() {
 			@Override
 			public void run() {
-				// TODO Auto-generated method stub
 				 try {
-					ctx.getResponse().getWriter().write("Async Started...");
+					
+					 
+					  while(!param.equals("exit")){
+						  
+					  }
+					  ctx.getResponse().getWriter().write(ctx.getRequest().getParameter("seq"));
+					  
 				} catch (IOException e) {
 					e.printStackTrace();
 				}
 
 			 ctx.complete();
 			}
+			
+			
 	   });
    }
 }

java-async-servlet/src/main/java/com/hmkcode/SyncServlet.java

@@ -0,0 +1,41 @@
+package com.hmkcode;
+
+import java.io.IOException;
+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(name="syncServlet",value = {"/sync"})
+public class SyncServlet extends HttpServlet 
+{
+	public static int index = 0;
+	
+	public SyncServlet(){
+		System.out.println("SyncServlet - "+index++);
+	}
+   
+private static final long serialVersionUID = 1L;
+
+  @Override
+	protected void doGet(HttpServletRequest req, HttpServletResponse resp)
+		throws ServletException, IOException {
+	   
+	  
+	  String seq = req.getParameter("seq");
+
+	  try {
+		  Thread.sleep(50 * Integer.parseInt(seq));
+	  } catch (NumberFormatException e) {
+		  e.printStackTrace();
+	  } catch (InterruptedException e) {
+		  e.printStackTrace();
+	  }
+	  resp.getWriter().write(seq);
+
+	   
+	  
+   }
+}

java-async-servlet/src/main/webapp/WEB-INF/web.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
+xmlns="http://java.sun.com/xml/ns/javaee" 
+xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" 
+xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" 
+id="WebApp_ID" version="3.0">
+  <display-name>java async servlet</display-name>
+  <welcome-file-list>
+    <welcome-file>index.html</welcome-file>
+  </welcome-file-list>
+  
+</web-app>