基于QT和websocket协议的多线程文件传输

一、目的与要求

做两个程序，实现文件收发
发送端放两个按钮，点击后打开电脑目录选择所要传输的文件，选好以后，把文件名和路径显示在界面上，点击第二个按钮，把文件传到远程机器（或者虚拟机）上由接收端接收
编写一接收端，把文件接收下来，存进指定的某个目录里
要能测试通过三个发送端同时发100M的文件，接收端能分别接收
使用多线程实现

二、工具/准备工作

Qt开发环境
websocket传输协议库
Win10_x64

三、分析

UI界面设计，使用qtdesigner工具，设计界面如下：

Server端

Client端

多线程实现

Qt中提供了创建线程的基类，并且新创建dialog默认为多线程，利用此特性，可以实现通过创建多个dialog从而实现多个client与服务器同时传输文件。

文件传输协议

使用Websocket协议，实现客户端与服务端的长连接，并且可以双方相互主动推送文本消息或文件流。

四、实现步骤

创建项目
编写客户端主线程程序，为按钮添加创建窗口消息相应事件

子线程程序

文件传输协议代码

```c++ / * * * * * * * * * * * * * * * * * * * * * * ****/

include "sslechoclient.h"

include

using namespace std;

QT_USE_NAMESPACE

//! [constructor] SslEchoClient::SslEchoClient(const QUrl &url, QObject parent) : QObject(parent) { ssl_dia.show(); QCoreApplication::processEvents(); connect(&m_webSocket, &QWebSocket::connected, this, &SslEchoClient::onConnected); typedef void (QWebSocket:: sslErrorsSignal)(const QList &); connect(&m_webSocket, static_cast (&QWebSocket::sslErrors), this, &SslEchoClient::onSslErrors); m_webSocket.open(QUrl(url)); }

void SslEchoClient::onConnected() { m_webSocket.sendTextMessage(QStringLiteral("Hello, world! Server,I'am client!")); connect(&m_webSocket, &QWebSocket::textMessageReceived, this, &SslEchoClient::onTextMessageReceived); connect(ssl_dia.m_pushButton, &QPushButton::clicked,this, &SslEchoClient::sendMessage); connect(ssl_dia.m_pushButton_2, &QPushButton::clicked,this, &SslEchoClient::sendFile);

}

void SslEchoClient::onTextMessageReceived(QString message) { ssl_dia.m_textEdit->setPlainText(message); }

void SslEchoClient::onSslErrors(const QList &errors) { Q_UNUSED(errors);

// WARNING: Never ignore SSL errors in production code.
// The proper way to handle self-signed certificates is to add a custom root
// to the CA store.

qDebug() << "ssl Error!";
m_webSocket.ignoreSslErrors();

}

void SslEchoClient::sendMessage() { QString message = ssl_dia.m_textEdit->toPlainText(); m_webSocket.sendTextMessage(message); }

void SslEchoClient::sendFile() { try{ QString path = QFileDialog::getOpenFileName(&ssl_dia, tr("Select File To Send"),".",tr("File(*)")); if(path.length()<1) return; QFileInfo info(path); QString file_name = info.fileName(); //文件发送消息标记协议 m_webSocket.sendTextMessage("f:" + file_name); QFile file(path); if(!file.open(QIODevice::ReadOnly)) { qDebug() << "Can't open file for writing"; return; } // out.setVersion(QDataStream::Qt_5_8); qDebug() << "read"; QByteArray byte = file.readAll(); m_webSocket.sendBinaryMessage(byte); qDebug() << "send"; file.close(); }catch(exception e){ e.what(); } } ```

服务端消息发送预处理程序

```c++ / * * * * * * * ** * * * * * * * /