黏包的处理

socket通讯时，tcp不会丢包，会黏包；udp不会黏包，会丢包

tcp发生黏包的原因有二：

• 1、当一个数据发送超过接收的大小时，剩余的数据会进入系统的缓冲区内，下一次再接收时会把上一次没传完的数据继续接收这也就造成了第二次发送的数据和第一次发送的数据混在一起
• 2、tcp协议本身的优化算法造成的黏包
  优化算法的功能是：连续两次send如果时间间隔小且两个数据包的大小都很小，则把这两个数据包合并成一个数据包来发送

通常情况下，每个tcp数据包的包头前4个字节表示当前这个包的数据长度，较为理想的形态是tcp每个包之间不发生黏连，每个包都是一个完整的包。
以下图为例，蓝色部分表示包头，后面白色部分表示包体，包头4个字节表示后面包体的长度。

当出现黏包时，socket收到的一个数据包内容大于或小于一个完整的数据包。
例如以几种形态：

• 1、数据包在一个完整的数据包与两个完整的数据包之间

  
  
  
  

  或

  
  

• 2、数据包小于一个完整的数据包

  
  
  
  

  或

  
  

• 3、数据包为两个完整的数据包

  
  

关于如何在代码中处理黏包，可以参考以下代码：

            while (state.get() == State.RUNNING) {

                int packageLength = in.get().read(receiver, readLength, receiver.length - readLength);
                readLength += packageLength;
                if (packageLength == -1) {
                    state.set(State.STOPPED);
                    continue;
                }
                while (true) {
                    if (msgLength <= 0 && readLength >= 4) {
                        msgLength = (int) BruteForceCoding.decodeIntBigEndian(receiver, 0, 4);
                        if (msgLength > 40 * DEFAULT_MESSAGE_SIZE) {
                            readLength = 0;
                            msgLength = 0;
                            receiver = new byte[DEFAULT_MESSAGE_SIZE];
                            break;
                        }
                        if (msgLength > receiver.length) {
                            byte[] tmp = new byte[receiver.length];
                            System.arraycopy(receiver, 0, tmp, 0, receiver.length);
                            receiver = new byte[msgLength];
                            System.arraycopy(tmp, 0, receiver, 0, tmp.length);
                        }
                    }
                    if (msgLength <= 0) {
                        // 包不足以解析出包头长度，继续收包
                        break;
                    }
                    if (readLength < msgLength) {
                        // 包数据不足以解析出包内容，继续收包
                        break;
                    }
                    handlePackageBody(receiver, msgLength);
                    // 继续处理剩余的包
                    readLength -= msgLength;
                    if (readLength > 0) {
                        // 处理黏包
                        byte[] tmp = new byte[readLength];
                        System.arraycopy(receiver, msgLength, tmp, 0, tmp.length);
                        receiver = new byte[Math.max(DEFAULT_MESSAGE_SIZE, tmp.length)];
                        System.arraycopy(tmp, 0, receiver, 0, tmp.length);
                        msgLength = 0;
                        continue;
                    } else {
                        msgLength = 0;
                        receiver = new byte[DEFAULT_MESSAGE_SIZE];
                        break;
                    }
                }
                try {
                    // 防止cpu空转
                    Thread.sleep(2);
                } catch (Exception e) {
                    LeLog.w(TAG, e);
                }
            }