Hi, I've done this just yesterday on tomcat 7.0.50 :)
Be sure to edit your server.xml and set the connector with the special
NIO protocol:
<Connector connectionTimeout="20000" port="8080"
protocol="org.apache.coyote.http11.Http11NioProtocol"
redirectPort="8443"/>
see:
http://tomcat.apache.org/tomcat-7.0-doc/aio.html
Le Fri, 31 Jan 2014 05:22:25 -0800 (PST)
anij <anij0009_at_gmail.com> a dit:
> Hi,
> I'm trying to use the Asynchronous Callback as mentioned in Jersey
> User Guide
> <https://jersey.java.net/documentation/latest/user-guide.html#d0e8496> .
> I'm trying to run this code on Tomcat 7.
>
> *This is my Service:*
> :::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
> /import javax.ws.rs.GET;
> import javax.ws.rs.Path;
> import javax.ws.rs.Produces;
> import javax.ws.rs.container.AsyncResponse;
> import javax.ws.rs.container.CompletionCallback;
> import javax.ws.rs.container.Suspended;
> import javax.ws.rs.core.MediaType;
> import javax.ws.rs.core.Response;
>
> @Path("/resource")
> public class AsyncResource {
> private static int numberOfSuccessResponses = 0;
> private static int numberOfFailures = 0;
> private static Throwable lastException = null;
>
> @GET
> public void asyncGetWithTimeout(@Suspended final AsyncResponse
> asyncResponse) {
> System.out.println("AsyncResource.asyncGetWithTimeout()");
> asyncResponse.register(new CompletionCallback() {
> @Override
> public void onComplete(Throwable throwable) {
> if (throwable == null) {
> // no throwable - the processing ended
> successfully // (response already written to the client)
> numberOfSuccessResponses++;
> } else {
> numberOfFailures++;
> lastException = throwable;
> }
> }
> });
>
> new Thread(new Runnable() {
> @Override
> public void run() {
> String result = veryExpensiveOperation();
> asyncResponse.resume(result);
> }
>
> private String veryExpensiveOperation() {
> // ... very expensive operation
> return "Hi";
> }
> }).start();
> }
> }/
> :::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
>
>
> *This is client:*
> :::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
> /ClientConfig clientConfig = new ClientConfig();
> Client client = ClientBuilder.newClient(clientConfig);
>
> WebTarget webTarget =
> client.target("http://localhost:8080/Jersey2.5Service/rest");
> WebTarget target = webTarget.path("resource");
>
> final AsyncInvoker asyncInvoker = target
> .request().async();
> final Future<Response> responseFuture = asyncInvoker.get();
> System.out.println("Request is being processed asynchronously.");
> final Response response = responseFuture.get();
> // get() waits for the response to be ready
> System.out.println("Response received."
> +response.readEntity(String.class));/
> :::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
>
> *These are the jars I'm using:*
> asm-all-repackaged-2.2.0-b21.jar
> cglib-2.2.0-b21.jar
> guava-14.0.1.jar
> hk2-api-2.2.0-b21.jar
> hk2-locator-2.2.0-b21.jar
> hk2-utils-2.2.0-b21.jar
> javax.annotation-api-1.2.jar
> javax.inject-2.2.0-b21.jar
> javax.servlet-api-3.0.1.jar
> javax.ws.rs-api-2.0.jar
> jaxb-api-2.2.7.jar
> jersey-client.jar
> jersey-common.jar
> jersey-container-servlet-core.jar
> jersey-container-servlet.jar
> jersey-server.jar
> org.osgi.core-4.2.0.jar
> osgi-resource-locator-1.0.1.jar
> persistence-api-1.0.jar
> servlet-api-3.0.jar
> validation-api-1.1.0.Final.jar
>
>
> *And this the error message:*
> :::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
> /Jan 31, 2014 6:48:23 PM
> org.glassfish.jersey.servlet.internal.ResponseWriter suspend
> WARNING: Attempt to put servlet request into asynchronous mode has
> failed. Please check your servlet configuration - all Servlet
> instances and Servlet filters involved in the request processing must
> explicitly declare support for asynchronous request processing.
> java.lang.IllegalStateException: Not supported.
> at
> org.apache.catalina.connector.Request.startAsync(Request.java:1676) at
> org.apache.catalina.connector.RequestFacade.startAsync(RequestFacade.java:1031)
> at
> org.glassfish.jersey.servlet.async.AsyncContextDelegateProviderImpl$ExtensionImpl.suspend(AsyncContextDelegateProviderImpl.java:87)
> at
> org.glassfish.jersey.servlet.internal.ResponseWriter.suspend(ResponseWriter.java:120)
> at
> org.glassfish.jersey.server.ServerRuntime$AsyncResponder.suspend(ServerRuntime.java:758)
> at
> org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:330)
> at
> org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:106)
> at
> org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:259)
> at org.glassfish.jersey.internal.Errors$1.call(Errors.java:271) at
> org.glassfish.jersey.internal.Errors$1.call(Errors.java:267) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:315) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:297) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:267) at
> org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:318)
> at
> org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:236)
> at
> org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:1010)
> at
> org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:373)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:382)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:345)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:220)
> at
> org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
> at
> org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
> at
> org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:51)
> at
> org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:243)
> at
> org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
> at
> org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:222)
> at
> org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:123)
> at
> org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:502)
> at
> org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:171)
> at
> org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:100)
> at
> org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:953)
> at
> org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
> at
> org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:408)
> at
> org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1041)
> at
> org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:603)
> at
> org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:310)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> at java.lang.Thread.run(Unknown Source)
>
> Jan 31, 2014 6:48:23 PM org.apache.catalina.core.StandardWrapperValve
> invoke SEVERE: Servlet.service() for servlet [HelloServlet] in
> context with path [/Jersey2.5Service] threw exception
> [javax.ws.rs.ProcessingException: Attempt to suspend a connection of
> an asynchronous request failed in the underlying container.] with
> root cause javax.ws.rs.ProcessingException: Attempt to suspend a
> connection of an asynchronous request failed in the underlying
> container. at
> org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:331)
> at
> org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:106)
> at
> org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:259)
> at org.glassfish.jersey.internal.Errors$1.call(Errors.java:271) at
> org.glassfish.jersey.internal.Errors$1.call(Errors.java:267) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:315) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:297) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:267) at
> org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:318)
> at
> org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:236)
> at
> org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:1010)
> at
> org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:373)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:382)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:345)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:220)
> at
> org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
> at
> org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
> at
> org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:51)
> at
> org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:243)
> at
> org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
> at
> org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:222)
> at
> org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:123)
> at
> org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:502)
> at
> org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:171)
> at
> org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:100)
> at
> org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:953)
> at
> org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
> at
> org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:408)
> at
> org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1041)
> at
> org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:603)
> at
> org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:310)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> at java.lang.Thread.run(Unknown
> Source)/ :::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
>
>
>
> --
> View this message in context:
> http://jersey.576304.n2.nabble.com/Jersey-2-5-1-How-to-user-Asynchronous-Callback-tp7581884.html
> Sent from the Jersey mailing list archive at Nabble.com.