本项目的数据包格式#

1
┌──────────────────────┬──────────────────────────────┐
2
│ 数据长度：sizeof(int) │ 数据内容：len 字节            │
3
└──────────────────────┴──────────────────────────────┘

发送顺序必须固定：

1. 发送 len；
2. 发送 data 中的 len 个字节。

接收顺序也必须完全一致：

1. 先接收数据长度；
2. 根据长度申请空间；
3. 循环接收，直到该包的数据体全部收完。

关键语句解释#

1
send(m_sock, (char*)&len, sizeof(int), 0);

• send() 要求缓冲区参数是 char*，因此把 &len 强制转换成 (char*)。
• 这里发送的是变量 len 本身在内存中的字节，发送大小为 sizeof(int)。
• TCP 客户端只有一个与服务器建立连接的套接字，因此使用成员变量 m_sock。

1
send(m_sock, data, len, 0);

• 第二次发送数据体。
• 数据长度必须写 len。
• 不能写 sizeof(data)，因为函数参数 data 是指针，sizeof(data) 得到的是指针本身的大小，不是实际数据长度。

为什么客户端暂时没有使用参数 to#

TCP 客户端的 m_sock 已经通过 connect() 与服务器建立了连接，所以数据只能沿着这条连接发送给服务器，不需要再次指定目标。

接口中保留 to，是因为 INet 同时统一了 UDP、TCP 客户端和 TCP 服务端的发送接口。

1. 先接收长度#

1
nRecvNum = recv(m_sock, (char*)&packLen, sizeof(int), 0);

接收成功后，packLen 就表示当前数据包的数据体长度。随后按照该长度申请空间：

1
char* pack = new char[packLen];

2. 为什么数据体不能只调用一次 recv()#

假设应用层要接收 2000 字节，底层可能将数据拆成多个 TCP/IP 报文。常见以太网 MTU 1500 字节说明：扣除 IP/TCP 首部后，单段数据常见约为 1460 字节。

因此第一次 recv() 可能只得到 1460 字节，剩余 540 字节稍后才到达：

1
一个应用层数据包：2000 字节
2

3
第一次 recv：1460 字节
4
第二次 recv： 540 字节
5
合计：       2000 字节

如果接收方只调用一次 recv()，剩余 540 字节会留在 TCP 接收缓冲区中。下一轮程序又先接收“长度”，就可能把这 540 字节的开头误当成下一个包的长度，后续数据全部错位。

3. offset 和 packLen 的作用#

每次接收的位置和剩余空间分别是：

1
pack + offset
2
packLen

每次成功接收后更新：

1
offset += nRecvNum;
2
packLen -= nRecvNum;

当 packLen == 0 时，说明当前包已经完整接收。

4. 两层循环分别负责什么#

• 外层 while (m_bRunning)：不断接收多个数据包。
• 内层 while (packLen > 0)：保证当前一个包的数据体全部收完。

每开始接收一个新包之前，必须把：

1
offset = 0;

否则上一个包累计的偏移量会影响下一个包。

5. 为什么输出长度使用 offset，不能使用 packLen#

内层循环会不断执行：

1
packLen -= nRecvNum;

一个完整数据包接收完以后，packLen 已经变成 0。因此测试输出实际接收长度时要使用累计值 offset：

1
cout << "tcpclient recv:" << pack << ", len:" << offset << endl;

1. 服务端初始化流程#

TcpServer::initNet() 的流程为：

1
加载 Winsock 库
2
    ↓
3
创建 TCP 监听套接字
4
    ↓
5
绑定本机 IP 和 TCP_PORT
6
    ↓
7
listen() 进入监听状态
8
    ↓
9
创建接受连接的线程

2. 为什么 accept() 要放在线程中#

accept() 是阻塞函数：没有客户端连接时，它会一直等待。

如果在主线程直接调用 accept()，主线程就无法继续执行其他网络功能。因此创建专门的接受连接线程，并在其中循环调用 accept()，以便连续接受多个客户端。

3. 线程函数为什么需要 pThis#

线程入口是静态成员函数，静态成员函数不能直接访问普通成员变量，所以通过 _beginthreadex() 的参数把当前对象指针 this 传进去：

1
m_handle = (HANDLE)_beginthreadex(nullptr, 0, &acceptThread, this, 0, nullptr);

在线程函数中再转换回来：

1
TcpServer* pThis = (TcpServer*)lpVoid;

之后通过 pThis->m_sock、pThis->m_bRunning 访问当前 TcpServer 对象的成员。

4. 监听套接字和已连接套接字#

服务端中会同时出现两类套接字：

不能使用监听套接字 m_sock 向某个客户端发送聊天数据，应该使用该客户端对应的已连接套接字。