java - Netty - Reuse Channel for periodic HTTP requests -

-

i want establish connection https server (for example google.com) , periodically obtain fresh content.

i wrote simple http client:

public class asyncloader {     private static final string host = "google.com";     private static final int port = 443;      public static void main(string[] args) throws interruptedexception, ioexception, urisyntaxexception {         final sslcontext sslctx = sslcontextbuilder.forclient().trustmanager(insecuretrustmanagerfactory.instance).build();          eventloopgroup elg = new nioeventloopgroup();         bootstrap cb = new bootstrap()                 .option(channeloption.tcp_nodelay, true)                 .option(channeloption.so_keepalive, true)                 .option(channeloption.so_reuseaddr, false)                 .option(channeloption.allocator, pooledbytebufallocator.default)                 .group(elg)                 .channel(niosocketchannel.class)                 .remoteaddress(host, port)                 .handler(new channelinitializer<socketchannel>() {                     @override                     protected void initchannel(socketchannel ch) throws exception {                         ch.pipeline()                                 .addlast("ssl", new sslhandler(sslctx.newengine(ch.alloc())))                                 .addlast("http", new httpclientcodec(4096, 8192, 8192, true, true))                                 .addlast("simple", new simplechannelinboundhandler<httpobject>() {                                     @override                                     public void channelactive(channelhandlercontext ctx) throws exception { //                                        ctx.writeandflush(createreq());                                     }                                      @override                                     protected void channelread0(channelhandlercontext ctx, httpobject msg) throws exception {                                         system.out.println(msg); //                                        ctx.writeandflush(createreq());                                     }                                 })                                 .addlast(new logginghandler());                     }                 });          channel channel = cb.connect().sync().channel();          channel.write(createreq());         thread.sleep(1000l);         channel.write(createreq());     }      private static defaultfullhttprequest createreq() throws urisyntaxexception {         defaultfullhttprequest requestcopy = new defaultfullhttprequest(httpversion.http_1_1, httpmethod.get,                 new uri("/").toasciistring());         httpheaders headerscopy = requestcopy.headers();         headerscopy.set(httpheadernames.host, host);         headerscopy.set(httpheadernames.connection, httpheadervalues.keep_alive);         return requestcopy;     } }

at end of main method send 2 http requests 1 second delay. server responds on first request, not on second...

i've enabled detail logging:

fine: -dio.netty.recycler.maxcapacity.maxcapacity: 262144 jan 28, 2016 4:32:30 pm io.netty.handler.logging.logginghandler write   fine: [id: 0x2baa7120, /172.21.222.178:32972 => google.com/173.194.220.138:443] write, defaultfullhttprequest(decoderesult: success, version: http/1.1, content: unpooledunsafeheapbytebuf(ridx: 0, widx: 0, cap: 0)) / http/1.1 host: google.com connection: keep-alive, 0b   jan 28, 2016 4:32:30 pm io.netty.handler.ssl.util.insecuretrustmanagerfactory$1 checkservertrusted fine: accepting server certificate: cn=*.google.com, o=google inc, l=mountain view, st=california, c=us jan 28, 2016 4:32:30 pm io.netty.handler.ssl.ciphersuiteconverter cachefromopenssl fine: cipher suite mapping: tls_ecdhe_rsa_with_aes_128_gcm_sha256 => ecdhe-rsa-aes128-gcm-sha256 jan 28, 2016 4:32:30 pm io.netty.handler.ssl.ciphersuiteconverter cachefromopenssl fine: cipher suite mapping: ssl_ecdhe_rsa_with_aes_128_gcm_sha256 => ecdhe-rsa-aes128-gcm-sha256 jan 28, 2016 4:32:30 pm io.netty.handler.ssl.sslhandler sethandshakesuccess fine: [id: 0x2baa7120, /172.21.222.178:32972 => google.com/173.194.220.138:443] handshaken: tls_ecdhe_rsa_with_aes_128_gcm_sha256 jan 28, 2016 4:32:30 pm io.netty.handler.logging.logginghandler usereventtriggered fine: [id: 0x2baa7120, /172.21.222.178:32972 => google.com/173.194.220.138:443] user_event: sslhandshakecompletionevent(success)   defaulthttpresponse(decoderesult: success, version: http/1.1) http/1.1 302 found location: https://ipv4.google.com/sorry/indexredirect?continue=https://google.com/&q=cgmsbfuxuysy7rcotquigqdxp4nlp1t70jloofxaotbiyimcgkkrqxe date: thu, 28 jan 2016 13:32:31 gmt pragma: no-cache expires: fri, 01 jan 1990 00:00:00 gmt cache-control: no-store, no-cache, must-revalidate, post-check=0, pre-check=0 content-type: text/html; charset=utf-8 server: http server (unknown) content-length: 331 x-xss-protection: 1; mode=block x-frame-options: sameorigin alternate-protocol: 443:quic,p=1 alt-svc: quic=":443"; ma=604800; v="30,29,28,27,26,25" defaultlasthttpcontent(data: slicedabstractbytebuf(ridx: 0, widx: 331, cap: 331/331, unwrapped: pooledunsafedirectbytebuf(ridx: 913, widx: 913, cap: 942)), decoderresult: success)   jan 28, 2016 4:32:32 pm io.netty.handler.logging.logginghandler write   fine: [id: 0x2baa7120, /172.21.222.178:32972 => google.com/173.194.220.138:443] write, defaultfullhttprequest(decoderesult: success, version: http/1.1, content: unpooledunsafeheapbytebuf(ridx: 0, widx: 0, cap: 0)) / http/1.1 host: google.com connection: keep-alive, 0b  jan 28, 2016 4:36:31 pm io.netty.handler.logging.logginghandler channelinactive fine: [id: 0x2baa7120, /172.21.222.178:32972 :> google.com/173.194.220.138:443] inactive jan 28, 2016 4:36:31 pm io.netty.handler.logging.logginghandler exceptioncaught fine: [id: 0x2baa7120, /172.21.222.178:32972 :> google.com/173.194.220.138:443] exception: io.netty.handler.codec.prematurechannelclosureexception: channel gone inactive 1 missing response(s) io.netty.handler.codec.prematurechannelclosureexception: channel gone inactive 1 missing response(s)     @ io.netty.handler.codec.http.httpclientcodec$decoder.channelinactive(httpclientcodec.java:228)     @ io.netty.channel.combinedchannelduplexhandler.channelinactive(combinedchannelduplexhandler.java:213)     @ io.netty.channel.channelhandlerinvokerutil.invokechannelinactivenow(channelhandlerinvokerutil.java:56)     @ io.netty.channel.defaultchannelhandlerinvoker.invokechannelinactive(defaultchannelhandlerinvoker.java:93)     @ io.netty.channel.abstractchannelhandlercontext.firechannelinactive(abstractchannelhandlercontext.java:133)     @ io.netty.handler.codec.bytetomessagedecoder.channelinactive(bytetomessagedecoder.java:332)     @ io.netty.handler.ssl.sslhandler.channelinactive(sslhandler.java:724)     @ io.netty.channel.channelhandlerinvokerutil.invokechannelinactivenow(channelhandlerinvokerutil.java:56)     @ io.netty.channel.defaultchannelhandlerinvoker.invokechannelinactive(defaultchannelhandlerinvoker.java:93)     @ io.netty.channel.abstractchannelhandlercontext.firechannelinactive(abstractchannelhandlercontext.java:133)     @ io.netty.channel.defaultchannelpipeline.firechannelinactive(defaultchannelpipeline.java:895)     @ io.netty.channel.abstractchannel$abstractunsafe$7.run(abstractchannel.java:719)     @ io.netty.util.concurrent.singlethreadeventexecutor.runalltasks(singlethreadeventexecutor.java:339)     @ io.netty.channel.nio.nioeventloop.run(nioeventloop.java:356)     @ io.netty.util.concurrent.singlethreadeventexecutor$5.run(singlethreadeventexecutor.java:742)     @ io.netty.util.concurrent.defaultthreadfactory$defaultrunnabledecorator.run(defaultthreadfactory.java:137)     @ java.lang.thread.run(thread.java:745)

as can see, server replied on first request , ignored second request.

but if remove:

channel.write(createreq()); thread.sleep(1000l); channel.write(createreq());

and uncomment code inside channelinitializer:

.addlast("simple", new simplechannelinboundhandler<httpobject>() {     @override     public void channelactive(channelhandlercontext ctx) throws exception {         ctx.writeandflush(createreq());     }      @override     protected void channelread0(channelhandlercontext ctx, httpobject msg) throws exception {         system.out.println(msg);         ctx.writeandflush(createreq());     }  })

everything work flying colours , i've got expected:

defaulthttpresponse(decoderesult: success, version: http/1.1) http/1.1 302 found location: https://ipv4.google.com/sorry/indexredirect?continue=https://google.com/&q=cgmsbfuxuysyprsotquigqdxp4nlfkyg4_x9zrf5oyzq5oluqegr-54 date: thu, 28 jan 2016 13:39:50 gmt pragma: no-cache expires: fri, 01 jan 1990 00:00:00 gmt cache-control: no-store, no-cache, must-revalidate, post-check=0, pre-check=0 content-type: text/html; charset=utf-8 server: http server (unknown) content-length: 331 x-xss-protection: 1; mode=block x-frame-options: sameorigin alternate-protocol: 443:quic,p=1 alt-svc: quic=":443"; ma=604800; v="30,29,28,27,26,25" defaultlasthttpcontent(data: slicedabstractbytebuf(ridx: 0, widx: 331, cap: 331/331, unwrapped: pooledunsafedirectbytebuf(ridx: 913, widx: 913, cap: 942)), decoderresult: success) defaulthttpresponse(decoderesult: success, version: http/1.1) http/1.1 302 found location: https://ipv4.google.com/sorry/indexredirect?continue=https://google.com/&q=cgmsbfuxuysyprsotquigqdxp4nlfkyg4_x9zrf5oyzq5oluqegr-54 date: thu, 28 jan 2016 13:39:51 gmt pragma: no-cache expires: fri, 01 jan 1990 00:00:00 gmt cache-control: no-store, no-cache, must-revalidate, post-check=0, pre-check=0 content-type: text/html; charset=utf-8 server: http server (unknown) content-length: 331 x-xss-protection: 1; mode=block x-frame-options: sameorigin alternate-protocol: 443:quic,p=1 alt-svc: quic=":443"; ma=604800; v="30,29,28,27,26,25" defaultlasthttpcontent(data: slicedabstractbytebuf(ridx: 0, widx: 331, cap: 331/331, unwrapped: pooledunsafedirectbytebuf(ridx: 913, widx: 913, cap: 942)), decoderresult: success)

what's problem? can't write channel outside netty's callback methods?

when using netty,it important make sure every call write() followed call flush(), when write channel, write without flushing, causing data stay in memory of program, , not being send out.

change call write() writeandflush().


Comments

Post a Comment

Popular posts from this blog

Hatching array of circles in AutoCAD using c# -

-
i beginner in autocad plugins .i have created array of circle using following code. now, have hatch circles in array .how that??how hatch circles @ once? moreover, how can return hatch method , use hatch objects.sorry language.thanks in advance. [assembly: commandclass(typeof(beamsection.class1))] namespace beamsection { public class class1 { //class1 obj = new class1(); [commandmethod("beamatsupport")] public void addlightweightpolyline() { // current document , database document acdoc = application.documentmanager.mdiactivedocument; database accurdb = acdoc.database; promptpointresult ppr = acdoc.editor.getpoint("\nselect starting point "); var ucs = acdoc.editor.currentusercoordinatesystem; point3d startingpt = ppr.value.transformby(ucs); list<double> radius = new list<double>(); radius.add(0.5);
Read more

ios - UITEXTFIELD InputView Uipicker not working in swift -

-
hello trying pop uipickerview view programmatically when user clicks on textfield. have tried doesn't doing anything. isn't working. nothing happening when click textfield class userprofiletableviewcontroller: uitableviewcontroller,uitextfielddelegate,uipickerviewdelegate,uipickerviewdatasource { var itempicker: uipickerview! = uipickerview() @iboutlet weak var gendertxtfield: uitextfield! var gender = ["male","female"] override func viewdidload() { super.viewdidload() gendertxtfield.delegate = self itempicker!.delegate = self itempicker!.datasource = self itempicker!.backgroundcolor = uicolor.blackcolor() self.gendertxtfield.inputview = itempicker } func numberofcomponentsinpickerview(pickerview: uipickerview) -> int{ return 1 } // returns # of rows in each component.. func pickerview(pickerview: uipickerview, numberofrowsincomponent component:
Read more

Python Pig Latin Translator -

-
so have been working on @ codecademy.com while trying learn python. don't know if blind , can't see why won't work or what. here's code won't let me use. function print variable if had typed in , print "empty" if didn't type anything. print "welcome english pig latin translator!" original = raw_input("what's name?") if len(original) > 0 print original else print "empty" if len(original) > 0 else the above lines contains syntax errors. try: if len(original) > 0: else: note added colons, ( : ).
Read more