多线程客户端未从服务器接收消息答案

【问题标题】：Multi-threaded client not receiving messages from server多线程客户端未从服务器接收消息
【发布时间】：2013-03-01 02:16:25
【问题描述】：

我有一个多客户端服务器程序。客户端控制台将需要等待用户输入要发送到服务器的消息，并且客户端还需要始终可以接收来自服务器的消息（这种情况会间歇性地发生）。为了做到这一点，我尝试在客户端设置两个线程，一个用于接收，一个用于发送。

最初，客户端程序（我从here 下载）旨在向服务器发送消息并立即接收回消息。这是初始代码（我没有在此处包含函数，因为我知道它们可以工作，并且函数名称是不言自明的）：

int main()
{
//initialize the winsock library
myTcpSocket::initialize();

//get client's information 
string clientName = clientInfo.getHostName();
string clientIPAddress = clientInfo.getHostIPAddress();

//get server's IP address and name
string serverIPAddress = "";
readServerConfig(serverIPAddress);

myHostInfo serverInfo(serverIPAddress,ADDRESS);
string serverName = serverInfo.getHostName();

//create the socket for client
myTcpSocket myClient(PORTNUM);

// connect to the server.
myClient.connectToServer(serverIPAddress, ADDRESS);

int recvBytes = 0;
while (1)
{
    // send message to server
    char messageToServer[MAX_MSG_LEN+1];
    memset(messageToServer, 0, sizeof(messageToServer));
    cout << "[SEND] ";
    cin.getline(messageToServer,MAX_MSG_LEN);

    winLog << "[SEND] " << messageToServer << endl;
    myClient.sendMessage(string(messageToServer));

    if ( !string(messageToServer).compare("Quit") || !string(messageToServer).compare("quit") ) 
        break;

    //receive message from server
    string messageFromServer = "";
    recvBytes = myClient.receiveMessage(messageFromServer);
    if ( recvBytes == -99 ) break;

    cout   << "[RECV:" << serverName << "]: " << messageFromServer << endl;
    winLog << "[RECV:" << serverName << "]: " << messageFromServer << endl;

}

return 1;
}

此代码有效，但由于服务器在接收到消息时并不总是有消息要发送回客户端，这会阻止客户端的进程，这就是我使用如下多线程结构的原因（因上述原因未包含函数），将接收和发送函数分离到不同的线程中：

DWORD WINAPI sendHandleThread(LPVOID threadInfo) //sending thread
{
//this structure contains all the data this callback will work on
myThreadArgument* sendArgument = (myThreadArgument*)threadInfo;

//create the socket for client
myTcpSocket myClient(PORTNUM); //PORTNUM = 1200

// connect to the server.
string serverIPAddress = "";
readServerConfig(serverIPAddress);
myClient.connectToServer(serverIPAddress, ADDRESS);

myHostInfo serverInfo(serverIPAddress,ADDRESS);
string serverName = serverInfo.getHostName();

int recvBytes = 0;

while (1)
{
    // send message to server
    char messageToServer[MAX_MSG_LEN+1];
    memset(messageToServer, 0, sizeof(messageToServer));
    cout << "[SEND] ";
    cin.getline(messageToServer,MAX_MSG_LEN);

    winLog << "[SEND] " << messageToServer << endl;
    myClient.sendMessage(string(messageToServer));

    if ( !string(messageToServer).compare("Quit") || !string(messageToServer).compare("quit") ) 
        break;
}
return 1;
}

DWORD WINAPI recHandleThread(LPVOID threadInfo) //receiving thread
{
//this structure contains all the data this callback will work on
myThreadArgument* recArgument = (myThreadArgument*)threadInfo;

//create the socket for client
myTcpSocket myClient(PORTNUM); //PORTNUM = 1200

// connect to the server.
string serverIPAddress = "";
readServerConfig(serverIPAddress);
myClient.connectToServer(serverIPAddress, ADDRESS);

myHostInfo serverInfo(serverIPAddress,ADDRESS);
string serverName = serverInfo.getHostName();

int recvBytes = 0;

while (1)
{
    //receive message from server
    string messageFromServer = "";
    recvBytes = myClient.receiveMessage(messageFromServer);
    if ( recvBytes == -99 ) break;

    cout   << "[RECV:" << serverName << "]: " << messageFromServer << endl;
    winLog << "[RECV:" << serverName << "]: " << messageFromServer << endl;
}
return 1;
}

int main()
{
//semaphore
mySemaphore coutSemaphore(string(""), 1);

//initialize the winsock library
myTcpSocket::initialize();

//get client's information (assume neither the name nor the address is given)
string clientName = clientInfo.getHostName();
string clientIPAddress = clientInfo.getHostIPAddress();

//get server's IP address and name
string serverIPAddress = "";
readServerConfig(serverIPAddress);

myHostInfo serverInfo(serverIPAddress,ADDRESS);
string serverName = serverInfo.getHostName();

//create sending thread
myTcpSocket send;
string sendName = "sendName";
myThreadArgument* sendArgument = new myThreadArgument(&send, &coutSemaphore, sendName);
myThread* sendThread = new myThread(sendHandleThread, (void*)sendArgument);
sendThread->execute();

//create receiving thread
myTcpSocket rec;
string recName = "recName";
myThreadArgument* recArgument = new myThreadArgument(&rec, &coutSemaphore, recName);
myThread* recThread = new myThread(recHandleThread, (void*)recArgument);
recThread->execute();

while (1)
{

    //dummy process
    Sleep(30000);
    cout << "--" << endl;

}

return 1;
}

我已经测试过我已经正确设置了线程 - 但只有我的发送线程工作，即当用户输入消息时，它将被发送到服务器并由服务器接收。但是，我似乎无法从我的服务器接收消息。

我是新手 - 我做错了什么吗？抱歉，如果问题不够清楚 - 我不知道还需要什么。

我的服务器代码的相关 sn-p 在这里供参考（我不知道是否需要更多，因为服务器部分似乎按照我需要的方式工作） - 目前我已经设置它用于测试，以便当它收到来自客户端的消息时，它会立即“回复”（这样我就可以在我的客户端上测试接收线程）。随后它不会立即回复，但只有当它有消息要传递给客户端时。

DWORD WINAPI clientHandleThread(LPVOID threadInfo)
{
     // this structure will contain all the data this callback will work on
     myThreadArgument* clientArgument = (myThreadArgument*)threadInfo;

   // get the client connection: receiving messages from client and
   // sending messages to the client will all be done by using
   // this client connection
   myTcpSocket* clientConnection = clientArgument->getClientConnect();
   string clientName = clientArgument->getHostName();

   // the server is communicating with this client here
   while(1)
   {
       string messageFromClient = "";

       // receive from the client

       int numBytes = clientConnection->recieveMessage(messageFromClient);
       if ( numBytes == -99 ) break;

       cout   << "[RECV fr " << clientName << "]: " << messageFromClient << endl;

       // if the client wants to disconnect
       if ( messageFromClient.compare("quit") == 0 || messageFromClient.compare("Quit") == 0 )
       {
           break;
       }
       else // send to the client
      {
           clientConnection->sendMessage(string("testing")); //test reply
       }
   }

   // if we reach here, this session with the client is done,
   // so we set the event on this thread to inform the main
  // control that this session is finished
   clientArgument->getExitEvent()->setEvent();
   return 1;
}

【问题讨论】：

我的猜测是服务器可能没有向您的客户端发送任何内容，或者它没有发送recieveMessage() 期望的数据格式。 recieveMessage() 在返回之前期望接收多少字节？它实际接收多少字节？您可能想在 recieveMessage() 实现中放置一些 printf 以查看其中发生了什么...或运行 WireShark 以查看实际从服务器进入您的计算机的字节，或两者兼而有之...
服务器正在向客户端发送消息（如果接收和发送功能在同一个线程中，我可以接收它。只有当它们分开时程序似乎收不到任何东西的线程
当两个函数在同一个线程中时，服务器正在向客户端发送消息。当函数在不同的线程中时，您如何证明它正在向客户端发送消息？

标签： c++ sockets client-server client-side

【解决方案1】：

在您的多线程程序中，您正在创建两个客户端，一个在sendHandleThread 中，另一个在recHandleThread 中，因此有两个连接。当然，服务器通过客户端消息进入的连接发送其回复消息，即。 e.到sendHandleThread，它不准备接收它，而recHandleThread 通过它的连接没有收到任何东西，因为那里没有发送任何东西。要解决这个问题，您必须只创建一个客户端连接并让两个线程使用相同的连接。

【讨论】：