Qt/C++ 实现文件双向传输：从客户端到服务端，再从服务端到客户端-平芜编程栈

Qt/cpp实现的客户端往服务端传输文件、服务端往客户端传输文件，可监测传输状态，可控制传输。源码：使用Qt5.6.1_MinGW编译通过。 c.37

在很多网络应用场景中，文件的双向传输，也就是客户端往服务端传输文件以及服务端往客户端传输文件，并且能够监测传输状态和对传输进行控制，是非常常见的需求。今天就来聊聊如何使用 Qt/C++ 来实现这一功能。

一、环境说明

本文的代码使用 Qt5.6.1_MinGW 编译通过，确保你也配置好了相应的开发环境，以便顺利运行和理解代码。

二、客户端往服务端传输文件

1. 建立连接

首先，我们需要在客户端和服务端之间建立一个 TCP 连接。在 Qt 中，可以使用 QTcpSocket 来实现。

QTcpSocket *socket = new QTcpSocket(this); socket->connectToHost(QHostAddress::LocalHost, 1234); if(socket->waitForConnected(5000)) { qDebug() << "Connected to server!"; } else { qDebug() << "Could not connect: " << socket->errorString(); }

这里我们创建了一个 QTcpSocket 对象，并尝试连接到本地主机的 1234 端口。waitForConnected函数会阻塞等待，直到连接建立或者超时，这里设置的超时时间是 5 秒。如果连接成功，会输出连接成功的信息，否则输出错误信息。

2. 文件传输

接下来进行文件传输。假设我们要传输的文件是test.txt。

QFile file("test.txt"); if(!file.open(QIODevice::ReadOnly)) { qDebug() << "Could not open file"; return; } qint64 totalBytes = file.size(); qint64 bytesWritten = 0; qint64 bytesToWrite = totalBytes; while(bytesToWrite > 0) { QByteArray buffer = file.read(qMin(bytesToWrite, (qint64)1024)); qint64 written = socket->write(buffer); if(written == -1) { qDebug() << "Write error: " << socket->errorString(); break; } bytesWritten += written; bytesToWrite -= written; qDebug() << "Transferred " << bytesWritten << " of " << totalBytes << " bytes"; } file.close(); socket->close();

首先打开要传输的文件，如果打开失败则输出错误信息并返回。获取文件的总大小totalBytes，然后循环读取文件内容并写入到 socket 中。每次读取最多 1024 字节的数据，写入成功后更新已传输字节数bytesWritten和剩余要传输字节数bytesToWrite，并输出当前传输进度。传输完成后关闭文件和 socket。

3. 监测传输状态

为了监测传输状态，我们可以在传输过程中实时输出已传输字节数和总字节数，就像上面代码中那样。也可以使用信号槽机制，比如QTcpSocket的bytesWritten信号。

connect(socket, SIGNAL(bytesWritten(qint64)), this, SLOT(updateTransferProgress(qint64))); void MyClass::updateTransferProgress(qint64 bytes) { static qint64 totalBytes = 0; totalBytes += bytes; qDebug() << "Transferred " << totalBytes << " bytes so far"; }

这里将bytesWritten信号连接到自定义的槽函数updateTransferProgress，在槽函数中累加已传输字节数并输出。

4. 控制传输

可以通过一些逻辑来控制传输，比如暂停和继续。我们可以在连接成功后设置一个标志位来表示传输状态。

bool isPaused = false; // 假设这里有一个暂停按钮的点击事件槽函数 void MyClass::onPauseButtonClicked() { isPaused = true; socket->pause(); } // 继续按钮的点击事件槽函数 void MyClass::onResumeButtonClicked() { isPaused = false; socket->resume(); }

当点击暂停按钮时，设置isPaused为 true 并调用socket->pause()暂停传输；点击继续按钮时，设置isPaused为 false 并调用socket->resume()继续传输。

三、服务端往客户端传输文件

1. 监听连接

服务端需要监听客户端的连接请求，使用 QTcpServer 来实现。

QTcpServer *server = new QTcpServer(this); if(!server->listen(QHostAddress::LocalHost, 1234)) { qDebug() << "Could not start server: " << server->errorString(); return; } connect(server, SIGNAL(newConnection()), this, SLOT(handleNewConnection()));

创建一个 QTcpServer 对象并尝试监听本地主机的 1234 端口。如果监听失败，输出错误信息并返回。将newConnection信号连接到自定义的槽函数handleNewConnection，当有新的客户端连接时会调用这个槽函数。

2. 文件传输

在handleNewConnection槽函数中进行文件传输。假设要传输的文件也是test.txt。

void MyClass::handleNewConnection() { QTcpSocket *socket = server->nextPendingConnection(); QFile file("test.txt"); if(!file.open(QIODevice::ReadOnly)) { qDebug() << "Could not open file"; socket->close(); return; } qint64 totalBytes = file.size(); qint64 bytesWritten = 0; qint64 bytesToWrite = totalBytes; while(bytesToWrite > 0) { QByteArray buffer = file.read(qMin(bytesToWrite, (qint64)1024)); qint64 written = socket->write(buffer); if(written == -1) { qDebug() << "Write error: " << socket->errorString(); break; } bytesWritten += written; bytesToWrite -= written; qDebug() << "Transferred " << bytesWritten << " of " << totalBytes << " bytes"; } file.close(); socket->close(); }

这里获取新连接的 socket，打开要传输的文件，然后和客户端往服务端传输文件类似，循环读取文件内容并写入到 socket 中，实时输出传输进度。传输完成后关闭文件和 socket。