QT线程池服务器在CentOS7无响应问题排查求助

问题现象 #

• Windows 32/64位系统中服务器运行正常，客户端连接交互无问题；
• CentOS 7系统中服务器地址127.0.0.1:8080可通过telnet建立连接，但后续无任何交互；
• HTTP请求处理器未被触发，服务器构造函数中的输出语句执行后返回-1，对应错误信息为QAbstractSocket::UnknownSocketError -1 发生了未识别的错误；
• 已通过netstat检查开放端口，疑似存在配置遗漏或代码逻辑问题。

相关代码 #

QThreadPoolServer.cpp #

#include "QThreadPoolServer.h"
#include "QSocketRunnable.h"
#include "ConfigReader.h"
#include <memory>

QThreadPoolServer::QThreadPoolServer()
{
    ConfigReader reader(config_file_path);

    QHostAddress server_IP(reader.getServerAddress());
    int port = reader.getServerPort();

    listen(QHostAddress::localhost, 8080); 
    std:: cout << serverError() << errorString().toStdString();
    m_threadPool = std::make_shared<QThreadPool>(this);
}

void QThreadPoolServer::incomingConnection(int handle)
{
    std::shared_ptr<QSocketRunnable> runnable = std::make_shared<QSocketRunnable>(handle);
    runnable->setAutoDelete(false);
    m_threadPool->start(runnable.get());
}

QThreadPoolServer::~QThreadPoolServer()
{
    m_threadPool->~QThreadPool();
}

QThreadPoolServer.h #

#ifndef QTHREADPOOLSERVER_H
#define QTHREADPOOLSERVER_H

#include <QTcpServer>
#include <QThreadPool>
#include <memory>

class QThreadPoolServer : public QTcpServer
{
public:
    explicit QThreadPoolServer();

    void incomingConnection(int handle);

    ~QThreadPoolServer();
private:
    std::shared_ptr<QThreadPool> m_threadPool;
};

#endif // QTHREADPOOLSERVER_H

QSocketRunnable.cpp #

#include "QSocketRunnable.h"
#include <QString>
#include <memory>
#include <iostream>


QSocketRunnable::QSocketRunnable(int handle) : m_descriptor(handle) { }

void QSocketRunnable::run()
{
    QTcpSocket* socket = new QTcpSocket();
    socket->setSocketDescriptor(m_descriptor);
    socket->waitForReadyRead();
    QString request_data = QString(socket->readAll());

    HttpRequestHandler handler(request_data);
    handler.makeResponse();

    QString http_response_result = handler.getHttpResponse();
    std::cout << http_response_result.toStdString() << "\n";
    socket->write(http_response_result.toUtf8());
    socket->waitForBytesWritten(90000);

    socket->disconnectFromHost();
    socket->close();
    socket->deleteLater();
}

QSocketRunnable.h #

#ifndef QSOCKETRUNNABLE_H
#define QSOCKETRUNNABLE_H

#include <QRunnable>
#include <QTcpSocket>
#include <QtDebug>
#include <QString>

//#include "IDHelper.h"
//#include "JsonFormatter.h"
//#include "HttpRequestHandler.h"

class QSocketRunnable : public QRunnable
{
public:
    QSocketRunnable(int handle);
    void run() override;
private:
    int m_descriptor;
};

#endif // QSOCKETRUNNABLE_H

main.cpp #

#include <QCoreApplication>
#include "QThreadPoolServer.h"
#include "signal.h"
#include <sstream>


int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    QThreadPoolServer server;

    return a.exec();
}

问题排查与修复方案 #

1. 服务器监听初始化错误 #

构造函数中listen(QHostAddress::localhost, 8080)硬编码端口，同时读取配置文件的IP和端口却未使用，且未检查listen返回值。serverError()返回-1说明监听初始化失败，可能是CentOS下端口权限或地址绑定问题。

• 修复：使用配置文件读取的IP和端口，添加返回值检查：

  if (!listen(server_IP, port)) {
      std::cerr << "监听失败: " << errorString().toStdString() << std::endl;
  } else {
      std::cout << "服务器启动成功，监听地址: " << server_IP.toString().toStdString() << ":" << port << std::endl;
  }
  

• 若仍报错，通过netstat -tulpn | grep 8080排查端口占用情况，非特权端口（8080）无需root权限，但需确保无其他进程占用。

2. QThreadPool内存管理错误 #

• 使用std::make_shared<QThreadPool>(this)将QTcpServer实例作为父对象，QThreadPool本身由Qt对象树管理，无需std::shared_ptr包裹，易导致内存混乱；
• 析构函数手动调用m_threadPool->~QThreadPool()会触发双重析构，属于错误操作。
• 修复：将m_threadPool改为普通指针，利用Qt对象树自动管理：

  // QThreadPoolServer.h修改成员变量
  QThreadPool* m_threadPool;
  
  // 构造函数初始化
  m_threadPool = new QThreadPool(this);
  
  // 析构函数删除手动析构语句
  QThreadPoolServer::~QThreadPoolServer()
  {
      // 无需手动销毁，Qt对象树自动处理
  }
  

  也可直接使用全局线程池QThreadPool::globalInstance()简化逻辑。

3. QRunnable生命周期管理错误 #

• 使用std::shared_ptr管理Runnable，却设置setAutoDelete(false)，同时将原始指针交给线程池，易导致Runnable提前销毁或内存泄漏。
• 修复：让线程池自动管理Runnable生命周期：

  void QThreadPoolServer::incomingConnection(int handle)
  {
      QSocketRunnable* runnable = new QSocketRunnable(handle);
      runnable->setAutoDelete(true);
      m_threadPool->start(runnable);
  }
  

4. QTcpSocket阻塞调用无超时 #

• socket->waitForReadyRead()默认无超时，客户端建立连接后未发送数据会导致永久阻塞，表现为无交互；
• waitForBytesWritten(90000)超时时间过长，不合理。
• 修复：添加合理超时时间：

  if (!socket->waitForReadyRead(30000)) {
      std::cerr << "等待数据超时" << std::endl;
      socket->close();
      delete socket;
      return;
  }
  // 调整写操作超时
  socket->waitForBytesWritten(5000);
  

5. 头文件缺失问题 #

QSocketRunnable.h中注释了#include "HttpRequestHandler.h"，但cpp文件中实例化了该类，可能导致编译链接异常或运行时逻辑错误，使得处理器未触发。

• 修复：取消注释#include "HttpRequestHandler.h"，确保依赖头文件正常引入。

6. 标准输出缓冲问题 #

CentOS下std::cout默认行缓冲，若输出未换行或刷新，可能看不到构造函数的输出，误以为未执行。

• 修复：添加换行或刷新操作：

  std::cout << serverError() << errorString().toStdString() << std::endl;
  

内容的提问来源于stack exchange，提问作者wwqeee