非常基本的netty用法：对接收到的对象的调用方法

本文介绍了非常基本的netty用法：对接收到的对象的调用方法的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述

适用于Netty 示例，分支4.0，服务器从客户端接收对象？更重要的是，在 ObjectEchoServer 或 ObjectEchoServerHandler 中，可以调用接收到的对象上的方法吗？
正在服务器上接收该对象：
  BUILD SUCCESSFUL 
总时间：2秒
 2014年7月23日下午11:44:04 io.netty.handler.logging.LoggingHandler channelRegistered 
信息：[id：0x93baa167]注册
 2014年7月23日11 ：44：04 PM io.netty.handler.logging.LoggingHandler bind 
 INFO：[id：0x93baa167] BIND（0.0.0.0/0.0.0.0:4454）
 Jul 23，2014 11:44： 04 PM io.netty.handler.logging.LoggingHandler channelActive 
 INFO：[id：0x93baa167，/ 0：0：0：0：0：0：0：0：4454] ACTIVE 
 Jul 23， 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler logMessage 
 INFO：[id：0x93baa167，/ 0：0：0：0：0：0：0：0：4454] RECEIVED： id：0x8c8385a6，/127.0.0.1:33803 => /127.0.0.1:4454] 
 Jul 23，2014 11:44:10 PM io.netty.handler.logging.LoggingHandler channelRegistered 
 INFO：[id：0x8c8385a6，/127.0.0.1:33803 => ; /127.0.0.1:4454] REGISTERED 
 2014年7月23日下午11:44:10 io.netty.handler.logging.LoggingHandler channelActive 
 INFO：[id：0x8c8385a6，/127.0.0.1:33803 = > /127.0.0.1:4454]活动
 2014年7月23日下午11:44:10 io.netty.handler.logging.LoggingHandler logMessage 
 INFO：[id：0x8c8385a6，/127.0.0.1:33803 = > /127.0.0.1:4454]写：Sun Jun 16 16:15:54 PST 1878 
 Jul 23，2014 11:44:10 PM io.netty.handler.logging.LoggingHandler flush 
 INFO：[ id：0x8c8385a6，/127.0.0.1:33803 => /127.0.0.1:4454] FLUSH 
 2014年7月23日下午11:44:10 io.netty.handler.logging.LoggingHandler close 
 INFO：[id：0x8c8385a6，/127.0.0.1:33803 = > /127.0.0.1:4454] CLOSE（）
 2014年7月23日下午11:44:10 io.netty.handler.logging.LoggingHandler channelInactive 
 INFO：[id：0x8c8385a6，/127.0.0.1： 33803：> /127.0.0.1:4454] INACTIVE 
 Jul 23，2014 11:44:10 PM io.netty.handler.logging.LoggingHandler channelUnregistered 
 INFO：[id：0x8c8385a6，/127.0.0.1:33803： > /127.0.0.1:4454] UNREGISTERED 
 ^ Cthufir @ dur：〜/ NetBeansProjects / ObjectEchoServer $ 
 thufir @ dur：〜/ NetBeansProjects / ObjectEchoServer $ 
  pre> 
 
 服务器如何处理接收的对象？如何从对象调用方法？
 
 
 我绝对意识到这是一个非常基本的问题。我翻阅了书，但无法找到相关部分说明此问题基本功能。
 
 
 我修改了服务器代码，如下所示：
  package io.netty.example.objectecho; 
 
 import io.netty.channel.ChannelHandlerContext; 
 import io.nettychannel.ChannelInboundHandlerAdapter; 
 import java.util.logging.Logger; 
 
 / ** 
 *根据调用
 *构造函数处理客户端和服务器端处理程序。 
 * / 
 public class ObjectEchoServerHandler extends ChannelInboundHandlerAdapter {
 
 private static final Logger log = Logger.getLogger（ObjectEchoServerHandler.class.getName（））; 
 
 @Override 
 public void channelRead（ChannelHandlerContext ctx，Object msg）{
 log.warning（msg.toString（））; 
 ctx.write（msg）; 
} 
 
 @Override 
 public void channelReadComplete（ChannelHandlerContext ctx）{
 log.info（finished reading ..？ 
 ctx.flush（）; 
} 
 
 @Override 
 public void exceptionCaught（ChannelHandlerContext ctx，Throwable cause）{
 cause.printStackTrace（）; 
 ctx.close（）; 
} 
} 
  
但似乎不能调用 msg.toString（），如我所料，也不记录完成阅读。每当收到一个对象时，服务器应该处理该对象并将其传递给另一个类 - 但是如何？
 
 
 我如何，至少，在接收对象上调用 toString ？它显然被收到，它被记录为收到。 
解决方案
客户端输出：
  BUILD SUCCESSFUL 
总时间：1秒
 2014年7月25日下午10:18:59 io.netty.example.objectecho.ObjectEchoClientHandler channelActive 
 INFO：[0，1，2，3，4，5，6，7，8，9，10，11，12，13，14，15，16，17，18，19，20，21， 22，23，24，25，26，27，28，29，30，31，32，33，34，35，36，37，38，39，40，41，42， 47，48，49，50，51，52，53，54，55，56，57，58，59，60，61，62，63，64，65，66，67， 72,73,74,75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99，80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97， 97，98，99，100，101，102，103，104，105，106，107，108，109，110，111，112，113，114，115，116，117， 122，123，124，125，126，127，128，129，130，131，132，133，134，135，136， 147，148，149，150，151，152，153，154，155，156，157，158，159，160， 172，173，174，175，176，177，178，179，180，181，182，183，184， 197，198，199，200，201，202，203，204，205，206，207，208，209，210，211，212，213，214，215， 222,223,224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246,234,234,234,234,234,234,234,234,234， 247，248，249，250，251，252，253，254，255] 
七月25，2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoClientHandler channelRead 
  
服务器输出：
  BUILD SUCCESSFUL 
总时间：1秒
 2014年7月25日下午10:18:48 io.netty.handler.logging.LoggingHandler channelRegistered 
信息：[id：0xe7cb1e59]注册
 7月25，2014 10:18:48 PM io.netty.handler.logging.LoggingHandler bind 
 INFO：[id：0xe7cb1e59] BIND（0.0.0.0/0.0.0.0:4454）
 2014年7月25日10:18:48 PM io.netty.handler.logging.LoggingHandler channelActive 
 INFO：[id：0xe7cb1e59，/ 0：0：0：0：0：0：0：0：4454] ACTIVE 
 Jul 25，2014 10:18:59 PM io.netty.handler.logging.LoggingHandler logMessage 
 INFO：[id：0xe7cb1e59，/ 0：0：0：0：0：0：0：0：4454 ] RECEIVED：[id：0xc5d3dfbf，/127.0.0.1:33250 => /127.0.0.1:4454] 
 2014年7月25日下午10:18:59 io.netty.example.objectecho.ObjectEchoServerHandler channelRead 
警告：[0，1，2，3，4，5， 6，7，8，9，10，11，12，13，14，15，16，17，18，19，20，21，22，23，24，25，26，27，28， 35，36，37，38，39，40，41，42，43，44，45，46，47，48，49，50， 56，57，58，59，60，61，62，63，64，65，66，67，68，69，70，71，72，73，74， 81，82，83，84，85，86，87，88，89，90，91，92，93，94，95，96，97，98， 106个，107个，108个，109个，110个，111个，112个，113个，114个，115个，116个，117个，118个， 131，132，133，134，135，136，137，138，139，140，141，142，143，144， 156，157，158，159，160，161,162,163,164,165,166,167,168,169,170,171,172,173,174,175,176,177,178,179,180， 181，182，183，184，185，186，187，188，189，190，191，192，193， 206位，207位，208位，209位，210位，211位，212位，213位，214位，215位，216位，217位，218位， 231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255]的氨基酸序列的多肽， 
 2014年7月25日下午10:18:59 io.netty.example.objectecho.ObjectEchoServerHandler channelReadComplete 
 INFO：完成阅读..？ 
 Jul 25，2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoServerHandler channelRead 
警告：[0，1，2，3，4，5，6，7，8，9 ，10，11，12，13，14，15，16，17，18，19，20，21，22，23，24，25，26，27，28，29，30，31，32，33，34 ，35，36，37，38，39，40，41，42，43，44，45，46，47，48，49，50，51，52，53，54，55，56，57，58， ，60，61，62，63，64，65，66，67，68，69，70，71，72，73，74，75，76，77，78，79，80，81，82， ，85，86，87，88，89，90，91，92，93，94，95，96，97，98，99，100，101，102，103，104，105，106，107，108，109 ，110，111，112，113，114，115，116，117，118，119，120，121，122，123，124，125，126，127，128，129，130，131，132，133，134 ，135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159的氨基酸序列的至少一个氨基酸序列，160,161,162,163,164,165,166,167,168,169,170,171,172,173,174,175,176,177,178,179,180,181,182,183,184的氨基酸序列的氨基酸序列，185,186,187,188,189,190,191,192,193,194,195,196,197,198,199,200,201,202,203,204,205,206,207,208,209的序列同一性的氨基酸序列，210,211,212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231,232,233,234中任一项所示的氨基酸序列，235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255] 
 Jul 25， 2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoServerHandler channelReadComplete 
 INFO：完成阅读..？ 
  
我认为这是相同的代码...不确定是什么问题。无限循环已建立：）
 
 
 服务器处理程序：
  netty.example.objectecho; 
 
 import io.netty.channel.ChannelHandlerContext; 
 import io.nettychannel.ChannelInboundHandlerAdapter; 
 import java.util.logging.Logger; 
 
 / ** 
 *根据调用
 *构造函数处理客户端和服务器端处理程序。 
 * / 
 public class ObjectEchoServerHandler extends ChannelInboundHandlerAdapter {
 
 private static final Logger log = Logger.getLogger（ObjectEchoServerHandler.class.getName（））; 
 
 @Override 
 public void channelRead（ChannelHandlerContext ctx，Object msg）{
 log.warning（msg.toString（））; 
 ctx.write（msg）; 
} 
 
 @Override 
 public void channelReadComplete（ChannelHandlerContext ctx）{
 log.info（finished reading ..？ 
 ctx.flush（）; 
} 
 
 @Override 
 public void exceptionCaught（ChannelHandlerContext ctx，Throwable cause）{
 cause.printStackTrace（）; 
 ctx.close（）; 
} 
} 
  
 
for the Netty ObjectEcho example, branch 4.0, where does the server receive an object from the client?  More importantly, where, in either ObjectEchoServer or ObjectEchoServerHandler can a method on the received object be invoked?
The object is being received on the server:
BUILD SUCCESSFUL
Total time: 2 seconds
Jul 23, 2014 11:44:04 PM io.netty.handler.logging.LoggingHandler channelRegistered
INFO: [id: 0x93baa167] REGISTERED
Jul 23, 2014 11:44:04 PM io.netty.handler.logging.LoggingHandler bind
INFO: [id: 0x93baa167] BIND(0.0.0.0/0.0.0.0:4454)
Jul 23, 2014 11:44:04 PM io.netty.handler.logging.LoggingHandler channelActive
INFO: [id: 0x93baa167, /0:0:0:0:0:0:0:0:4454] ACTIVE
Jul 23, 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler logMessage
INFO: [id: 0x93baa167, /0:0:0:0:0:0:0:0:4454] RECEIVED: [id: 0x8c8385a6, /127.0.0.1:33803 => /127.0.0.1:4454]
Jul 23, 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler channelRegistered
INFO: [id: 0x8c8385a6, /127.0.0.1:33803 => /127.0.0.1:4454] REGISTERED
Jul 23, 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler channelActive
INFO: [id: 0x8c8385a6, /127.0.0.1:33803 => /127.0.0.1:4454] ACTIVE
Jul 23, 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler logMessage
INFO: [id: 0x8c8385a6, /127.0.0.1:33803 => /127.0.0.1:4454] WRITE: Sun Jun 16 16:15:54 PST 1878
Jul 23, 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler flush
INFO: [id: 0x8c8385a6, /127.0.0.1:33803 => /127.0.0.1:4454] FLUSH
Jul 23, 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler close
INFO: [id: 0x8c8385a6, /127.0.0.1:33803 => /127.0.0.1:4454] CLOSE()
Jul 23, 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler channelInactive
INFO: [id: 0x8c8385a6, /127.0.0.1:33803 :> /127.0.0.1:4454] INACTIVE
Jul 23, 2014 11:44:10 PM io.netty.handler.logging.LoggingHandler channelUnregistered
INFO: [id: 0x8c8385a6, /127.0.0.1:33803 :> /127.0.0.1:4454] UNREGISTERED
^Cthufir@dur:~/NetBeansProjects/ObjectEchoServer$ 
thufir@dur:~/NetBeansProjects/ObjectEchoServer$ 
How does the server, literally, handle the received object?  How is a method from the object invoked?
I absolutely realize this is a very basic question.  I've flipped through a book on netty, but wasn't able to find a relevant section explaining this fundamental functionality.
I've modified the server code as follows:
package io.netty.example.objectecho;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import java.util.logging.Logger;

/**
 * Handles both client-side and server-side handler depending on which
 * constructor was called.
 */
public class ObjectEchoServerHandler extends ChannelInboundHandlerAdapter {

    private static final Logger log = Logger.getLogger(ObjectEchoServerHandler.class.getName());

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        log.warning(msg.toString());
        ctx.write(msg);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        log.info("finished reading..?");
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}
but cannot seem to invoke msg.toString() as I would expect, nor log "finished reading".  Each and every time an object is received, the server should process that object and pass it off to another class -- but how?
How do I, at a minimum, invoke toString on the receive object?  It's clearly being received, it's logged as received.  This happens in the server class, and not the handler?
 解决方案 
client output:
BUILD SUCCESSFUL
Total time: 1 second
Jul 25, 2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoClientHandler channelActive
INFO: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 95, 96, 97, 98, 99, 100, 101, 102, 103, 104, 105, 106, 107, 108, 109, 110, 111, 112, 113, 114, 115, 116, 117, 118, 119, 120, 121, 122, 123, 124, 125, 126, 127, 128, 129, 130, 131, 132, 133, 134, 135, 136, 137, 138, 139, 140, 141, 142, 143, 144, 145, 146, 147, 148, 149, 150, 151, 152, 153, 154, 155, 156, 157, 158, 159, 160, 161, 162, 163, 164, 165, 166, 167, 168, 169, 170, 171, 172, 173, 174, 175, 176, 177, 178, 179, 180, 181, 182, 183, 184, 185, 186, 187, 188, 189, 190, 191, 192, 193, 194, 195, 196, 197, 198, 199, 200, 201, 202, 203, 204, 205, 206, 207, 208, 209, 210, 211, 212, 213, 214, 215, 216, 217, 218, 219, 220, 221, 222, 223, 224, 225, 226, 227, 228, 229, 230, 231, 232, 233, 234, 235, 236, 237, 238, 239, 240, 241, 242, 243, 244, 245, 246, 247, 248, 249, 250, 251, 252, 253, 254, 255]
Jul 25, 2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoClientHandler channelRead
server output:    
BUILD SUCCESSFUL
Total time: 1 second
Jul 25, 2014 10:18:48 PM io.netty.handler.logging.LoggingHandler channelRegistered
INFO: [id: 0xe7cb1e59] REGISTERED
Jul 25, 2014 10:18:48 PM io.netty.handler.logging.LoggingHandler bind
INFO: [id: 0xe7cb1e59] BIND(0.0.0.0/0.0.0.0:4454)
Jul 25, 2014 10:18:48 PM io.netty.handler.logging.LoggingHandler channelActive
INFO: [id: 0xe7cb1e59, /0:0:0:0:0:0:0:0:4454] ACTIVE
Jul 25, 2014 10:18:59 PM io.netty.handler.logging.LoggingHandler logMessage
INFO: [id: 0xe7cb1e59, /0:0:0:0:0:0:0:0:4454] RECEIVED: [id: 0xc5d3dfbf, /127.0.0.1:33250 => /127.0.0.1:4454]
Jul 25, 2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoServerHandler channelRead
WARNING: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 95, 96, 97, 98, 99, 100, 101, 102, 103, 104, 105, 106, 107, 108, 109, 110, 111, 112, 113, 114, 115, 116, 117, 118, 119, 120, 121, 122, 123, 124, 125, 126, 127, 128, 129, 130, 131, 132, 133, 134, 135, 136, 137, 138, 139, 140, 141, 142, 143, 144, 145, 146, 147, 148, 149, 150, 151, 152, 153, 154, 155, 156, 157, 158, 159, 160, 161, 162, 163, 164, 165, 166, 167, 168, 169, 170, 171, 172, 173, 174, 175, 176, 177, 178, 179, 180, 181, 182, 183, 184, 185, 186, 187, 188, 189, 190, 191, 192, 193, 194, 195, 196, 197, 198, 199, 200, 201, 202, 203, 204, 205, 206, 207, 208, 209, 210, 211, 212, 213, 214, 215, 216, 217, 218, 219, 220, 221, 222, 223, 224, 225, 226, 227, 228, 229, 230, 231, 232, 233, 234, 235, 236, 237, 238, 239, 240, 241, 242, 243, 244, 245, 246, 247, 248, 249, 250, 251, 252, 253, 254, 255]
Jul 25, 2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoServerHandler channelReadComplete
INFO: finished reading..?
Jul 25, 2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoServerHandler channelRead
WARNING: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 95, 96, 97, 98, 99, 100, 101, 102, 103, 104, 105, 106, 107, 108, 109, 110, 111, 112, 113, 114, 115, 116, 117, 118, 119, 120, 121, 122, 123, 124, 125, 126, 127, 128, 129, 130, 131, 132, 133, 134, 135, 136, 137, 138, 139, 140, 141, 142, 143, 144, 145, 146, 147, 148, 149, 150, 151, 152, 153, 154, 155, 156, 157, 158, 159, 160, 161, 162, 163, 164, 165, 166, 167, 168, 169, 170, 171, 172, 173, 174, 175, 176, 177, 178, 179, 180, 181, 182, 183, 184, 185, 186, 187, 188, 189, 190, 191, 192, 193, 194, 195, 196, 197, 198, 199, 200, 201, 202, 203, 204, 205, 206, 207, 208, 209, 210, 211, 212, 213, 214, 215, 216, 217, 218, 219, 220, 221, 222, 223, 224, 225, 226, 227, 228, 229, 230, 231, 232, 233, 234, 235, 236, 237, 238, 239, 240, 241, 242, 243, 244, 245, 246, 247, 248, 249, 250, 251, 252, 253, 254, 255]
Jul 25, 2014 10:18:59 PM io.netty.example.objectecho.ObjectEchoServerHandler channelReadComplete
INFO: finished reading..?
I think it's the same code...not sure what the problem was.   Infinite loop established :)
server handler:
package io.netty.example.objectecho;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import java.util.logging.Logger;

/**
 * Handles both client-side and server-side handler depending on which
 * constructor was called.
 */
public class ObjectEchoServerHandler extends ChannelInboundHandlerAdapter {

    private static final Logger log = Logger.getLogger(ObjectEchoServerHandler.class.getName());

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        log.warning(msg.toString());
        ctx.write(msg);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        log.info("finished reading..?");
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}
                        
这篇关于非常基本的netty用法：对接收到的对象的调用方法的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！