qt多线程tcp文件传输

在Qt中使用多线程进行TCP文件传输可以分为以下几个步骤：

1. 创建一个TCP服务器和一个TCP客户端。
2. 在TCP服务器中，为每个连接创建一个线程，并在该线程中处理文件的传输。
3. 在TCP客户端中，创建一个线程，该线程负责发送文件给服务器。
4. 在服务器和客户端之间建立连接后，客户端将文件发送到服务器。
5. 服务器收到文件后，在相应的线程中将文件保存到本地。

下面是一个简单的示例代码，可以供您参考：

1. TCP服务器端代码：

void Server::startServer()
{
    tcpServer = new QTcpServer(this);
    connect(tcpServer, SIGNAL(newConnection()), this, SLOT(newConnection()));

    if (!tcpServer->listen(QHostAddress::Any, 12345)) {
        qDebug() << "Unable to start the server: " << tcpServer->errorString();
        return;
    }
    qDebug() << "Server is running on port " << tcpServer->serverPort();
}

void Server::newConnection()
{
    QTcpSocket* clientSocket = tcpServer->nextPendingConnection();
    ServerThread* thread = new ServerThread(clientSocket, this);
    connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));
    thread->start();
}

2. TCP服务器端线程代码：

ServerThread::ServerThread(qintptr socketDescriptor, QObject *parent)
    : QThread(parent), socketDescriptor(socketDescriptor)
{
}

void ServerThread::run()
{
    QTcpSocket tcpSocket;
    if (!tcpSocket.setSocketDescriptor(socketDescriptor)) {
        return;
    }

    QFile file("/path/to/save/file");
    if (!file.open(QIODevice::WriteOnly)) {
        return;
    }

    QByteArray buffer;
    while (tcpSocket.bytesAvailable() > 0) {
        buffer = tcpSocket.read(1024);
        file.write(buffer);
    }

    file.close();
}

3. TCP客户端代码：

void Client::sendFile(QString filePath)
{
    QThread* thread = new QThread();
    ClientWorker* worker = new ClientWorker(filePath);
    worker->moveToThread(thread);

    connect(thread, SIGNAL(started()), worker, SLOT(sendFile()));
    connect(worker, SIGNAL(finished()), thread, SLOT(quit()));
    connect(worker, SIGNAL(finished()), worker, SLOT(deleteLater()));
    connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));

    thread->start();
}

4. TCP客户端线程代码：

ClientWorker::ClientWorker(QString filePath)
    : filePath(filePath)
{
}

void ClientWorker::sendFile()
{
    QTcpSocket tcpSocket;
    tcpSocket.connectToHost("127.0.0.1", 12345);
    if (!tcpSocket.waitForConnected()) {
        return;
    }

    QFile file(filePath);
    if (!file.open(QIODevice::ReadOnly)) {
        return;
    }

    QByteArray buffer;
    while (!file.atEnd()) {
        buffer = file.read(1024);
        tcpSocket.write(buffer);
    }

    file.close();
}

请注意，这只是一个简单的示例代码，您需要根据您的实际需求进行修改和优化。同时，确保您的代码具有足够的安全性和可靠性，以避免数据丢失和安全问题。