【Netty4 简单项目实践】二、解决TCP连包问题：分隔符解码器

TCP他会分包发很讨厌，开始的时候用分隔符来实现String消息的提取。

这种解决方案适合于用Json进行消息交互的TCP长连接。

下面的代码，在第一篇的代码上进行修改即可。

分隔符处理器

解决的思路是在channel链上加载分隔符处理器DelimiterBasedFrameDecoder，代码如下

String delimiter = "Doge";
ByteBuf[] delimiterBytes = new ByteBuf[] {
Unpooled.wrappedBuffer(delimiter.getBytes()) };
// 这里省略十几行代码
bootstrap.localAddress(new InetSocketAddress(port))
.childHandler(new ChannelInitializer<Channel>() {
@Override
protected void initChannel(Channel ch) throws Exception {
// TODO Auto-generated method stub
ch.pipeline().addLast("framer",new DelimiterBasedFrameDecoder(
4096, delimiterBytes));// 这里，看这里
ch.pipeline().addLast(new StringDecoder());
ch.pipeline().addLast(new StringEncoder());
ch.pipeline().addLast(new ByteStreamHandler());
}
});

记得ByteBuff要释放掉，在finally代码中调用：

for (inti=0; i<delimiterBytes.length;i++){
delimiterBytes[i].release();
}

上面的处理类 ByteStreamHandler.java

public class ByteStreamHandler extends SimpleChannelInboundHandler<String>{
private StringBuffer sb = new StringBuffer();
@Override
protected void channelRead0(ChannelHandlerContextctx, String msg)throws Exception {
// TODO Auto-generated method stub
sb.append(msg);
}
@Override
public void channelReadComplete(ChannelHandlerContextctx) throws Exception {
System.out.println(sb.toString());
}
}