使用方法ExecutorService.execute()在后台线程中生成一些任务。
应遵循的步骤:
- Read some init parameters from web.xml in servlet init() method such as timeout and threadpoolsize
- timeout参数用于设置Async线程的超时时间
- threadpoolsize 用于创建异步线程池
- 通过在 doGet() 或 doPost() 方法中调用 HTTP request.startAsync() 来获取 AsyncContext
- 设置AsyncContext的超时时间
- 附加侦听器以响应此 AsyncContext 的生命周期事件,例如 onComplete()、onTimeout()、onError()、onStartAsync()
- 调用 ExecutorService.execute() 在后台线程中生成一些任务
尝试这个示例代码。它可能对你有帮助。
AsyncServletTaskProcessor:
import java.io.IOException;
import javax.servlet.AsyncContext;
import javax.servlet.ServletException;
public interface AsyncServletTaskProcessor {
void process(AsyncContext ctx) throws IOException, ServletException;
}
测试服务:
import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import javax.servlet.AsyncContext;
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 = { "/test" }, asyncSupported = true)
public class TestServ extends HttpServlet implements AsyncServletTaskProcessor{
/** The exec. */
private ExecutorService exec;
public int CALLBACK_TIMEOUT;
public void init() throws ServletException {
// read callback timeout form web.xml as init parameter
CALLBACK_TIMEOUT = Integer.parseInt(getInitParameter("timeout"));
// read thread pool size form web.xml as init parameter
int size = Integer.parseInt(getInitParameter("threadpoolsize"));
exec = Executors.newFixedThreadPool(size);
}
@Override
public void doGet(HttpServletRequest rq, HttpServletResponse rs) {
rs.setContentType("text/plain");
rs.setHeader("Access-Control-Allow-Origin", "*");
//AsyncContext asy = rq.startAsync(rq, rs);
//asy.start(new Client(asy));
final AsyncContext asy = rq.startAsync();
// set the timeout
asy.setTimeout(CALLBACK_TIMEOUT);
// attach listener to respond to lifecycle events of this AsyncContext
asy.addListener(new AsyncListenerImpl(asy));
// spawn some task in a background thread
exec.execute(new AsyncServletTaskRunner(asy, this));
}
@Override
public String getServletInfo() {
return "Short description";
}
@Override
public void process(AsyncContext ctx) throws IOException, ServletException {
//do whatever you want to do as process of each thread
}
}
AsyncServletTaskRunner:
import javax.servlet.AsyncContext;
public class AsyncServletTaskRunner implements Runnable {
/** The ctx. */
private AsyncContext ctx;
/** The processor. */
private AsyncServletTaskProcessor processor;
public AsyncServletTaskRunner() {
super();
}
public AsyncServletTaskRunner(AsyncContext ctx, AsyncServletTaskProcessor processor) {
this.ctx = ctx;
this.processor = processor;
}
@Override
public void run() {
try {
processor.process(ctx);
} catch (Exception e) {
try {
// redirect to error page or do whatever is needed
} catch (Exception e1) {
e1.printStackTrace();
}
} finally {
ctx.complete();
}
}
public AsyncContext getCtx() {
return ctx;
}
public void setCtx(AsyncContext ctx) {
this.ctx = ctx;
}
}
异步监听器实现:
import java.io.IOException;
import javax.servlet.AsyncContext;
import javax.servlet.AsyncEvent;
import javax.servlet.AsyncListener;
public class AsyncListenerImpl implements AsyncListener {
/** The ctx. */
private AsyncContext ctx;
public AsyncListenerImpl() {
super();
}
public AsyncListenerImpl(AsyncContext ctx) {
this.ctx = ctx;
}
@Override
public void onComplete(AsyncEvent event) throws IOException {
/** complete() has already been called on the async context, nothing to do */
}
@Override
public void onTimeout(AsyncEvent event) throws IOException {
/** timeout has occured in async task... handle it */
try {
// redirect to error page or do whatever is needed
} catch (Exception e1) {
e1.printStackTrace();
} finally {
ctx.complete();
}
}
@Override
public void onError(AsyncEvent event) throws IOException {
/** THIS NEVER GETS CALLED - error has occured in async task... handle it */
try {
// redirect to error page or do whatever is needed
} catch (Exception e1) {
e1.printStackTrace();
} finally {
ctx.complete();
}
}
@Override
public void onStartAsync(AsyncEvent event) throws IOException {
/** async context has started, nothing to do */
}
}