我正在通过TCP / IP发送消息,我需要在char数组中为消息长度添加前缀,然后发送它.我该怎么做? 还请你提供一个如何在另一端提取它的例子.如果可能的话,请解释一下. 我正在使用C和Win
还请你提供一个如何在另一端提取它的例子.如果可能的话,请解释一下.
我正在使用C和Winsock.
编辑:
string writeBuffer = "Hello"; unsigned __int32 length = htonl(writeBuffer.length());
它没有返回正确的长度而是非常大的数字.
对于接收部分,如果我使用ntohl(),那么我也得到一个大数而不是正确的长度?为什么会这样?我收到这样的
bool Server::Receive(unsigned int socketIndex) { // Read data from the socket if (receivingLength) { bytesReceived = recv(socketArray[socketIndex - WSA_WAIT_EVENT_0], ((char*)&messageLength) + bytesReceived, MESSAGE_LENGTH_SIZE - bytesReceived, 0); if (bytesReceived == SOCKET_ERROR) { return false; } if (bytesReceived == MESSAGE_LENGTH_SIZE) { // If uncomment the following line, // I won't get the correct length, but a large number //messageLength = ntohl(messageLength); receivingLength = false; bytesReceived = 0; bytesLeft = messageLength; } } else { if (bytesLeft > BUFFER_SIZE) { return false; } bytesReceived = recv(socketArray[socketIndex - WSA_WAIT_EVENT_0], &receiveBuffer[bytesReceived], bytesLeft, 0); if (bytesReceived == SOCKET_ERROR) { return false; } if (bytesReceived == messageLength) { // we have received full message messageReceived = true; receiveBuffer[bytesReceived] = '\0'; // wait for next message receivingLength = true; } bytesLeft -= bytesReceived; } return true; }在TCP流上发送长度字段时,您需要确定两件事:
>长度应该是多长(1字节,2字节,4字节,可变长度)
>我应该使用什么字节序
我建议使用4个字节的长度和网络字节顺序(即big-endian).对于网络字节顺序,宏htonl和ntohl将在主机(本机)字节顺序(在您的情况下为little-endian)和网络字节顺序之间进行转换.
要发送数据,片段应如下所示:
size_t length = strlen(data); uint32_t nlength = htonl(length); send(sock, &nlength, 4, 0); send(sock, data, length, 0);
在接收方,首先提取长度,然后提取数据:
uint32_t length, nlength; recv(sock, &nlength, 4, 0); length = ntohl(nlength); data = malloc(length+1); recv(sock, data, length, 0); data[length] = 0;
缺少此代码的是错误处理:每个发送和接收调用都可能失败; recvs可能收到的数据少于预期.但这应该给你一个想法.
编辑:要处理recv返回的数据太少的情况,请在循环中运行它,保持到目前为止所读取内容的计数,例如:
int length_bytes = 0; while(length_bytes < 4){ int read = recv(sock, ((char*)&nLength)+length_bytes, 4-length_bytes, 0); if (read == -1) some_error_occurred_check_errno(); length_bytes += read; }