在 C++ 中的套接字上发送和接收数据答案

【问题标题】：Sending and receiving data on a socket in c++在 C++ 中的套接字上发送和接收数据
【发布时间】：2016-11-03 22:24:00
【问题描述】：

我目前正在学习 C++ 并尝试了解套接字。我以前用 C# 和 Java 的高级语言做过套接字，但在 C++ 中遇到了问题。

我已经浏览了https://msdn.microsoft.com/en-us/library/windows/desktop/ms737593(v=vs.85).aspx 的示例。

我拥有的代码几乎可以正常工作，除了一件事我不确定。当我编写其他套接字应用程序时，我通常在收到换行符之后才会收到响应。

我认为可能 C++ 一次添加 1 个字符并添加到缓冲区，所以当我关闭套接字时，缓冲区将包含接收到的所有内容，但它似乎是一个十六进制值，但十六进制在ascii 转换器似乎打印乱码而不是套接字数据。

下面是我的代码

const int DEFAULT_BUF_LEN = 525;
    InitialiseLibrary initLibrary("tunnel.conf");
    if (initLibrary.initialise(0))
    {
        cout << "Failed to initialise library" << endl;
    }   

    BitsLibrary bitsLibrary;
    StaticSettings staticSettings(&bitsLibrary, "tunnel.conf");

    //Open a socket connection
    WSAData wsaData;
    int iResult;

    SOCKET listenSocket = INVALID_SOCKET;
    SOCKET clientSocket = INVALID_SOCKET;

    struct addrinfo *result = NULL;
    struct addrinfo hints;

    int iSendResult;
    char recvBuf[DEFAULT_BUF_LEN];
    int recBufLen = DEFAULT_BUF_LEN;

    iResult = WSAStartup(MAKEWORD(2, 2), &wsaData);
    if (iResult != 0)
    {
        cout << "WSAStartup Failed with error: " << iResult << endl;
        return EXIT_FAILURE;
    }

    ZeroMemory(&hints, sizeof(hints));
    hints.ai_family = AF_INET;
    hints.ai_socktype = SOCK_STREAM;
    hints.ai_protocol = IPPROTO_TCP;
    hints.ai_flags = AI_PASSIVE;

    iResult = getaddrinfo(NULL, "500", &hints, &result);
    if (iResult != 0)
    {
        cout << "getaddrinfo failed with error: " << iResult << endl;
        return EXIT_FAILURE;
    }

    listenSocket = socket(result->ai_family, result->ai_socktype, result->ai_protocol);
    if (listenSocket == INVALID_SOCKET)
    {
        cout << "Socket failed with error: " << WSAGetLastError() << endl;
        freeaddrinfo(result);
        WSACleanup();
        return EXIT_FAILURE;
    }

    iResult = ::bind(listenSocket, result->ai_addr, (int)result->ai_addrlen);
    if (iResult != 0)
    {
        cout << "bind failed with error: " << iResult << endl;
        FreeAddrInfo(result);
        closesocket(listenSocket);
        WSACleanup();
        return EXIT_FAILURE;
    }

    freeaddrinfo(result);
    iResult = listen(listenSocket, SOMAXCONN);
    if (iResult == SOCKET_ERROR)
    {
        cout << "Listen failed with error: " << WSAGetLastError() << endl;
        closesocket(listenSocket);
        WSACleanup();
        return EXIT_SUCCESS;
    }
    sockaddr_in clientAddr;
    socklen_t sin_size = sizeof(struct sockaddr_in);
    clientSocket = accept(listenSocket, (struct sockaddr*)&clientAddr, &sin_size);
    send(clientSocket, "welcome", string("welcome").length(),0);
    if (clientSocket == INVALID_SOCKET)
    {
        cout << "accept failed with error: " << WSAGetLastError() << endl;
        closesocket(listenSocket);
        WSACleanup();
        return EXIT_FAILURE;
    }

    closesocket(listenSocket);

    do {
        iResult = recv(clientSocket, recvBuf, recBufLen, 0);
        if (iResult > 0)
        {
            cout << "Bytes received: " << iResult << endl;
            cout << "Received: " << recvBuf << endl;

            iSendResult = send(clientSocket, recvBuf, iResult, 0);
            if (iSendResult == SOCKET_ERROR)
            {
                cout << "send failed with error: " << WSAGetLastError() << endl;
                closesocket(clientSocket);
                WSACleanup();
                return EXIT_FAILURE;
            }
            cout << "Bytes sent " << iSendResult << endl;
        }
        else if (iResult == 0)
        {
            cout << "Connection closing" << endl;
        }
        else
        {
            cout << "Recv failed with error: " << WSAGetLastError() << endl;
            closesocket(clientSocket);
            WSACleanup();
            return EXIT_FAILURE;
        }
    } while (iResult > 0);

    iResult = shutdown(clientSocket, SD_SEND);
    if (iResult == SOCKET_ERROR)
    {
        cout << "shutdown failed with error: " << WSAGetLastError() << endl;
        closesocket(clientSocket);
        WSACleanup();
        return EXIT_FAILURE;
    }
    closesocket(clientSocket);
    WSACleanup();

    cout << "Message was: " << recvBuf << endl;

    return EXIT_SUCCESS;

如果我没记错的话，如果我在 C# 中执行此操作并通过 telnet 连接到我的套接字，我可以发送 Hello 但应用程序不会执行任何操作，直到我发送 \r\n 或缓冲区已满。

但是，在我的 C++ 应用程序中，只要我输入 H，我的应用程序就会立即响应打印出仅包含 H 的 recvBuf 以及我假设的大量空白字符（在 cmd 中显示为正方形）是数组缓冲区的空白部分，并发送回复。

【问题讨论】：

标签： c++ sockets winsock

【解决方案1】：

套接字不关心换行符或空值。只有更高级别的流 API 才能做到这一点。重要的是recv() 的返回值。这会准确地告诉您收到了多少字节。超出该计数的缓冲区中没有任何内容是有效的。

【讨论】：

啊，我认为可能是这种情况，所以 C++ 中没有什么可以为我做这件事，如果我希望 recv 只返回新行，我需要自己编写代码，没有库或 C++ 的任何部分可以做到这一点
@Boardy 有关于无限库这样做（大多数都很糟糕，但仍然如此）。

【解决方案2】：

在流式传输协议中，建立用于确定内容长度的协议很有用。

例如，客户端可以发送内容长度后跟数据，服务器将首先读取内容长度，然后循环读取套接字并缓冲数据，直到接收到内容长度字节数。

【讨论】：