2

目前我正在用 C++ 创建一个客户端服务器控制台应用程序。通过使用winsock2.h库和 UDP 协议，我们使用sendtoandrecvfrom将消息作为字符串从客户端发送到服务器，然后服务器将消息发送到不同的客户端，现在如果客户端 1 向客户端 2 发送消息，客户端 2 将不会收到消息，直到他们尝试向 client1 发送消息。我希望让程序像即时通讯工具一样工作，这样当客户端 1 向客户端 2 发送消息时，客户端 2 几乎会立即收到它，而无需先发送消息。

此外，如果客户端 1 向客户端 2 发送消息，客户端 1 将无法发送另一条消息，除非客户端 2 已回复第一个消息。

如果您需要更多信息或查看一些代码，请询问。

发送代码：

while( getline( cin, line ) )
{
    // send a string to the server.
    sendto( hSocket, line.c_str(), line.size(), 0, 
        reinterpret_cast<sockaddr*>( &serverAddress ),
        sizeof( serverAddress ) );

    // recieve the response.
    int n = recvfrom( hSocket, recvLine, MAXLINE, 0, NULL, NULL );
    if( n == -1 )
    {
        cout << "no reply" << endl;
    }
    else
    {
        recvLine[n] = 0;
        string const terminateMsg = "server exit";
        string msg = recvLine;
        if( msg == terminateMsg )
        {
            cout << "Server terminated" << endl;
            break;
        }
        cout << n << ": " << recvLine << endl;
    }
}
4

1 回答 1

1

现在，如果客户端 1 向客户端 2 发送消息，客户端 2 在尝试向客户端 1 发送消息之前不会收到该消息。

你已经这样编码了。

此外，如果客户端 1 向客户端 2 发送消息，客户端 1 将无法发送另一条消息，除非客户端 2 已回复第一个消息。

同样，您已经以这种方式对其进行了编码。您的代码假定 everysendto()后跟一个recvfrom(). 但你的问题表明这不是你想要的。我在下面的代码中添加了一些注释

while( getline( cin, line ) )
{
    // send a string to the server. <-- will never get here a 2nd time through the loop without recvfrom() returning
    sendto( hSocket, line.c_str(), line.size(), 0, 
        reinterpret_cast<sockaddr*>( &serverAddress ),
        sizeof( serverAddress ) );

    // recieve the response. <--- will never get here without getline() returning
    int n = recvfrom( hSocket, recvLine, MAXLINE, 0, NULL, NULL );
    if( n == -1 )
    {
        cout << "no reply" << endl;
    }
    else
    {
        recvLine[n] = 0;
        string const terminateMsg = "server exit";
        string msg = recvLine;
        if( msg == terminateMsg )
        {
            cout << "Server terminated" << endl;
            break;
        }
        cout << n << ": " << recvLine << endl;
    }
}

我希望让程序像即时通讯工具一样工作，这样当客户端 1 向客户端 2 发送消息时，客户端 2 几乎会立即收到它，而无需先发送消息。

使用 Boost.Asio 和异步套接字，异步chat_client 示例使用 TCP 套接字完美地完成了这件事，修改 UDP 示例相当简单。异步UDP 回显服务器示例也可能很有用。你会想要使用boost::asio::ip::udp::socket::async_recv_from()and boost::asio::ip::udp::socket::async_send_to()。其他 BSD 套接字接口具有文档中描述的等效映射。

于 2012-04-10T01:35:52.353 回答