在 C++ 中使用套接字 io 获取动态字节数

Question

我正在尝试实现一个简单的客户端-服务器应用程序，其中客户端或服务器可以在单个 write() 调用中发送动态字节数。

例如，假设客户端发送一个 1500 字节的字节流。服务器每 1000 个字节读取一次。

int BUFFER_SIZE = 1000;
...
read( iSockFD, cBuffer, BUFFER_SIZE );

我可以使用循环并调用 read，直到它的返回值为 0。但是客户端可能在一个循环中有多个write()调用（即发送多条消息）。

我的问题是，它会影响服务器端的read() 吗？意思是，客户端的两个连续的 1000 字节的 write() 会被服务器端的 2000 字节缓冲区大小的单个 read() 读取吗？

如果是这样，那么推荐的实现这种场景的方法是什么？我应该对消息使用分隔符（使用编码算法）吗？

我理解这与套接字本身而不是 C++ 更相关。但是，我们非常感谢您的帮助和指导。

更新：

目的是实现一个简单的中间件系统来发送不同类型的消息，其中消息在发送之前将被编码为二进制。

Answer 1

没有人能保证一个 write(x) 会在接收端触发一个 read(x)。如果 x 大于您的套接字接收缓冲区，或者如果您在套接字接收缓冲区中接收到整个消息之前调用 read()，则 read() 将仅返回一小部分数据并要求您发出后续读取() 得到其余的。

推荐的方法是定义一个足够大的消息缓冲区。每次调用 read() 都将返回 1 个或更多字节，您会一直将其排入缓冲区。现在，一旦缓冲区大于 4 个字节 + 存储在缓冲区前 4 个字节中的 be32toh(integer) ，您必须消耗整数加上缓冲区开头的以下 x 个字节（并进一步处理它们）。这将允许您很好地处理 read() 包含以前未完成的数据包的结尾并同时包含下一个（不完整）数据包的开头的情况。

只需确保您传输的每个有效负载都以 htobe32(length) 开头。