Socket粘包和拆包处理思路

一旦客户端和服务器建立了Socket通信连接，接下来粘包和拆包就是一个必须要考虑的问题

本文是关于使用TCP协议下Socket粘包和拆包的处理思路

一个大前提：TCP协议是可靠的，数据包一定会到达（999%的情况下），而且是按顺序到达，所以就不需要考虑UDP协议丢包和乱序的问题

一个小前提：TCP协议会根据数据包的大小和网络通讯状况对数据包合并发送或分片（分包），一个重要的尝试就是大于MTU值的数据包一定会被分割，因此当数据包到达时会出现两种情况：1、和其他数据包的一部分或者整体连成一个大包，2：被分割成几个小包先后到达

因此，为了确定每个包的起始位置，需要在要发送的数据前面加上包头，包头里一般记录了数据的长度，复杂一点了要加上压缩标志位和CRC校验位等信息，以便于检错。更严格的情况下还会加上包尾

首先从缓冲流中读取一个包头的长度（假设是4个字节）,如果连一个包头都读不出来，要么是连接中断了（处理异常，检查心跳，进入超时等待），要么是网络有延迟需要继续接收

解析包头数据，得到包体长度

进入读取循环

判断缓冲流中剩余的数据长度是否大于包体长度

大于等于（粘包的情况），则读取一个包体，然后将缓冲流清空，将剩余数据写回缓冲流（其实就是改变流指针的位置） 然后继续读取下一个包头

小于（被拆分了），则跳出读取循环，继续等待下一次数据接收（可以是异步等待）

对于连接断开，可以分为服务器知道客户端断开（客户端主动用四次挥手和服务器断开），和不知道客户端断开（拔网线），前一种情况走正常流程就可以了，后一种情况下有时链路层会通知网络层，进而抛出异常，比如16001，处理之。可靠的做法还是使用心跳检测，设定在若干秒后没有收到心跳包，就由服务器主动结束这个连接

1客户端连接到代理服务器开放的端口；
2客户端向代理服务器发送验证申请；
3代理服务器向客户端发送一个数据包，从而客户端得知自己的通信申请是否被批准；
4客户端向代理服务器发送一个数据包，告知代理服务器自己要连接的目的主机的地址和端口；
5代理服务器开始进行到目的主机的真正连接；
6代理服务器为客户端开放一个新的端口并向客户端发送一个数据包告知客户端这个新的端口；
7客户端创建一个新的套接字并连接到代理服务器的新的端口；
8然后，代理服务器把由新端口接收到的数据都转发给目的主机，把从目的主机发过来的数据都由新端口转发给客户端。

Socket接口是TCP/IP网络的API（Application Programming Interface,应用程序编程接口），Socket接口定义了许多函数或例程，程序员可以用它们来开发 TCP/IP网络上的应用程序。
请参阅以下资料：
socket非常类似于电话插座。以一个国家级电话网为例。电话的通话双方相当于相互通信的2个进程，区号是它的网络地址；区内一个单位的交换机相当于一台主机，主机分配给每个用户的局内号码相当于socket号。任何用户在通话之前，首先要占有一部电话机，相当于申请一个socket；同时要知道对方的号码，相当于对方有一个固定的socket。然后向对方拨号呼叫，相当于发出连接请求(假如对方不在同一区内，还要拨对方区号，相当于给出网络地址)。对方假如在场并空闲(相当于通信的另一主机开机且可以接受连接请求)，拿起电话话筒，双方就可以正式通话，相当于连接成功。双方通话的过程，是一方向电话机发出信号和对方从电话机接收信号的过程，相当于向socket发送数据和从socket接收数据。通话结束后，一方挂起电话机相当于关闭socket，撤消连接。
在电话系统中，一般用户只能感受到本地电话机和对方电话号码的存在，建立通话的过程，话音传输的过程以及整个电话系统的技术细节对他都是透明的，这也与socket机制非常相似。socket利用网间网通信设施实现进程通信，但它对通信设施的细节毫不关心，只要通信设施能提供足够的通信能力，它就满足了。
至此，我们对socket进行了直观的描述。抽象出来，socket实质上提供了进程通信的端点。进程通信之前，双方首先必须各自创建一个端点，否则是没有办法建立联系并相互通信的。正如打电话之前，双方必须各自拥有一台电话机一样。在网间网内部，每一个socket用一个半相关描述:
(协议，本地地址，本地端口)
一个完整的socket有一个本地唯一的socket号，由 *** 作系统分配。
最重要的是，socket 是面向客户/服务器模型而设计的，针对客户和服务器程序提供不同的socket 系统调用。客户随机申请一个socket (相当于一个想打电话的人可以在任何一台入网电话上拨号呼叫)，系统为之分配一个socket号；服务器拥有全局公认的 socket ，任何客户都可以向它发出连接请求和信息请求(相当于一个被呼叫的电话拥有一个呼叫方知道的电话号码)。
socket利用客户/服务器模式巧妙地解决了进程之间建立通信连接的问题。服务器socket 半相关为全局所公认非常重要。读者不妨考虑一下，两个完全随机的用户进程之间如何建立通信？假如通信双方没有任何一方的socket 固定，就好比打电话的双方彼此不知道对方的电话号码，要通话是不可能的。

题主是否想询问“socket中服务器不进行tcp应答是什么原因”？tcp消息与socket连接断开。根据查询相关公开信息显示，服务器请求客户端确认的时候，客户端返回的是Rst，而不是tcp。传输控制协议（TCP，TransmissionControlProtocol）是一种面向连接的，可靠的，基于字节流的传输层通信协议，由IETF的RFC793定义。

当您尝试建立TCP连接时，如果您的socket创建失败，可能是由于以下原因：1网络问题，您可以检查您的网络连接是否正常；2端口号问题，您可以检查您的端口号是否正确；3服务器问题，您可以检查服务器是否正常运行；4编程问题，您可以检查您的编程代码是否正确。

用到了，因为socket通信是计算机网络编程的基础，互联网上的通信离不开它。
说详细一点，至少要明白HTML,socket编程，计算机网络的TCP/IP模型。
1、TCP/IP是计算机通信的基础；
2、socket通信本来是UNIX的基于服务器/客户端的TCP/IP实现，不过目前几乎所有的 *** 作系统都兼容；
3、HTML是运行在SOCKET的80端口上的高层网络协议。
如果你有时间和精力，完全可以使用SOCKET自行开一个WEB服务器

所谓socket通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。\x0d\以J2SDK-13为例，Socket和ServerSocket类库位于javanet包中。ServerSocket用于服务器端，Socket是建立网络连接时使用的。在连接成功时，应用程序两端都会产生一个Socket实例， *** 作这个实例，完成所需的会话。对于一个网络连接来说，套接字是平等的，并没有差别，不因为在服务器端或在客户端而产生不同级别。不管是Socket还是ServerSocket它们的工作都是通过SocketImpl类及其子类完成的。\x0d\重要的Socket API：\x0d\javanetSocket继承于javalangObject，有八个构造器，其方法并不多，下面介绍使用最频繁的三个方法，其它方法大家可以见JDK-13文档。\x0d\ Accept方法用于产生"阻塞"，直到接受到一个连接，并且返回一个客户端的Socket对象实例。"阻塞"是一个术语，它使程序运行暂时"停留"在这个地方，直到一个会话产生，然后程序继续；通常"阻塞"是由循环产生的。\x0d\ getInputStream方法获得网络连接输入，同时返回一个InputStream对象实例。\x0d\ getOutputStream方法连接的另一端将得到输入，同时返回一个OutputStream对象实例。\x0d\注意：其中getInputStream和getOutputStream方法均会产生一个IOException，它必须被捕获，因为它们返回的流对象，通常都会被另一个流对象使用。\x0d\2ServerSocket类例子编辑\x0d\\x0d\package comlanbersocket;\x0d\import javaioDataInputStream;\x0d\import javaioDataOutputStream;\x0d\import javaioIOException;\x0d\import javanetServerSocket;\x0d\import javanetSocket;\x0d\public class ServerDemo {\x0d\/\x0d\ 注意：Socket的发送与接收是需要同步进行的，即客户端发送一条信息，服务器必需先接收这条信息，\x0d\ 而后才可以向客户端发送信息，否则将会有运行时出错。\x0d\ @param args\x0d\/\x0d\public static void main(String[] args) {\x0d\ServerSocket ss = null;\x0d\try {\x0d\ss = new ServerSocket(8888);\x0d\//服务器接收到客户端的数据后，创建与此客户端对话的Socket\x0d\Socket socket = ssaccept();\x0d\//用于向客户端发送数据的输出流\x0d\DataOutputStream dos = new DataOutputStream(socketgetOutputStream());\x0d\//用于接收客户端发来的数据的输入流\x0d\DataInputStream dis = new DataInputStream(socketgetInputStream());\x0d\Systemoutprintln("服务器接收到客户端的连接请求：" + disreadUTF());\x0d\//服务器向客户端发送连接成功确认信息\x0d\doswriteUTF("接受连接请求，连接成功!");\x0d\//不需要继续使用此连接时，关闭连接\x0d\socketclose();\x0d\ssclose();\x0d\} catch (IOException e) {\x0d\eprintStackTrace();\x0d\}\x0d\}\x0d\}\x0d\\x0d\3客户端的例子编辑\x0d\package comlanbersocket;\x0d\importjavaioDataInputStream;\x0d\import javaioDataOutputStream;\x0d\importjavaioIOException;\x0d\import javaioOutputStream;\x0d\import javanetSocket;\x0d\import javanetUnknownHostException;\x0d\public class ClientDemo {\x0d\/\x0d\ @param args\x0d\/\x0d\public static void main(String[] args) {\x0d\Socket socket = null;\x0d\try {\x0d\socket = new Socket("localhost",8888);\x0d\//获取输出流，用于客户端向服务器端发送数据\x0d\DataOutputStream dos = new DataOutputStream(socketgetOutputStream());\x0d\//获取输入流，用于接收服务器端发送来的数据\x0d\DataInputStream dis = new DataInputStream(socketgetInputStream());\x0d\//客户端向服务器端发送数据\x0d\doswriteUTF("我是客户端，请求连接!");\x0d\//打印出从服务器端接收到的数据\x0d\Systemoutprintln(disreadUTF());\x0d\//不需要继续使用此连接时，记得关闭哦\x0d\socketclose();\x0d\} catch (UnknownHostException e) {\x0d\eprintStackTrace();\x0d\} catch (IOException e) {\x0d\eprintStackTrace();\x0d\}\x0d\}\x0d\}

---