C:\Users\SFM301\Documents\untitled6\main.cpp:18: error: allocation of incomplete type 'Worker'-QT开发中文网

这个错误是因为在 MyTcpServer 类的 incomingConnection 函数中创建了一个 Worker 对象，但是编译器无法识别 Worker 类的定义。这可能是由于在类之间的相互引用导致的。

为了解决这个问题，你可以将 Worker 类的定义提前放置在 MyTcpServer 类之前，并在 MyTcpServer.h 文件中添加对 Worker 类的前向声明。

以下是修改后的示例代码：

#include <QtNetwork/QTcpServer>
#include <QtNetwork/QTcpSocket>
#include <QtCore/QThreadPool>

class Worker; // 前向声明

class MyTcpServer : public QTcpServer
{
    Q_OBJECT

public:
    explicit MyTcpServer(QObject *parent = nullptr) : QTcpServer(parent) {}

protected:
    void incomingConnection(qintptr socketDescriptor) override;
};

class Worker : public QObject
{
    Q_OBJECT
    
public:
    explicit Worker(qintptr socketDescriptor, QObject *parent = nullptr)
        : QObject(parent), m_socketDescriptor(socketDescriptor) {}
    
public slots:
    void start();
    
signals:
    void finished();

private:
    void processData(QTcpSocket* socket);
    void exec();
    
private:
    qintptr m_socketDescriptor;
};

void MyTcpServer::incomingConnection(qintptr socketDescriptor)
{
    // 创建新的线程来处理连接
    QThread *thread = new QThread(this);
    Worker *worker = new Worker(socketDescriptor);
        
    worker->moveToThread(thread);

    connect(thread, &QThread::started, worker, &Worker::start);
    connect(worker, &Worker::finished, thread, &QThread::quit);

    // 在线程完成工作后清理资源
    connect(thread, &QThread::finished, worker, &Worker::deleteLater);
    connect(thread, &QThread::finished, thread, &QThread::deleteLater);

    thread->start();
}

void Worker::start()
{
    QTcpSocket socket;
        
    if (!socket.setSocketDescriptor(m_socketDescriptor)) {
        emit finished();
        return;
    }
        
    // 处理客户端连接...
        
    connect(&socket, &QTcpSocket::readyRead, this, [this]() {
        processData(static_cast<QTcpSocket*>(sender()));
    });
        
    connect(&socket, &QTcpSocket::disconnected, this, [this]() {
        QTcpSocket* socket = static_cast<QTcpSocket*>(sender());
        socket->deleteLater();

        emit finished();
    });

    exec();
}

void Worker::processData(QTcpSocket* socket)
{
    QByteArray data = socket->readAll();

   // 处理数据...

   qDebug() << "Received data from client:" << data;

   // 发送响应给客户端
   socket->write("Server response");
}

void Worker::exec()
{
   QThread::currentThread()->exec();
}

int main(int argc, char *argv[])
{
   QCoreApplication a(argc, argv);
   
   MyTcpServer server;
   
   if (!server.listen(QHostAddress::Any, 1234)) {
       qDebug() << "Failed to start server:" << server.errorString();
       return -1;
   }
   
   qDebug() << "Server started. Listening on port" << server.serverPort();

   return a.exec();
}

请尝试使用修改后的代码，并确保在 MyTcpServer.h 文件中添加了 Worker 类的前向声明。这样，编译器就能正确识别 Worker 类的定义，并解决前述的错误。

内容由零声教学AI助手提供，问题来源于学员提问