什么是TCP粘包/拆包

首先要明确, 粘包问题中的 “包”, 是指应用层的数据包.在TCP的协议头中, 没有如同UDP一样的 “报文长度” 字段,但是有一个序号字段.
站在传输层的角度, TCP是一个一个报文传过来的. 按照序号排好序放在缓冲区中.
站在应用层的角度, 看到的只是一串连续的字节数据.那么应用程序看到了这一连串的字节数据, 就不知道从哪个部分开始到哪个部分是一个完整的应用层数据包.此时数据之间就没有了边界, 就产生了粘包问题,那么如何避免粘包问题呢?归根结底就是一句话, 明确两个包之间的边界

在这里插入图片描述

如图所示，假设客户端分别发送两个数据包D1和D2给服务器端，由于服务器端一次读取到的字节数是不确定的，所以可能存在以下几种情况:

服务端分两次读取到了两个独立的数据包，分别是D1和D2，这种情况没有粘包和拆包
服务端一次接收到了两个数据包，D1和D2粘合在一起，被称为TCP粘包
服务端分两次读取到了两个数据包，第一次读取到了完整的D2包和D1包的部分内容，第二次读取到了D1包剩余的内容，这被称为TCP拆包
和第3中情况相反，也是拆包
如果服务端的TCP接收滑窗非常小，而数据包D1和D2比较大，那么服务器要分多次才能将D1和D2完全接收完，期间发生了多次拆包

未考虑TCP粘包案例

上面我们介绍了TCP粘包和拆包的原因，现在我们通过Netty案例来实现下不考虑TCP粘包和拆包问题而造成的影响。代码如下

服务端代码

服务端每读取到一条消息，就计数一次，然后发送应答消息给客户端，按照设计，服务端接受到的消息总数应该跟客户端发送消息总数相同，而且请求消息删除回车换行符后应该为”Query time order”.

package com.dpb.netty.demo1;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.LineBasedFrameDecoder;
import io.netty.handler.codec.string.StringDecoder;
public class TimerServer { 
    public void bind(int port) throws Exception{ 
        // 配置服务端的NIO线程组
        // 服务端接受客户端的连接
        NioEventLoopGroup bossGroup = new NioEventLoopGroup();
        // 进行SocketChannel的网络读写
        NioEventLoopGroup workerGroup = new NioEventLoopGroup();
        try { 
            // 用于启动NIO服务端的辅助启动类，目的是降低服务端的开发复杂度
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup,workerGroup)
            // 设置Channel
            .channel(NioServerSocketChannel.class)
            // 设置TCP参数
            .option(ChannelOption.SO_BACKLOG, 1024)
            // 绑定I/O事件的处理类ChildChannelHandler
            .childHandler(new ChildChannelHandler());
        // 绑定端口，同步等待成功
        ChannelFuture f = b.bind(port).sync();
        // 等待服务端监听端口关闭
        f.channel().closeFuture().sync();
        } finally { 
            // 优雅退出，释放线程池资源
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
    private class ChildChannelHandler extends ChannelInitializer<SocketChannel>{ 
        @Override
        protected void initChannel(SocketChannel arg0) throws Exception { 
            arg0.pipeline().addLast(new TimerServerHandler());
        }
    }
    public static void main(String[] args) throws Exception { 
        int port = 8080;
        new TimerServer().bind(port);
    }
}
package com.dpb.netty.demo1;
import java.nio.ByteBuffer;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;
/** * 用于对网络事件进行读写操作 * @author 波波烤鸭 * @email dengpbs@163.com * */
public class TimerServerHandler extends ChannelHandlerAdapter{ 
    private int counter;
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { 
        // ByteBuf 类似于NIO中的java.nio.ByteBuffer对象，
        ByteBuf buf = (ByteBuf) msg;
        byte[] req = new byte[buf.readableBytes()];
        buf.readBytes(req);
        String body = new String(req,"utf-8")
                .substring(0,req.length-System.getProperty("line.separator").length());
        System.out.println("The time server receive order : "+body+",counter is:"+ ++counter);
        String currentTime = "Query time order".equalsIgnoreCase(body)?new java.util.Date(System.currentTimeMillis()).toString():"BAD ORDER";
        ByteBuf resp = Unpooled.copiedBuffer(currentTime.getBytes());
        ctx.writeAndFlush(resp);
    }
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception { 
        // TODO Auto-generated method stub
        ctx.flush();
    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { 
        // TODO Auto-generated method stub
        ctx.close();
    }
}

客户端代码

客户端跟服务器连接建立成功后，循环发送100条消息，每发送一条就刷新一次，保证每条消息都会被写入Channel中，按照设计，服务端应该接收到100条查询时间指令的请求消息，客户端每接收到服务端一条应答消息后，就打印一次计数器，按照设计客户端应该打印100次服务端的系统时间。

package com.dpb.netty.demo1;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
public class TimeClient { 
    public static void main(String[] args) throws Exception { 
        int port = 8080;
        new TimeClient().connect(port, "127.0.0.1");
    }
    public void connect(int port,String host)throws Exception{ 
        // 配置客户端NIO线程组
        EventLoopGroup group = new NioEventLoopGroup();
        try{ 
            Bootstrap b = new Bootstrap();
            b.group(group).channel(NioSocketChannel.class)
                .option(ChannelOption.TCP_NODELAY, true)
                .handler(new ChannelInitializer<SocketChannel>() { 
                    @Override
                    protected void initChannel(SocketChannel arg0) throws Exception { 
                        arg0.pipeline().addLast(new TimeClientHandler());
                    }
                });
            // 发起异步连接操作
            ChannelFuture f = b.connect(host,port).sync();
            // 等待客户端链路关闭
            f.channel().closeFuture().sync();
        }catch(Exception e){ 
            e.printStackTrace();
        }finally{ 
            // 优雅退出，释放NIO线程组
            group.shutdownGracefully();
        }
    }
}
package com.dpb.netty.demo1;
import java.util.logging.Logger;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;
public class TimeClientHandler extends ChannelHandlerAdapter{ 
    private static final Logger logger = Logger.getLogger(TimeClientHandler.class.getName());
    private int counter;
    private byte[] req;
    public TimeClientHandler(){ 
        // 客户端每次发送的消息后面都跟了一个换行符
        req = ("Query time order"+System.getProperty("line.separator")).getBytes();
    }
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception { 
        ByteBuf message = null;
        for(int i =0;i < 100 ; i++){ 
            message = Unpooled.buffer(req.length);
            message.writeBytes(req);
            ctx.writeAndFlush(message);
        }
    }
    @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("Now is :"+body+";counter is :"+ ++counter);
    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { 
        // TODO Auto-generated method stub
        logger.warning("Unexpected exception from downstream:"+cause.getMessage());
        ctx.close();
    }
}

测试结果

服务端输出结果:

The time server receive order : Query time order
Query time order
... 省略55
Query time ord,counter is:1
The time server receive order : 
Query time order
... 省略41
Query time order,counter is:2

客户端输出结果

Now is :BAD ORDERBAD BAD ORDERBAD ;counter is :1

服务端的运行结果表明它只接受到了两条消息，第一条包含57个”Query time order”指令，第二条包含43条”Query time order”指令，总数刚好是100条，我们期待服务器会接收到100次，结果只接受到了两次，说明发送了TCP粘包。而客户端设计应该受到100条响应，实际服务器发送了两次响应，客户端只受到了一条响应，说明服务器返回给客户端的应答信息也发生了粘包问题。

Netty解决TCP粘包

为了解决TCP粘包/拆包导致的半包读写问题，Netty默认提供了多种编解码器用于处理半包，此处我们使用LineBasedFrameDecoder来解决，实现如下

服务端修改

在这里插入图片描述

客户端修改

在这里插入图片描述

测试结果

服务端输出

在这里插入图片描述

客户端输出

在这里插入图片描述

程序的运行结果完全符合我们的预期，说明通过LineBasedFrameDecoder和StringDecoder成功解决了TCP粘包导致的读半包问题，对于使用者来说，只要将支持半包解码的Handler添加到ChannelPiPeline中即可，不需要额外的代码，用户使用起来非常简单。

LineBasedFrameDecoder和StringDecoder的原理

的工作原理是依次遍历ByteBuf中的可读字节，判断看是否有”\n”或者”\r\n”,如果有就以此位置为结束位置，从可读索引到结束位置区间的字节就组成了一行，它是以换行符为结束标志的解码器，StringDecoder的功能非常简单，就是将接收到的对象转换成字符串，然后继续调用后面的Handler, LineBasedFrameDecoder + StringDecoder组合就是按行切换的文本解码器，它被设计用来支持TCP的粘包和拆包问题。

在这里插入图片描述