C++ 多线程 TCP 服务器问题答案

【问题标题】：C++ Multithreaded TCP Server IssueC++ 多线程 TCP 服务器问题
【发布时间】：2012-10-22 10:46:30
【问题描述】：

我正在编写一个简单的 TCP 服务器。我想到的模型是服务器在主线程中接受客户端连接并将它们交给另一个线程，以便服务器可以再次监听连接。我使用的代码的相关部分发布在下面：

接受连接：

void startServer () {

    int serverSideSocket = 0;
    int clientSideSocket = 0;

    serverSideSocket = socket(AF_INET, SOCK_STREAM, 0);
    if (serverSideSocket < 0) {
        error("ERROR opening socket");
        exit(1);
    }

    clientAddressLength = sizeof(clientAddress);
    memset((char *) &serverAddress, 0, sizeof(serverAddress));
    memset((char *) &clientAddress, 0, clientAddressLength);

    serverAddress.sin_family = AF_INET;
    serverAddress.sin_addr.s_addr = INADDR_ANY;
    serverAddress.sin_port = htons(32000);

    if (bind(serverSideSocket, (struct sockaddr *) &serverAddress, sizeof(serverAddress)) < 0) {
        error("ERROR on binding");
        exit(1);
    }      

    listen(serverSideSocket, SOMAXCONN);

    while(true) {
        clientSideSocket = accept(serverSideSocket, (struct sockaddr *) &clientAddress, &clientAddressLength);

    if (clientSideSocket < 0)
            error("ERROR on accept");

        processingThreadGroup->create_thread(boost::bind(process, clientSideSocket, this));
    }

}

这里，processingThreadGroup 是一个 boost::thread_group 实例。在处理方法中：

void process (int clientSideSocket, DataCollector* collector) {

int numberOfCharactersRead = 0;
string buffer;

do {
      char msgBuffer[1000];
      numberOfCharactersRead = recv(clientSideSocket, msgBuffer, (1000 - 1), 0);
      if (numberOfCharactersRead < 0) {
          //display error
          close(clientSideSocket);
      }
      else if (numberOfCharactersRead == 0)
          close(clientSideSocket);
      else {
          printf("%s", msgBuffer);
          memset(msgBuffer, 0, 1000);
      }
   } while (numberOfCharactersRead > 0); 
}

但是，当我调试代码时，我看到当调用处理线程时，主线程不再接受连接。数据仅在 process() 方法内读取。主线程似乎不再运行。我采取的方法有什么问题，有什么建议可以纠正它？

编辑：我想我在这里找到了问题，并将其更新为答案。不会接受，因为我回答了我自己的问题。谢谢大家的帮助！

【问题讨论】：

也许你的主线程由于某种原因没有收到处理器时间。尝试确定你的主线程卡在哪里。在你感觉主线程被冻结的process设置断点并查看主线程执行点。
你的方法很好......你从第二个+调用中得到什么错误？您的第二次以上迭代可能有 clientAddress 和 clientAddressLength 有一些意想不到的东西......你可能应该在接受之前在 while(true) 循环的顶部初始化它们......
'printf("%s", msgBuffer);'第一次似乎有点可疑，因为没有 memset()，但一般来说，为什么未终止字符串的尝试 printf 会填满你的 accept() 线程，我不知道。还是……
@Rost 是的 - 调试 101。如果您只关闭“进程”顶部的客户端套接字并返回会发生什么？
大家好，感谢您的所有建议。我在主循环中放置了一些调试点，但似乎只有生成的线程正在运行。第一次后没有命中主线程调试点。所有后续数据都是通过第一个接受的连接接收的。但是，如果我在打印接收到的数据后关闭客户端套接字，则下一个连接会再次由主线程定向到另一个线程。我不知道为什么会这样。有什么想法吗？

标签： c++ multithreading sockets networking tcp

【解决方案1】：

认为我找到了问题所在。我用它作为服务器来接受系统日志消息。我用于 syslog 消息生成器的代码如下：

openlog ("MyProgram", LOG_CONS | LOG_PID | LOG_NDELAY, LOG_LOCAL0);
cout << "opened the log" << endl;
for (int i = 0 ; i < 10 ; i++) 
{
    syslog (LOG_INFO, "Program started by User %d \n", getuid ());
    syslog (LOG_WARNING, "Beware of the WARNING! \n");
    syslog (LOG_ERR, "fatal ERROR! \n");
}   
closelog ();
cout << "closed the log" << endl;

我使用 rsyslog.conf 文件中的条目将所有 syslog LOG_LOCAL0 应用程序流量发送到服务器正在侦听的相关 TCP 端口。不知何故，syslog 只允许建立一个连接，而不是多个连接。因此，它只在一个线程中使用了一个连接。如果该连接已关闭，则会创建一个新连接。

我检查了一个普通的 tcp 客户端。这很好用，每个接受的连接都会产生多个线程。

【讨论】：