recv(socket, buf, len, flags)来接收传入的数据包，但是在运行时我并不知道这个数据包的长度，因此前8个字节应该告诉我这个数据包的长度。我不想随意分配一个大的len来解决这个问题，所以能否将len = 8，让buf是uint64_t类型。然后之后用memcpy(dest, &buf, buf)来复制？由于TCP是基于流的，我不确定你指的是什么类型的数据包。我会假设你是指应用程序级别的数据包。我的意思是这些数据包是由你的应用程序定义的，而不是由底层协议如TCP定义的。为了避免混淆，我将它们称为消息。
我将展示两种可能性。首先，我将展示如何在读取完成之前不知道消息长度的情况下读取消息。第二个例子将进行两次调用。首先它读取消息的大小。然后一次性读取整个消息。
由于TCP是基于流的，当您的缓冲区不够大时，您不会丢失任何数据。因此，您可以读取固定数量的字节。如果有数据缺失，您可以再次调用recv。这里是一个详细的例子。我只是写了一下，没有测试过。希望一切都能正常工作。
std::size_t offset = 0;
std::vector<char> buf(512);
std::vector<char> readMessage() {
while (true) {
ssize_t ret = recv(fd, buf.data() + offset, buf.size() - offset, 0);
if (ret < 0) {
if (errno == EINTR) {
// Interrupted, just try again ...
continue;
} else {
// Error occured. Throw exception.
throw IOException(strerror(errno));
}
} else if (ret == 0) {
// No data available anymore.
if (offset == 0) {
// Client did just close the connection
return std::vector<char>(); // return empty vector
} else {
// Client did close connection while sending package?
// It is not a clean shutdown. Throw exception.
throw ProtocolException("Unexpected end of stream");
}
} else if (isMessageComplete(buf)) {
// Message is complete.
buf.resize(offset + ret); // Truncate buffer
std::vector<char> msg = std::move(buf);
std::size_t msgLen = getSizeOfMessage(msg);
if (msg.size() > msgLen) {
// msg already contains the beginning of the next message.
// write it back to buf
buf.resize(msg.size() - msgLen)
std::memcpy(buf.data(), msg.data() + msgLen, msg.size() - msgLen);
msg.resize(msgLen);
}
buf.resize(std::max(2*buf.size(), 512)) // prepare buffer for next message
return msg;
} else {
// Message is not complete right now. Read more...
offset += ret;
buf.resize(std::max(buf.size(), 2 * offset)); // double available memory
}
}
}
bool isMessageComplete(std::vector<char>)和std::size_t getSizeOfMessage(std::vector<char>)。
第二种可能性是先读取头文件，只需8个字节，其中包含包的大小。之后，你就知道了包的大小。这意味着你可以分配足够的存储空间，并一次性读取整个消息：
/// Reads n bytes from fd.
bool readNBytes(int fd, void *buf, std::size_t n) {
std::size_t offset = 0;
char *cbuf = reinterpret_cast<char*>(buf);
while (true) {
ssize_t ret = recv(fd, cbuf + offset, n - offset, MSG_WAITALL);
if (ret < 0) {
if (errno != EINTR) {
// Error occurred
throw IOException(strerror(errno));
}
} else if (ret == 0) {
// No data available anymore
if (offset == 0) return false;
else throw ProtocolException("Unexpected end of stream");
} else if (offset + ret == n) {
// All n bytes read
return true;
} else {
offset += ret;
}
}
}
/// Reads message from fd
std::vector<char> readMessage(int fd) {
std::uint64_t size;
if (readNBytes(fd, &size, sizeof(size))) {
std::vector buf(size);
if (readNBytes(fd, buf.data(), size)) {
return buf;
} else {
throw ProtocolException("Unexpected end of stream");
}
} else {
// connection was closed
return std::vector<char>();
}
}
MSG_WAITALL标志要求函数阻塞，直到完整的数据可用。但是，您不能依赖它。您必须检查它，并在缺少某些内容时再次读取。就像我上面所做的一样。
readNBytes(fd, buf, n)读取 n 字节。只要连接没有从另一端关闭，该函数将不会返回而不读取 n 字节。如果连接已由另一端关闭，则该函数返回false。如果在传输消息过程中连接被关闭，则会抛出异常。如果发生输入/输出错误，则会抛出另一个异常。
readMessage 读取8个字节 [sizeof(std::unit64_t)] 并将其用作下一个消息的大小。然后它读取消息。size转换为定义的字节顺序。计算机（使用x86架构）使用小端字节序。在网络传输中使用大端字节序是常见的。
注意: 使用MSG_PEEK可以实现UDP的此功能。您可以在使用此标志时请求标头。然后，您可以为整个包分配足够的空间。recv调用有任何特定的期望。TCP提供了一个双向字节流给应用程序，而不是一个数据包或消息接口。 - David Schwartz由于TCP是流式的，你接收到的数据没有真正的终点，除非连接关闭或出现错误。
因此，你需要在TCP上实现自己的协议，其中包含特定的消息结束标记、数据长度头字段或可能的基于命令的协议，其中每个命令的数据都具有已知的大小。
这样，你就可以读入一个小的固定大小的缓冲区，并根据需要将其添加到一个较大的（可能会扩展）缓冲区中。在C++中，“可能扩展”的部分非常容易，因为有 std::vector 和 std::string（取决于你所拥有的数据）。
还有一件重要的事情要记住，由于TCP是基于流的，单个read或recv调用可能并不实际获取你请求的所有数据。你需要循环接收数据，直到你接收到所有数据。
while( recv(socket, buf, len, flags) > 0) {...}？ - Math is Hardstd::vector中，可能还存储一些标志以检测消息何时完成，然后只需迭代整个向量处理整个消息。因此，不需要附加字节和调整字节缓冲区的大小（尽管处理消息可能变得不那么直观；具体取决于您想要对字节执行什么操作）。 - JustAMartin