Examples of javax.servlet.AsyncContext.dispatch()

javax.servlet.AsyncContext.dispatch()
EST dispatch to /url/A AsyncContext ac = request.startAsync(); ... ac.dispatch(); // ASYNC dispatch to /url/A // FORWARD dispatch to /url/B getRequestDispatcher("/url/B").forward(request,response); // Start async operation from within the target of the FORWARD // dispatch ac = request.startAsync(); ... ac.dispatch(); // ASYNC dispatch to /url/A // FORWARD dispatch to /url/B getRequestDispatcher("/url/B").forward(request,response); // Start async operation from within the target of the FORWARD // dispatch ac = request.startAsync(request,response); ... ac.dispatch(); // ASYNC dispatch to /url/B
This method returns immediately after passing the request and response objects to a container managed thread, on which the dispatch operation will be performed.
The dispatcher type of the request is set to DispatcherType.ASYNC. Unlike {@link RequestDispatcher#forward(ServletRequest,ServletResponse) forward dispatches}, the response buffer and headers will not be reset, and it is legal to dispatch even if the response has already been committed.
Control over the request and response is delegated to the dispatch target, and the response will be closed when the dispatch target has completed execution, unless {@link ServletRequest#startAsync()} or{@link ServletRequest#startAsync(ServletRequest,ServletResponse)}are called.
Any errors or exceptions that may occur during the execution of this method must be caught and handled by the container, as follows:
1. Invoke, at their {@link AsyncListener#onError onError} method, all{@link AsyncListener} instances registered with the ServletRequestfor which this AsyncContext was created, and make the caught Throwable available via {@link AsyncEvent#getThrowable}.
2. If none of the listeners called {@link #complete} or any of the{@link #dispatch} methods, perform an error dispatch with a status codeequal to HttpServletResponse.SC_INTERNAL_SERVER_ERROR, and make the above Throwable available as the value of the RequestDispatcher.ERROR_EXCEPTION request attribute.
3. If no matching error page was found, or the error page did not call {@link #complete} or any of the {@link #dispatch} methods, call{@link #complete}.
There can be at most one asynchronous dispatch operation per asynchronous cycle, which is started by a call to one of the {@link ServletRequest#startAsync} methods. Any attempt to perform anadditional asynchronous dispatch operation within the same asynchronous cycle will result in an IllegalStateException. If startAsync is subsequently called on the dispatched request, then any of the dispatch or {@link #complete} methods may be called. @throws IllegalStateException if one of the dispatch methodshas been called and the startAsync method has not been called during the resulting dispatch, or if {@link #complete}was called @see ServletRequest#getDispatcherType


                @Override
                public void run() {
                    // This should be delayed until the original container
                    // thread exists
                    async.dispatch("/ServletB");
                }
            });


            try {
                Thread.sleep(3000);

View Full Code Here

                    TestAsyncContextImpl.track("Complete-");
                    ctxt.complete();
                    break;
                case DISPATCH:
                    TestAsyncContextImpl.track("Dispatch-");
                    ctxt.dispatch("/error/nonasync");
                    break;
                case NO_COMPLETE:
                    TestAsyncContextImpl.track("NoOp-");
                    break;
                default:

View Full Code Here

                            new ServletResponseWrapper(resp));
                } else {
                    asyncContext = req.startAsync();
                }
                if ("y".equals(req.getParameter(EMPTY_DISPATCH))) {
                    asyncContext.dispatch();
                } else {
                    asyncContext.dispatch("/target");
                }
                try {
                    asyncContext.dispatch("/nonExistingServlet");

View Full Code Here

                    asyncContext = req.startAsync();
                }
                if ("y".equals(req.getParameter(EMPTY_DISPATCH))) {
                    asyncContext.dispatch();
                } else {
                    asyncContext.dispatch("/target");
                }
                try {
                    asyncContext.dispatch("/nonExistingServlet");
                    TestAsyncContextImpl.track("FAIL");
                } catch (IllegalStateException e) {

View Full Code Here

                    asyncContext.dispatch();
                } else {
                    asyncContext.dispatch("/target");
                }
                try {
                    asyncContext.dispatch("/nonExistingServlet");
                    TestAsyncContextImpl.track("FAIL");
                } catch (IllegalStateException e) {
                    TestAsyncContextImpl.track("OK");
                }
            } else {

View Full Code Here

        });


        System.out.println("====filter servlet 1  before dispatch");
        //异步下分派过去的请求，异步filter也可以拦截
        //如果filter不是DispatcherType.ASYNC 类型，那么分派到/filter2时，拦截器不会调用
        asyncContext.dispatch("/filter2");
        System.out.println("====filter servlet 1  after dispatch");


        System.out.println("====filter servlet 1  after");

View Full Code Here

            }
        });


        System.out.println("====filter servlet 2  before dispatch");
        req.setAttribute("msg", "success");
        asyncContext.dispatch("/WEB-INF/jsp/dispatch.jsp");
        System.out.println("====filter servlet 2  after dispatch");


        System.out.println("====filter servlet 2  after");

View Full Code Here

            @Override
            public void onStartAsync(final AsyncEvent event) throws IOException {
                System.out.println("=====start new async");
            }
        });
        asyncContext.dispatch("/error"); //分派到一个不存在的地址 会报404，但是最终服务器会调用onComplete来完成异步
    }
}

View Full Code Here

                    Thread.sleep(3L * 1000);
                } catch (InterruptedException e) {
                }
                req.setAttribute("ok", "true");
                req.setAttribute("msg", "success");
                asyncContext.dispatch("/WEB-INF/jsp/dispatch.jsp");
            }
        }).start();


    }
}

View Full Code Here

                        Thread.sleep(3L * 1000);
                    } catch (InterruptedException e) {
                    }
                    req.setAttribute("ok", "true");
                    req.setAttribute("msg", "success");
                    asyncContext.dispatch();
                    System.out.println("===after dispatch before handle:" + req.isAsyncStarted());
                }
            }).start();


            return;

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.