java - How to close AsyncHttpClient with Netty for an asynchronous Http request? -

-

using asynchttpclient netty provider prevent main program terminate when execute asynchronous request. instance, following program terminates after println, or not, depending on whether provider jdkasynchttpprovider or nettyasynchttpprovider:

public class program {     public static completablefuture<response> getdataasync(string uri) {         final asynchttpclient asynchttpclient = new asynchttpclient();         final completablefuture<response> promise = new completablefuture<>();         asynchttpclient             .prepareget(uri)             .execute(new asynccompletionhandler<response>(){                 @override                 public response oncompleted(response resp) throws exception {                     promise.complete(resp);                     asynchttpclient.close(); // ??? correct ????                     return resp;                 }             });         return promise;     }      public static void main(string [] args) throws exception {         final string uri = "…";         system.out.println(getdataasync(uri).get());     } }

about asynhttpclient documentation states:

ahc abstraction layer can work on top of bare jdk, netty , grizzly. note jdk implementation limited , should use other real providers.

to use asynchttpclient netty need include corresponding library in java class path. so, may run previous program 1 of following class path configurations use netty, or not:

  • -cp .;async-http-client-1.9.24.jar;netty-3.10.3.final.jar;slf4j-api-1.7.12.jar use nettyasynchttpprovider
  • -cp .;async-http-client-1.9.24.jar;slf4j-api-1.7.12.jar use jdkasynchttpprovider

what else should use netty provider correctly? instance, closing asynchttpclient in asynccompletionhandler. correct?

is there configuration change observed behavior?

using netty provider , stepping through in debugger, see calling asynchttpclient.close() inside callback causes niosocketchannelfactory.releaseexternalresources() fail when tries shutdown. exception thrown, , causing non daemon thread remain, , keeping vm exiting. exception thrown logged @ warn, you're not seeing (if add slf4j-log4j12-1.7.7.jar classpath should see it). can't call close() in call (and don't need close after every request execution anyhow).

here's trace:

 warn [new i/o worker #1] (nettyasynchttpprovider.java:79) - unexpected error on close java.lang.illegalstateexception: must not called i/o-thread prevent deadlocks! @ org.jboss.netty.channel.socket.nio.abstractnioselector.shutdown(abstractnioselector.java:415) @ org.jboss.netty.channel.socket.nio.nioworker.shutdown(nioworker.java:36) @ org.jboss.netty.channel.socket.nio.abstractnioworkerpool.shutdown(abstractnioworkerpool.java:142) @ org.jboss.netty.channel.socket.nio.nioclientsocketchannelfactory.releaseexternalresources(nioclientsocketchannelfactory.java:225) @ com.ning.http.client.providers.netty.channel.channelmanager.close(channelmanager.java:355) @ com.ning.http.client.providers.netty.nettyasynchttpprovider.close(nettyasynchttpprovider.java:70) @ com.ning.http.client.asynchttpclient.close(asynchttpclient.java:336) @ com.cie.program.program$1.oncompleted(program.java:23)

Comments

Post a Comment

Popular posts from this blog

Java 3D LWJGL collision -

-
i making 3d java game lwjgl library, , wondering how add collision detection, player not go through models. i using obj models. here objloader class, loads models: package renderengine; import java.io.bufferedreader; import java.io.file; import java.io.filenotfoundexception; import java.io.filereader; import java.util.arraylist; import java.util.list; import models.rawmodel; import org.lwjgl.util.vector.vector2f; import org.lwjgl.util.vector.vector3f; public class objloader { public static rawmodel loadobjmodel(string filename, loader loader){ filereader fr = null; try { fr = new filereader(new file("res/"+filename+".obj")); } catch (filenotfoundexception e) { system.err.println("couldn't load file!"); e.printstacktrace(); } bufferedreader reader = new bufferedreader(fr); string line; list<vector3f> vertices = new arraylist<vector3f...
Read more

spring - SubProtocolWebSocketHandler - No handlers -

-
i have ugly error during deploying spring app on jboss. 18:11:16,025 error [org.apache.catalina.core.containerbase.[jboss.web].[default-host].[/consumer]] (msc service thread 1-7) exception sending context initialized event listener instance of class org.springframework.web.context.contextloaderlistener: org.springframework.context.applicationcontextexception: failed start bean 'subprotocolwebsockethandler'; nested exception java.lang.illegalargumentexception: no handlers @ org.springframework.context.support.defaultlifecycleprocessor.dostart(defaultlifecycleprocessor.java:176) [spring-context-4.1.3.release.jar:4.1.3.release] @ org.springframework.context.support.defaultlifecycleprocessor.access$200(defaultlifecycleprocessor.java:51) [spring-context-4.1.3.release.jar:4.1.3.release] @ org.springframework.context.support.defaultlifecycleprocessor$lifecyclegroup.start(defaultlifecycleprocessor.java:346) [spring-context-4.1.3.release.jar:4.1.3.release] @ org.s...
Read more

methods - python can't use function in submodule -

-
my folder structure this: pythonstuff/ program.py modulea/ __init__.py foo.py bar.py here's code bar.py : def hello(): print("hello, world!") here's code program.py : #!/usr/bin/env python3 modulea import bar bar.hello() i run $ python3 program.py somehow error: file "program.py", line 3, in <module> bar.hello() attributeerror: 'module' object has no attribute 'hello' edit: __init__.py file empty. edit2: after trying realized had bar.py in root directory contained hello() method. bar.py in modulea/ directory empty. add it import os __all__ = [] module in os.listdir(os.path.dirname(__file__)): if module != '__init__.py' , module[-3:] == '.py': __all__.append(module[:-3]) the init .py files required make python treat directories containing packages; done prevent directories common name, such string, unintentionally hiding v...
Read more