QT笔记之VS2012 TCP传送文件

注意:工程监理后，因为用到网路，所以要加入对应的库

服务器:

 #ifndef TCPFILE_H

 #define TCPFILE_H

 #include <QtWidgets/QWidget>

 #include "ui_tcpfile.h"

 #include <QtNetwork/QTcpServer>//监听套接字

 #include <QtNetwork/QTcpSocket>//通信套接字

 #include <QFile>

 #include <QTimer>

 class TCPFile : public QWidget

 {

     Q_OBJECT

 public:

     TCPFile(QWidget *parent = );

     ~TCPFile();

     void SendData();//发送文件数据函数

 private slots:

     void on_buttonSelect_clicked();

     void on_buttonSend_clicked();

 private:

     Ui::TCPFileClass ui;

     QTcpServer* tcpServer;//监听套接字

     QTcpSocket* tcpSocket;//通信套接字

     QFile file;//文件对象

     QString filename;//文件名字

     qint64 filesize;//文件大小

     qint64 sendsize;//已发送文件大小

     QTimer timer;//定时器

 };

 #endif // TCPFILE_H

.cpp

 #include "tcpfile.h"

 #include <QTextCodec>

 #include <QFileDialog>//选择文件对话框

 #include <QDebug>

 #include <QFileInfo>//文件信息

 TCPFile::TCPFile(QWidget *parent)

     : QWidget(parent)

 {

     ui.setupUi(this);

     //监听套接字

     tcpServer = new QTcpServer(this);

     //监听

     tcpServer->listen(QHostAddress::Any,);

     QTextCodec *codec = QTextCodec::codecForLocale();//解决中文乱码

     QString Titleinfo = codec->toUnicode("服务器端口为:8888");

     setWindowTitle(Titleinfo);

     //建立连接之前两个按钮不可用

     ui.buttonSelect->setEnabled(false);

     ui.buttonSend->setEnabled(false);

     //如果客户端和服务器连接

     //tcpServer会自动触发 newConnection()

     connect(tcpServer,&QTcpServer::newConnection,

         [=]()

     {

         //取出建立好连接的套接字

         tcpSocket = tcpServer->nextPendingConnection();

         //获取对方的ip和port

         QString strIP = tcpSocket->peerAddress().toString();

         quint16 port = tcpSocket->peerPort();

         QString str = QStringLiteral("[%1,%2] 成功连接").arg(strIP).arg(port);

         //str = codec->toUnicode(str);

         ui.textEdit->setText(str);//显示到编辑框

         //成功连接后 选择按钮可用

         ui.buttonSelect->setEnabled(true);

     }

     );

     connect(&timer,&QTimer::timeout,

         [=]()

     {

         //关闭定时器

         timer.stop();

         SendData();

     }

     );

 }

 TCPFile::~TCPFile()

 {

 }

 void TCPFile::on_buttonSelect_clicked()

 {

     QString filepath = QFileDialog::getOpenFileName(this,"open","../");

     if(!filepath.isEmpty())

     {

         //文件路径有效

         //只读方式打开文件

         filename.clear();

         filesize = ;

         QFileInfo info(filepath);//获取文件信息

         filename = info.fileName();

         filesize = info.size();

         sendsize = ;//发送文件的大小

         file.setFileName(filepath);

         //打开文件

         bool isOk = file.open(QIODevice::ReadOnly);

         if(false == isOk)

         {

             qDebug() << "只读方式打开文件失败";

         }

         else

         {

             //提示打开文件的路径

             ui.textEdit->append(filepath);

             ui.buttonSelect->setEnabled(false);

             ui.buttonSend->setEnabled(true);

         }

     }

 }

 void TCPFile::on_buttonSend_clicked()

 {

     //先发送文件头部信息

     QString head = QString("%1##%2").arg(filename).arg(filesize);//自定义文件头部

     //发送头部信息

     qint64 len = tcpSocket->write(head.toUtf8());

     if(len > )//头部信息发送成功

     {

         //发送真正的文件信息

         //防止TCP粘包文件

         //需要通过定时器延时 20ms

         timer.start();

     }

     else

     {

         qDebug() << "头部信息发送失败 115";

         file.close();

         ui.buttonSelect->setEnabled(true);

         ui.buttonSend->setEnabled(false);

     }

 }

 void TCPFile::SendData()

 {

     qint64 len = ;

     do

     {

         //每次发送数据的大小

         char buf[*] = {};

         len = ;

         //往文件中读数据

         len =  file.read(buf,sizeof(buf));

         //发送数据 读多少  发送多少

         //发送多好

         len = tcpSocket->write(buf,len);

         sendsize += len;

     }while(len > );

     if(sendsize == filesize)

     {

         ui.textEdit->append("file finshed");

         file.close();

         //把客户端断开连接

         tcpSocket->disconnectFromHost();

         tcpSocket->close();

     }

 }

客户端

 #ifndef CLIENTWIDGET_H

 #define CLIENTWIDGET_H

 #include <QWidget>

 #include "ui_clientwidget.h"

 #include <QtNetwork/QTcpSocket>//通信套接字

 #include <QFile>

 class ClientWidget : public QWidget

 {

     Q_OBJECT

 public:

     ClientWidget(QWidget *parent = );

     ~ClientWidget();

 private slots:

     void on_buttonConnect_clicked();

 private:

     Ui::ClientWidget ui;

     QTcpSocket* tcpSocket;//通信套接字

     QFile file;//文件对象

     QString filename;//文件名字

     qint64 filesize;//文件大小

     qint64 recvsize;//已接收文件大小

     bool isHead;//是否是头

 };

 #endif // CLIENTWIDGET_H

.cpp

 #include "clientwidget.h"

 #include <QMessageBox>

 #include <QHostAddress>

 #include <QTextCodec>

 ClientWidget::ClientWidget(QWidget *parent)

     : QWidget(parent)

 {

     ui.setupUi(this);

     tcpSocket = new QTcpSocket(this);

     setWindowTitle(QStringLiteral("客户端"));

     isHead = true;

     QTextCodec *codec = QTextCodec::codecForLocale();//解决中文乱码

     connect(tcpSocket,&QTcpSocket::readyRead,

         [=]()

          {

              //取出接收到的东西

              QByteArray buf = tcpSocket->readAll();

              if (isHead)

              {//接收头

                  isHead = false;

                  //解析头部信息 QString buf = "hello##1024";  文件名为 "hello" 大小为 1024

                  // QString str ="hello##1024";

                  //str.section("##",0,0); 取出 "hello"

                  //str.section("##",1,1); 取出 "1024"

                  filename = QString(buf).section("##", , );

                  filesize = QString(buf).section("##", , ).toInt();

                  recvsize = ;

                  //初始化

                  //打开文件

                  file.setFileName(filename);

                  bool isOk = file.open(QIODevice::WriteOnly);

                  if (false == isOk)

                  {

                      QMessageBox::information(this,"打开","文件打开失败");

                  }

              }

              else

              {

                  //文件信息

                  qint64 len = file.write(buf);

                  recvsize += len;

                  if (recvsize == filesize)

                  {

                      file.close();

                      QString title = codec->toUnicode("完成");

                      QString info = codec->toUnicode("接收完成");

                      QMessageBox::information(this,title,info);

                      //断开连接

                      tcpSocket->disconnectFromHost();

                     tcpSocket->close();

                  }

              }

          }

         );

 }

 ClientWidget::~ClientWidget()

 {

 }

 void ClientWidget::on_buttonConnect_clicked()

 {

      //获取服务器的IP和端口

     QString strIP = ui.lineEditIP->text();

     quint16 port =  ui.lineEditPort->text().toInt();

     tcpSocket->connectToHost(QHostAddress(strIP),port);

 }

main文件

 #include "tcpfile.h"

 #include <QtWidgets/QApplication>

 #include "clientwidget.h"

 int main(int argc, char *argv[])

 {

     QApplication a(argc, argv);

     TCPFile w;

     w.show();

     ClientWidget cw;

     cw.show();

     return a.exec();

 }

运行效果:

第一步：

第二步:

第三步:

第四步：

巴特西

QT笔记之VS2012 TCP传送文件

最新文章

热门文章