客户端代码如图所示,其中对于消息的解码操作只有2个部分,其中LOGGING_HANDLER为日志的输出。
bootstrap.handler(new ChannelInitializer() { @Override protected void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast(new ProcotolframeDecoder()); ch.pipeline().addLast(LOGGING_HANDLER); ch.pipeline().addLast(MESSAGE_CODEC);
服务端的代码也如图所示,使用的是与客户端相同的handler对消息进行处理
serverBootstrap.childHandler(new ChannelInitializer() { @Override protected void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast(new ProcotolframeDecoder()); ch.pipeline().addLast(LOGGING_HANDLER); ch.pipeline().addLast(MESSAGE_CODEC);
要注意客户端与服务端处理的消息的流程是否是一致的,要能够对消息进行解析
import com.zty.netty.message.LoginRequestMessage; import com.zty.netty.server.message.* ;
在传递登录消息的时候,我导入了两次LoginRequestMessage这个消息类,server.message当中也会存在一个LoginRequestMessage类,可以看出,我导入了两次消息类,但是这两个消息类并不是相同的包里面的,所以创建与解析的方式可能不相同导致消息无法接收到?
同样,也要保证编码解码器是相同包当中的类,一定要是同一个类,否则消息也是无法正确的编码与解码的。



