Netty入门系列(2) --使用Netty解决粘包和拆包问题 (2)

客户端的Handler

public class PrintClientHandler extends ChannelHandlerAdapter { private static final Logger logger = Logger .getLogger(TimeClientHandler.class.getName()); private final ByteBuf firstMessage; /** * Creates a client-side handler. */ public TimeClientHandler() { byte[] req = "你好服务端".getBytes(); firstMessage = Unpooled.buffer(req.length); firstMessage.writeBytes(req); } @Override public void channelActive(ChannelHandlerContext ctx) { ctx.writeAndFlush(firstMessage); } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { ByteBuf buf = (ByteBuf) msg; byte[] req = new byte[buf.readableBytes()]; buf.readBytes(req); String body = new String(req, "UTF-8"); System.out.println("服务端回应消息 : " + body); } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { // 释放资源 System.out.println("Unexpected exception from downstream : " + cause.getMessage()); ctx.close(); } }

上诉代码逻辑与上一章代码逻辑相同,客户端接受服务端数据答应,并回复客户端信息,客户端接受到数据后打印数据。

我们观察代码可以发现,要想Netty解决粘包拆包问题,只需在编写服务端和客户端的pipeline上加上相应的解码器即可,上诉注释 1,2,3,4处。

LineBasedFrameDecoder+StringDecoder的组合就是按行切换的文本解码器,它被设计用来支持TCP的粘包和拆包。原理为:如果连续读取到最大长度后任然没有发现换行符,就会抛出异常,同时忽略掉之前督导的异常码流。

DelimiteBasedFrameDecoder

该解码器的可以自动完成以分割符作为码流结束标识的消息解码。(其实上一个解码器类似,如果指定分隔符为换行符,那么与上一个编码器的作用基本相同)

使用也很简单:

只需要修改服务端和客户端对应代码中的initChannel代码即可

public void initChannel(SocketChannel ch) ByteBuf delimiter = Unpooled.copiedBuffer("_".getBytes()); //1 ch.pipeline().addLast( new DelimiterBasedFrameDecoder(1024, delimiter)); //2 ch.pipeline().addLast(new StringDecoder()); //3 ch.pipeline().addLast(new PrintHandler()); }

注释1:首先创建分隔符缓冲对象ByteBuf,并指定以"_"作为分隔符。

注释2:将分隔符缓冲对象ByteBuf传入DelimiterBasedFrameDecoder,并指定最大长度。

注释3:指定为字符串字节流

FixedLengthFrameDecoder

该解码器为固定长度解码器,它能够按照指定的长度对详细进行自动解码。

使用同样也很简单:

同样只需要修改服务端和客户端对应代码中的initChannel代码即可

public void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast(new FixedLengthFrameDecoder(20)); ch.pipeline().addLast(new StringDecoder()); ch.pipeline().addLast(new PrintHandler()); } });

这样我们就指定了,每接收20个字符大小的字符串字节流就将其看作一个包来经行处理。

总结

Netty已经在底层为我们做了很多事情,我们只需要简单的使用其提供好的解码器使用即可,源码内容待我研究归来,再进行展开,哈哈,完活~睡觉!

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zyywxw.html