我有两个应用程序，一个服务器和另一个客户端，都是用 C++ 和 Qt 编写的，但它们都使用 C 库，该库使用 C 套接字方法在它们之间执行套接字通信(这一切都在 Linux 中)。

当它们都已连接并且我关闭客户端时，当服务器尝试向其发送新消息时，它收到 SIGPIPE 错误并关闭。我在网络和 SO 中做了一些研究，看看如何为 SIGPIPE 创建一个处理程序，而不是关闭应用程序，我会告诉不断发送信息的计时器停止。

现在我确实学会了如何简单地处理信号:创建一个接收 int 的方法并在 main() 或全局中使用 signal(SIGPIPE, myMethod)(注意:从 SO 中了解到，是的，我知道 signal( ) 已过时)。

但问题是，通过这种方式我无法停止向死客户端发送信息，因为处理信号的方法需要在发送消息的类之外或静态方法中，它无权访问我的服务器对象。

澄清一下，这是当前的架构:

// main.cpp

void signal_callback_handler(int signum)
{
    qDebug() << "Caught signal SIGPIPE" << signum << "; closing the application";

    exit(EXIT_FAILURE);
}

int main(int argc, char *argv[])
{
    QApplication app(argc, argv);
    app.setApplicationName("ConnEmulator");
    app.setApplicationVersion("1.0.0");
    app.setOrganizationName("Embrasul");
    app.setOrganizationDomain("http://www.embrasul.com.br");

    MainWidget window;
    window.show();

    /* Catch Signal Handler SIGPIPE */
    signal(SIGPIPE, signal_callback_handler);

    return app.exec();
}

//MainWidget 类(简化)

MainWidget::MainWidget(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::MainWidget),
    timerSendData(new QTimer(this))
{
    ui->setupUi(this);

    connect(timerSendData,SIGNAL(timeout()),this,SLOT(slotSendData()));

    timerSendData->start();
    //...
}

void MainWidget::slotSendData()
{
    //Prepares data
    //...

    //Here the sending message is called with send()
    if (hal_socket_write_to_client(&socket_descriptor, (u_int8_t *)buff_write, myBufferSize) == -1)
        qDebug() << "Error writting to client";
}

//套接字库

int hal_socket_write_to_client(socket_t *obj, u_int8_t *buffer, int size)
{
    struct s_socket_private * const socket_obj = (struct s_socket_private *)obj;
    int retval = send(socket_obj->client_fd, buffer, size, 0);

    if (retval < 0)
        perror("write_to_client");

    return retval;
}

那么如何让在 int main() 中创建的 MainWidget 对象处理信号，以便他可以调用 timerSendData->stop()？

最佳答案

SIGPIPE 很丑陋，但可以通过完全封装、线程安全的方式处理，并且除了编写可能导致 SIGPIPE。一般的方法是:

1. 用pthread_sigmask(或sigprocmask，但后者在多线程程序中不保证安全)阻止SIGPIPE并保存原始信号掩码。

2. 执行可能引发 SIGPIPE 的操作。

3. 使用零超时调用 sigtimedwait 以消耗任何待处理的 SIGPIPE 信号。

4. 恢复原始信号掩码(如果之前已解锁，则解锁 SIGPIPE)。

下面是一些使用此方法的示例代码的尝试，以纯包装器的形式 write 避免了 SIGPIPE:

ssize_t write_nosigpipe(int fd, void *buf, size_t len)
{
    sigset_t oldset, newset;
    ssize_t result;
    siginfo_t si;
    struct timespec ts = {0};

    sigemptyset(&newset);
    sigaddset(&newset, SIGPIPE);
    pthread_sigmask(SIG_BLOCK, &newset, &oldset);

    result = write(fd, buf, len);

    while (sigtimedwait(newset, &si, &ts)>=0 || errno != EAGAIN);
    pthread_sigmask(SIG_SETMASK, &oldset, 0);

    return result;
}

它未经测试(甚至未编译)并且可能需要进行小的修复，但希望能够理解要点。显然，为了提高效率，您希望在比单个 write 调用更大的粒度上执行此操作(例如，您可以在整个库函数的持续时间内阻止 SIGPIPE 直到它返回给外部调用者)。

另一种设计是简单地阻塞 SIGPIPE 并且从不解除阻塞，并在函数的接口(interface)中记录它使 SIGPIPE 阻塞(注意:阻塞是线程局部的并且不影响其他线程)并且可能使 SIGPIPE 挂起(处于阻塞状态)。然后调用者将负责在必要时恢复它，因此想要 SIGPIPE 的罕见调用者可以通过解锁信号来获得它(但在你的函数完成之后)，而大多数来电者可以愉快地阻止它。阻塞代码的工作方式与上面类似，只是删除了 sigtimedwait/unblocking 部分。这类似于 Maxim 的回答，只是影响是线程局部的，因此是线程安全的。

关于c++ - 如何处理生成它的对象内部的 SIGPIPE 错误？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24920748/