Qt：多线程TCP服务器客户端双向文件互传，Server端和Client端分离（带进度 ...

Client 界面：

Server 界面：

Server 利用：

输入端口号后，点击启动监听
Client 利用：

1.毗连服务器

输入IP（服务器的IP所在）和端口号后，点击毗连按钮，毗连成功如下图所示：

2.向服务器发送文件

2.1 点击“选择当地文件”按钮，选择一个当地的文件。

2.2 点击“选择存储在服务器的目录”，选择发送的文件将要存储在服务器的哪个目录中。（此功能可直接在一台电脑上测试，当多台电脑的时候可以将目录改为服务器的现实目录所在）

2.3 点击“发送文件”按钮，即可开始向服务器传输文件，传输成功后客户端会有提示框。

3.下载服务器的文件（服务器向客户端发送文件）

3.1 点击“选择要下载的文件”按钮，选择想要下载的服务器下的文件（此功能可直接在一台电脑上测试，当多台电脑的时候可以将目录改为服务器的现实文件所在）。

3.2 点击“选择下载目录”按钮，选择下载文件的存储位置。

3.3 点击“下载文件”按钮，即可开始下载服务器的文件，下载成功后客户端会有提示框。



Server-Mainwindow焦点代码

1.     //设置进度条
2.     ui->progressBar->setRange(0,100);
3.     ui->progressBar->setValue(0);
6.     QWidget *progressWidget = new QWidget(this);
7.     progressWidget->setLayout(new QHBoxLayout());
8.     progressWidget->layout()->addWidget(ui->progressBar);
10.     // 创建 QStatusBar
11.     // 将小部件添加到 QStatusBar
12.     ui->statusbar->addPermanentWidget(progressWidget);
13.     // 设置主窗口的状态栏
14.     setStatusBar(ui->statusbar);
15.     ui->statusbar->setSizeGripEnabled(false);
19.     //创建线程对象
20.     QThread *thread = new QThread;
21.     //创建任务对象
22.     RecvFile *recvWork = new RecvFile;
23.     //将任务对象移到子线程中
24.     recvWork->moveToThread(thread);
26.     connect(this,&MainWindow::startListen,recvWork,&RecvFile::startListen);
27.     //更新进度条
28.     connect(recvWork,&RecvFile::curPercent,ui->progressBar,&QProgressBar::setValue);
31.     //启动线程
32.     thread->start();

复制代码

Server-receiver.cpp焦点代码

1. void RecvFile::startListen(unsigned short port)
2. {
3.     qDebug()<<port;
4.     //分配内存空间
5.     tcpServer = new QTcpServer(this);
6.     tcpServer->listen(QHostAddress::Any,port);
7.     connect(tcpServer,&QTcpServer::newConnection,[=]()
8.     {
9.         //取出建立好连接的套接字
10.         tcpSocket = tcpServer->nextPendingConnection();
12.         isStart = true;
13.         connect(tcpSocket,&QTcpSocket::readyRead,this,&RecvFile::recvFile);
14.         connect(tcpSocket,&QTcpSocket::disconnected,this,[=]()
15.         {
16.             //断开连接
17.             tcpSocket->close();
18.             tcpSocket->deleteLater();
19.         });
20.     });
21. }
25. void RecvFile:: recvFile()
26. {
27.     qDebug()<<"触发recvFile";
28.     //取出接收的内容
29.     QByteArray buf = tcpSocket->readAll();
30.     if(true == isStart)//之前未接收文件的头部信息
31.     {
32.         //接收头部
33.         qDebug()<<"接收头部===";
34.         isStart = false;
35.         //解析头部  buf的内容格式 <文件名>##<文件大小>
36.         QString token=QString(buf).section("##",0,0);//token
37.         qDebug()<<"token1="<<token;
38.         recvfilesize = 0;//初始化已接收的文件长度为0
40.         if(token=="197%*FILE*%197"){//是文件
41.             qDebug()<<"文件";
42.             filename = QString(buf).section("##",1,1);//文件名
43.             filesize = QString(buf).section("##",2,2).toUInt();//文件大小
44.             targetDir=QString(buf).section("##",3,3);//文件应存储的目录
45.             qDebug()<<"filename="<<filename;
46.             qDebug()<<"filesize="<<filesize;
47.             qDebug()<<"targetDir="<<targetDir;
48.         }
49.         else if(token=="197%*DOWNLOAD*%197"){//请求下载文件信号
50.             qDebug()<<"下载文件请求";
51.             filePath = QString(buf).section("##",1,1);//文件完整路径
52.             storagePath = QString(buf).section("##",2,2);//文件完整路径
53.             qDebug()<<"filePath="<<filePath;
54.             qDebug()<<"storagePath="<<storagePath;
55.             isStart = true;//信号只是个头，不应该继续接收尾部
56.             sendDownloadFile(filePath,storagePath);
57.             return;
58.         }
59.         else if(token=="197%*CLIENT_RECEIVED*%197"){
60.             qDebug()<<"客户端已成功接收文件";
61.             isStart = true;//信号只是个头，不应该继续接收尾部
62.             return;
63.         }
64.         else{
65.             qDebug()<<"无效token！";
66.             return;
67.         }
70.         filename=targetDir+"\"+filename;//设置文件位置
71.         file.setFileName(filename);
72.         qDebug()<<"filename="<<filename;
73.         bool isOk = file.open(QIODevice::WriteOnly);
74.         if(false == isOk)//打开失败
75.         {
76.             return;
77.         }
78.     }
79.     else//文件的头部信息已经接收
80.     {
81.         qDebug()<<"接收尾部===";
82.         qint64 len = file.write(buf);//将buf中的数据写入file文件，并返回实际写入的字节数。
83.         if(len>0)
84.         {
85.             recvfilesize += len;//累计接收大小
86.             int percent = ((recvfilesize)*100)/filesize;
87.             //发出更新进度条的信号
88.             //qDebug()<<"percent="<<percent;
89.             emit curPercent(percent);
90.         }
92.         if(recvfilesize == filesize)
93.         {
94.             //emit recvOver();//接收完毕
95.             qDebug()<<"接收完毕1";
96.             file.close();
97.             isStart = true;
99.             //通知客户端 接收完毕
100.             // 文件传输成功后发送文件接收完毕的信息给客户端
101.             //============================================Token==================================================================
102.             QString token="197%*SERVER_RECEIVED*%197";
103.             //============================================Token==================================================================
104.             QByteArray completionMessage = token.toUtf8();
105.             completionMessage.append("##");
107.             tcpSocket->write(completionMessage);
108.             tcpSocket->waitForBytesWritten(); // 等待数据写入完毕
109.         }
110.         else{
111.             qDebug()<<"recvfilesize != filesize";
112.             //isStart = true;
113.         }
114.     }
115. }
117. void RecvFile::sendDownloadFile(QString path,QString targetDir)//发送头
118. {
119.     timer = new QTimer(this);
120.     connect(timer,&QTimer::timeout,[=]()
121.     {
122.         //关闭定时器
123.         timer->stop();
124.         //发送文件数据
125.         sendDownloadFileData();
126.     });
128.     file.setFileName(path);
129.     //获取文件信息
130.     QFileInfo info(path);
131.     filesize = info.size();//获取文件大小
132.     filename = info.fileName();//获取文件名
133.     //============================================Token==================================================================
134.     QString token="197%*FILE*%197";
135.     //============================================Token==================================================================
136.     //只读方式打开文件
137.     bool isOk = file.open(QIODevice::ReadOnly);
138.     if(true == isOk)
139.     {
140.         //创建文件头信息
141.         QString head = QString("%1##%2##%3##%4").arg(token).arg(filename).arg(filesize).arg(targetDir);
142.         //创建文件头信息，格式为"文件名##文件大小"，例如 "example.txt##1024"
143.         //发送头部信息
144.         qint64 len = tcpSocket->write(head.toUtf8());
145.         if(len>0)//发送成功
146.         {
147.             //防止tcp黏包问题,延时20ms
148.             timer->start(20);
149.         }
150.         else
151.         {
152.             //发送失败
153.             file.close();
154.         }
155.     }
156.     else
157.     {
158.         QMessageBox::warning(nullptr,"错位","打开文件失败！");
159.         return;
160.     }
161. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。