Writing a ChannelBuffer to a Netty Channel throws java.io.NotSerializableException -


i want write raw bytes netty channel. thought first creating channelbuffer, filling bytes (coming from, say, kryo serializer), , writing channelbuffer netty channel.

here relevant code, i'm filling bytes channelbuffer in ctor , trying send upon connection:

/**  * handler implementation object echo client.  initiates  * ping-pong traffic between object echo client , server sending  * first message server.  */ public class objectechoclienthandler extends simplechannelupstreamhandler {  private final channelbuffer firstmessage;  /**  * creates client-side handler.  */ public objectechoclienthandler(int firstmessagesize) {     if (firstmessagesize <= 0) {         throw new illegalargumentexception(                 "firstmessagesize: " + firstmessagesize);     }     firstmessage = channelbuffers.buffer(8192);     (int = 0; < firstmessagesize; i++) {         firstmessage.writebyte(i % 256);     } }  @override public void channelconnected(         channelhandlercontext ctx, channelstateevent e) {      // send first message if handler client-side handler.     // e.getchannel().write(firstmessage);     channels.write(ctx, e.getfuture(), firstmessage); }  }

this doesn't seem work, throws exception:

java.io.notserializableexception: org.jboss.netty.buffer.bigendianheapchannelbuffer @ java.io.objectoutputstream.writeobject0(objectoutputstream.java:1164) @ java.io.objectoutputstream.writeobject(objectoutputstream.java:330) @ org.jboss.netty.handler.codec.serialization.objectencoder.encode(objectencoder.java:80) @ org.jboss.netty.handler.codec.oneone.onetooneencoder.handledownstream(onetooneencoder.java:61) @ org.jboss.netty.channel.channels.write(channels.java:626) @ org.jboss.netty.channel.channels.write(channels.java:587) @ ca.gsimard.spacecraft.client.objectechoclienthandler.channelconnected(objectechoclienthandler.java:83) @ ca.gsimard.spacecraft.client.objectechoclienthandler.handleupstream(objectechoclienthandler.java:75) @ org.jboss.netty.channel.channels.firechannelconnected(channels.java:227) @ org.jboss.netty.channel.socket.nio.nioworker$registertask.run(nioworker.java:784) @ org.jboss.netty.channel.socket.nio.nioworker.processregistertaskqueue(nioworker.java:250) @ org.jboss.netty.channel.socket.nio.nioworker.run(nioworker.java:192) @ java.util.concurrent.threadpoolexecutor$worker.runtask(threadpoolexecutor.java:886) @ java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor.java:908) @ java.lang.thread.run(thread.java:662)

i'm sure dead trivial , wrong way of doing it, because can't seem find had same error this. i'm using netty 3.3.0 right now.

i can work creating sized byte[] , copying contents of channelbuffer it, have liked more direct solution avoids useless byte copying.

    byte[] array = new byte[firstmessage.writerindex()];     firstmessage.readbytes(array);     e.getchannel().write(array);

thanks pointers !

looking @ stack trace, observed these 2 lines:

at org.jboss.netty.handler.codec.serialization.objectencoder.encode(objectencoder.java:80) @ org.jboss.netty.handler.codec.oneone.onetooneencoder.handledownstream(onetooneencoder.java:61

what means me pipeline contains objectencoder attempting serialize channelbuffer. since objects have been encoded kryo, don't need objectencoder.

or put differently (without kryo), channelbuffer should output of objectencoder , object should input.

your best bet write new channelhandler uses kryo encode objects. may find added efficiencies when kryo it's job handler in netty pipeline.


Comments

Post a Comment

Popular posts from this blog

java - Play! framework 2.0: How to display multiple image? -

i need display gallery of photos. here template: @(photos: list[photo]) @title = { <bold>gallery</bold> } @main(title,"photo"){ <ul class="thumbnails"> @for(photo <- photos) { <li class="span3"> <a href="#" class="thumbnail"> <img src="@photo.path" alt=""> </a> </li> } </ul> } and here controller method: public static result getphotos() { return ok(views.html.photo.gallery.render(photo.get())); } and here photo bean : @entity public class photo extends model { @id public long id; @required public string label; public string path; public photo(string path, string label) { this.path = path; this.label = label; } private static finder<long, photo> find = new finder<long, photo>( long.class, photo.class); public static list<phot...
Read more

gmail - Is there any documentation for read-only access to the Google Contacts API? -

i want read-only access user's google contacts. there stackoverflow member wanted this, , received following answer : yes, there is, use https://www.googleapis.com/auth/contacts.readonly scope , "view contacts". this exchange reference read-only access google contacts can find using google. simply using access token obtained attempt read usual google contacts api (i.e. https://www.google.com/m8/feeds ) fails insufficient permissions. similarly, using google contacts api on new target fails 404 errors (for example https://www.googleapis.com/auth/contacts.readonly/default/full ). is there documentation anywhere on how use api, or permissible way access google contacts api full read-write access?
Read more

php - Controller/JToolBar not working in Joomla 2.5 -

relevant code: jtoolbarhelper::custom('savecategories', 'save', '', 'save', false, false); ... <input type="hidden" name="controller" value="easyblogcontroller"> according can dig docs , own previous questions, should call savecategories() function in easyblogcontroller . i've tried setting value easyblog , easyblog.php (file name) current easyblogcontroller (class name). clicking on save button refreshes page. not redirect, echo or var_dump test code put in savecategories() function. var_dump ing jrequest::getvar('controller') , 'task' return correct values. creating controller object , using $controller->execute('task'); works. the values going depend on location of controller trying call, , have couple options here. typically there controller in base folder of component (likely components/com_easyblog) in file called controller.php , class name inside ...
Read more