最近，在研究异步处理时Servlets，我至少遇到了三种实现方法
使用这种方法的一些功能。
问题是：
- 哪一个是最好的？
- 也许其中一些方法不推荐？
- 也许还有另一种方法比下面提到的所有方法更好？
找到的方法：
-
Using AsyncContext.start(Runnable).
这种方法非常简单明了。但是许多服务器在为创建的线程池中执行这样的作业HTTP要求
（更多相关信息在这里http://www.nurkiewicz.com/2012/05/javaxservletservletrequeststartasync.html http://www.nurkiewicz.com/2012/05/javaxservletservletrequeststartasync.html)
-
使用在 Servlet 上下文初始化期间创建的自定义线程池
（示例在这里：http://www.journaldev.com/2008/async-servlet-feature-of-servlet-3 http://www.journaldev.com/2008/async-servlet-feature-of-servlet-3）。
但是我可以在 Servlet 容器中创建自己的线程吗？不推荐（甚至禁止）EJB（前JavaEE7）。
我可以用吗JavaSE执行者还是我应该使用ManagedExecutors from JavaEE7（假设我使用JavaEE7)?
-
Using EJB and @Asynchronious注解
（这里的例子：https://github.com/wildfly/quickstart/tree/master/servlet-async/src/main/java/org/jboss/as/quickstarts/servlet/async https://github.com/wildfly/quickstart/tree/master/servlet-async/src/main/java/org/jboss/as/quickstarts/servlet/async）。
但在这里我无法控制执行任务的线程（即应该创建多少线程等）
我很高兴听到您对这个问题的想法以及您的经验AsyncContext.
所有线程都将具有相同的性能，在后端，所有线程都将请求处理线程替换为另一个线程，以便可以服务更多请求。
您将在下面找到一个简单的实现：
@WebServlet(urlPatterns = "/AsyncLongRunningServlet", asyncSupported = true)
public class AsyncLongRunningServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
System.out.println("Request Processing Thread "+Thread.currentThread().getName());
request.setAttribute("org.apache.catalina.ASYNC_SUPPORTED", true);
response.setContentType("text/html");
PrintWriter printWriter=response.getWriter();
printWriter.println("<html><head><title>Asynchronous servlet</title></head><body>");
printWriter.println("Request Processing Thread "+Thread.currentThread().getName());
printWriter.println("<br>");
printWriter.println("<progress id='progress' max='100')></progress>");
printWriter.println("<br>");
AsyncContext asyncCtx = request.startAsync();
asyncCtx.addListener(new AppAsyncListener());
asyncCtx.setTimeout(12000);
//release of request processing thread
asyncCtx.start(() ->{
printWriter.println("<br>");
printWriter.println("Async thread Name "+Thread.currentThread().getName());
printWriter.println("<br>");
int i=0;
while(i<100)
{
printWriter.println("<script>document.getElementById('progress').value=\""+i+"\";</script>");
printWriter.flush();
try {
Thread.sleep(100);
} catch (Exception e) {
}
i++;
}
printWriter.println("</body></html>");
asyncCtx.complete();
}
);
printWriter.println("<br>");
printWriter.println("End of response");
}
}
package com.journaldev.servlet.async;
import java.io.IOException;
import java.io.PrintWriter;
import javax.servlet.AsyncEvent;
import javax.servlet.AsyncListener;
import javax.servlet.ServletResponse;
import javax.servlet.annotation.WebListener;
@WebListener
public class AppAsyncListener implements AsyncListener {
@Override
public void onComplete(AsyncEvent asyncEvent) throws IOException {
System.out.println("AppAsyncListener onComplete");
// we can do resource cleanup activity here
}
@Override
public void onError(AsyncEvent asyncEvent) throws IOException {
System.out.println("AppAsyncListener onError");
//we can return error response to client
}
@Override
public void onStartAsync(AsyncEvent asyncEvent) throws IOException {
System.out.println("AppAsyncListener onStartAsync");
//we can log the event here
}
@Override
public void onTimeout(AsyncEvent asyncEvent) throws IOException {
System.out.println("AppAsyncListener onTimeout");
//we can send appropriate response to client
ServletResponse response = asyncEvent.getAsyncContext().getResponse();
PrintWriter out = response.getWriter();
out.write("TimeOut Error in Processing");
}
}
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
