c ++ system（）挂起使用netcat连接到不同线程中的套接字答案

【问题标题】：c++ system() hangs on using netcat to connect to socket in different threadc ++ system（）挂起使用netcat连接到不同线程中的套接字
【发布时间】：2016-05-15 19:58:39
【问题描述】：

我正在一个单独的线程上启动一个简单的套接字服务器，并尝试在主线程上使用netcat 连接到它。这是代码：

#include <cstdlib>
#include <sys/socket.h>
#include <unistd.h>
#include <netinet/in.h>
#include <iostream>
#include <string>
#include <cstring>

using namespace std;

void* callback(void*);

bool isServerReady = false;

int main()
{
    pthread_t thread;
    int result = pthread_create(&thread, 0, callback, 0);
    if (result != 0) {
        cout << "[ERROR] Unable to create thread" << endl;
    }

    while (!isServerReady) {
    }

    int returnValue = system("echo TEST | netcat localhost 1234");
    cout << "Return value: " << returnValue << endl;
    return 0;
}

void* callback(void* threadId)
{
    int serverSocketId = socket(AF_INET, SOCK_STREAM, 0);
    if (serverSocketId == -1) {
        cout << "[SERVER ERROR] Unable to create server socket." << endl;
        return (void*)-1;
    }

    int serverPort = 1234;
    struct sockaddr_in serverAddress;
    serverAddress.sin_family = AF_INET;
    serverAddress.sin_port = htons(serverPort);
    serverAddress.sin_addr.s_addr = INADDR_ANY;

    int bindReturn = bind(serverSocketId, (struct sockaddr*)&serverAddress, sizeof(serverAddress));
    if (bindReturn == -1) {
        cout << "[SERVER ERROR] Unable to bind server socket." << endl;
        return (void*) -1;
    }

    isServerReady = true;

    int waitQueueSize = 5;
    listen(serverSocketId, waitQueueSize);

    struct sockaddr_in clientAddress;
    socklen_t clientAddressSize = sizeof(clientAddress);
    int clientSocketId = accept(serverSocketId, (struct sockaddr*)&clientAddress, &clientAddressSize);
    if (clientSocketId == -1) {
        cout << "[SERVER ERROR] Unable to create client socket." << endl;
        return (void*)-1;
    }

    char clientBuffer[256];
    bzero(clientBuffer, 256);
    int charsRead = read(clientSocketId, clientBuffer, 255);
    if (charsRead == -1) {
        cout << "[SERVER ERROR] Unable to read client socket." << endl;
        return (void*)-1;
    }

    string serverMessage = "You wrote: ";
    serverMessage.append(clientBuffer);
    int charsWritten = write(clientSocketId, (char*)serverMessage.c_str(), (int)serverMessage.length());
    if (charsWritten == -1) {
        cout << "[SERVER ERRROR] Error writing to client socket." << endl;
        return (void*)-1;
    }

    int closeReturn = close(serverSocketId);
    if (closeReturn == -1) {
        cout << "[SERVER ERROR] Error closing server socket." << endl;
        return (void*)-1;
    }

    return (void*)0;
}

但是，system 函数永远不会返回，导致程序挂起：服务器的响应 "You wrote: TEST" 正确打印在控制台上，但之后程序只是挂起，没有到达打印返回值的行。如果我将相同的服务器代码提取到另一个程序中，启动它，并从命令行使用相同的netcat 调用，我会收到相同的响应消息，然后netcat 退出而无需我做任何事情。

这是编译命令：

g++ -std=c++11 test.cpp -o test -lpthread && ./test

和编译器版本：

g++ (Ubuntu 4.8.4-2ubuntu1~14.04.1) 4.8.4

为什么你认为netcat 在从system() 内部调用时没有返回？

【问题讨论】：

我认为this answer 谈论客户端调用netcat 的部分与您的问题有关。
你没有关闭clientSocketId。
只是对为什么使用 POSIX 线程而不是 C++ 线程感兴趣？另外，您没有将isServerReady 声明为易失性？
感谢您的评论，这只是从一个更大的程序中进行的一个快速而肮脏的实验，而且 C++ 不是我的主要编程语言，所以我仍在学习 C++ 11/14 的新功能:)
@kfsone 谢谢！就是这样:)

标签： c++ multithreading sockets system freeze

【解决方案1】：

感谢@kfsone，问题只是我的服务器从未关闭客户端套接字，从而阻止客户端netcat 意识到服务器不再监听，并使其无缘无故地等待。解决这个问题：

// ...
string serverMessage = "You wrote: ";
serverMessage.append(clientBuffer);
int charsWritten = write(clientSocketId, (char*)serverMessage.c_str(), (int)serverMessage.length());
if (charsWritten == -1) {
    cout << "[SERVER ERRROR] Error writing to client socket." << endl;
    return (void*)-1;
}

// ADDED THIS:
int closeClientReturn = close(clientSocketId);
if (closeClientReturn == -1) {
    cout << "[SERVER ERROR] Error closing client socket." << endl;
    return (void*)-1;
}

int closeReturn = close(serverSocketId);
if (closeReturn == -1) {
    cout << "[SERVER ERROR] Error closing server socket." << endl;
    return (void*)-1;
}

return (void*)0;

【讨论】：