首页 > 代码库 > QT网络编程----TCP客户端(2)

QT网络编程----TCP客户端(2)

一、客户端

在客户端里与服务器进行连接,一旦连接成功,就会发出connected()信号,这时就进行文件的发送。

发送数据时我们先发送了数据的大小信息。这一次,我们要先发送文件的总大小,然后文件名长度,然后是文件名,这三部分我们合称为文件头结构,最后再发送文件数据。所以在发送函数里我们就要进行相应的处理,当然,在服务器的接收函数里我们也要进行相应的处理。对于文件大小,这次我们使用了qint64,它是64位的,可以表示一个很大的文件了。

1.同前一节,我们新建工程,将工程命名为“tcpSender”。注意添加network模块。

2.我们在widget.ui文件中将界面设计如下。

 

这里“主机”后的Line Edit的objectName为hostLineEdit;“端口”后的Line Edit的objectName为portLineEdit;下面的Progress Bar的objectName为clientProgressBar,其value属性设为0;“状态”Label的objetName为clientStatusLabel;“打开”按钮的objectName为openButton;“发送”按钮的objectName为sendButton;

3.在widget.h 文件中进行更改。

(1)添加头文件#include <QtNetwork>

(2)添加private变量:

QTcpSocket *tcpClient;

    QFile *localFile;  //要发送的文件

    qint64 totalBytes;  //数据总大小

    qint64 bytesWritten;  //已经发送数据大小

    qint64 bytesToWrite;   //剩余数据大小

    qint64 loadSize;   //每次发送数据的大小

    QString fileName;  //保存文件路径

QByteArray outBlock;  //数据缓冲区,即存放每次要发送的数据

(3)添加私有槽函数:

private slots:

    void send();  //连接服务器

    void startTransfer();  //发送文件大小等信息

    void updateClientProgress(qint64); //发送数据,更新进度条

    voiddisplayError(QAbstractSocket::SocketError); //显示错误

void openFile();  //打开文件

4.在widget.cpp文件中进行更改。

添加头文件:#include <QFileDialog>

(1)在构造函数中添加代码:

loadSize = 4*1024;

    totalBytes = 0;

    bytesWritten = 0;

    bytesToWrite = 0;

    tcpClient = new QTcpSocket(this);

   connect(tcpClient,SIGNAL(connected()),this,SLOT(startTransfer()));

    //当连接服务器成功时,发出connected()信号,我们开始传送文件

    connect(tcpClient,SIGNAL(bytesWritten(qint64)),this,

SLOT(updateClientProgress(qint64)));

    //当有数据发送成功时,我们更新进度条

   connect(tcpClient,SIGNAL(error(QAbstractSocket::SocketError)),this,

           SLOT(displayError(QAbstractSocket::SocketError)));

    ui->sendButton->setEnabled(false);

    //开始使”发送“按钮不可用

我们主要是进行了变量的初始化和几个信号和槽函数的关联。

(2)实现打开文件函数。

void Widget::openFile()   //打开文件

{

    fileName =QFileDialog::getOpenFileName(this);

    if(!fileName.isEmpty())

    {

       ui->sendButton->setEnabled(true);

       ui->clientStatusLabel->setText(tr(“打开文件 %1 成功!”)

                                      .arg(fileName));

    }

}

该函数将在下面的“打开”按钮单击事件槽函数中调用。

(3)实现连接函数。

void Widget::send()   //连接到服务器,执行发送

{

   ui->sendButton->setEnabled(false);

    bytesWritten = 0;

    //初始化已发送字节为0

    ui->clientStatusLabel->setText(tr(“连接中…”));

   tcpClient->connectToHost(ui->hostLineEdit->text(),

                            ui->portLineEdit->text().toInt());//连接

}

该函数将在“发送”按钮的单击事件槽函数中调用。

(4)实现文件头结构的发送。

void Widget::startTransfer()  //实现文件大小等信息的发送

{

    localFile = new QFile(fileName);

   if(!localFile->open(QFile::ReadOnly))

    {

        qDebug()<< "open file error!";

        return;

    }

    totalBytes = localFile->size();

    //文件总大小

    QDataStreamsendOut(&outBlock,QIODevice::WriteOnly);

    sendOut.setVersion(QDataStream::Qt_4_6);

    QString currentFileName =fileName.right(fileName.size() - fileName.lastIndexOf(‘/‘)-1);

    sendOut << qint64(0) <<qint64(0) << currentFileName;

    //依次写入总大小信息空间,文件名大小信息空间,文件名

    totalBytes += outBlock.size();

    //这里的总大小是文件名大小等信息和实际文件大小的总和

    sendOut.device()->seek(0);

   sendOut<<totalBytes<<qint64((outBlock.size() - sizeof(qint64)*2));

    //返回outBolock的开始,用实际的大小信息代替两个qint64(0)空间

    bytesToWrite = totalBytes -tcpClient->write(outBlock);

    //发送完头数据后剩余数据的大小

   ui->clientStatusLabel->setText(tr("已连接"));

    outBlock.resize(0);

}

(5)下面是更新进度条,也就是发送文件数据。

void Widget::updateClientProgress(qint64 numBytes) //更新进度条,实现文件的传送

{

    bytesWritten += (int)numBytes;

    //已经发送数据的大小

    if(bytesToWrite > 0) //如果已经发送了数据

    {

        outBlock =localFile->read(qMin(bytesToWrite,loadSize));

      //每次发送loadSize大小的数据,这里设置为4KB,如果剩余的数据不足4KB,

      //就发送剩余数据的大小

        bytesToWrite-= (int)tcpClient->write(outBlock);

       //发送完一次数据后还剩余数据的大小

       outBlock.resize(0);

        //清空发送缓冲区

    }

    else

    {

       localFile->close(); //如果没有发送任何数据,则关闭文件

    }

   ui->clientProgressBar->setMaximum(totalBytes);

   ui->clientProgressBar->setValue(bytesWritten);

    //更新进度条

    if(bytesWritten == totalBytes) //发送完毕

    {

       ui->clientStatusLabel->setText(tr(“传送文件 %1 成功”).arg(fileName));

       localFile->close();

       tcpClient->close();

    }

}

(6)实现错误处理函数。

void Widget::displayError(QAbstractSocket::SocketError)//显示错误

{

    qDebug() <<tcpClient->errorString();

    tcpClient->close();

    ui->clientProgressBar->reset();

   ui->clientStatusLabel->setText(tr(“客户端就绪”));

   ui->sendButton->setEnabled(true);

}

(7)我们从widget.ui中分别进行“打开”按钮和“发送”按钮的单击事件槽函数,然后更改如下。

void Widget::on_openButton_clicked() //打开按钮

{

    openFile();

}

void Widget::on_sendButton_clicked() //发送按钮

{

    send();

}

5.我们为了使程序中的中文不显示乱码,在main.cpp文件中更改。

添加头文件:#include <QTextCodec>

在main函数中添加代码:QTextCodec::setCodecForTr(QTextCodec::codecForLocale());

代码:

工程文件

#-------------------------------------------------
#
# Project created by QtCreator 2014-09-28T19:45:50
#
#-------------------------------------------------
QT       += core gui
QT       += network
greaterThan(QT_MAJOR_VERSION, 4): QT += widgets
TARGET = tcpSender
TEMPLATE = app
SOURCES += main.cpp\
        widget.cpp
HEADERS  += widget.h
FORMS    += widget.ui

wiget.h头文件

#ifndef WIDGET_H
#define WIDGET_H
#include <QWidget>
#include <QtNetwork>
#include <QTcpServer>
#include <QTcpSocket>
#include <QFileDialog>
#include <QDebug>
#include <QMessageBox>
#include <QTextCodec>
#include <QAbstractSocket>
namespace Ui {
class Widget;
}
class Widget : public QWidget
{
    Q_OBJECT
public:
    explicit Widget(QWidget *parent = 0);
    ~Widget();
private:
    Ui::Widget *ui;
    QTcpSocket *tcpClient;
    QFile *localFile;               //要发送的文件
    qint64 totalBytes;                      //数据总大小
    qint64 bytesWritten;            //已经发送数据的大小
    qint64 bytesToWrite;            //剩余数据大小
    qint64 loadSize;            //每次发送数据的大小
    QString fileName;           //保存文件路径
    QByteArray outBlock;            //数据缓冲区,即存放每次要发送的数据
private slots:
    void send();        //连接服务器
    void startTransfer();       //发送文件大小等信息
    void updateClientProgress(qint64);          //发送数据,更新进度条
    void displayError(QAbstractSocket::SocketError socketError);            //显示错误
    void openFile();                      //打开文件
    void on_openButton_clicked();
    void on_sendButton_clicked();
};
#endif // WIDGET_H

main.cpp

#include "widget.h"
#include <QApplication>
int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    Widget w;
   /* QTextCodec::setCodecForLocale(QTextCodec::codecForName("UTF-8"));
 //   QTextCodec::setCodecForCStrings(QTextCodec::codecForName("UTF-8"));
   // QTextCodec::setCodecForTr(QTextCodec::codecForName("UTF-8"));
    QTextCodec::setCodecForLocale(QTextCodec::codecForName("GB18030"));
    //QTextCodec::setCodecForTr(QTextCodec::codecForLocale());*/
    w.show();
    return a.exec();
}

widget.cpp文件

#include "widget.h"
#include "ui_widget.h"
Widget::Widget(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::Widget)
{
    ui->setupUi(this);
    loadSize = 4*1024;
    totalBytes = 0;
    bytesWritten = 0;
    bytesToWrite = 0;
    tcpClient = new QTcpSocket(this);
    connect(tcpClient,SIGNAL(connected()),this,SLOT(startTransfer()));
    //当连接服务器成功时,发出connected()信号,我们开始传送文件
    connect(tcpClient,SIGNAL(byteWritten(qint64)),this,SLOT(updateClientProgress(qint64)));
    //当有数据发送成功时,我们更新进度条
    connect(tcpClient,SIGNAL(error(QAbstractSocket::SocketError)),this,SLOT(displayError(AbstractSocket::SocketError)));
    ui->sendButton->setEnabled(false);
    //开始时“发送“按钮不可用
}
Widget::~Widget()
{
    delete ui;
}
void Widget::openFile()
{
    fileName = QFileDialog::getOpenFileName(this);
    if(!fileName.isEmpty())
    {
        ui->sendButton->setEnabled(true);
        ui->clientStatuslabel->setText(tr("打开文件%1成功!").arg(fileName));
    }
}
//该函数将在下面的”打开“按钮单击事件槽函数中调用
//实现连接函数
void Widget::send()
{
    ui->sendButton->setEnabled(false);
    bytesWritten = 0;
    //初始化已发送字节为0
    ui->clientStatuslabel->setText(tr("连接中"));
    tcpClient->connectToHost(ui->hostlineEdit->text(),ui->portlineEdit->text().toInt());  //连接
}
//该函数将在”发送“按钮的单击事件槽函数中调用
//实现文件头结构的发送
void Widget::startTransfer()      //实现文件大小等信息的发送
{
    localFile = new QFile(fileName);
    if(!localFile->open(QFile::ReadOnly))
    {
        qDebug()<<"open file error";
        return ;
    }
    totalBytes = localFile->size();
    //文件总大小
    QDataStream sendOut(&outBlock,QIODevice::WriteOnly);
    sendOut.setVersion(QDataStream::Qt_4_6);
    QString currentFileName = fileName.right(fileName.size()-fileName.lastIndexOf(‘/‘)-1);
    sendOut<<qint64(0)<<qint64(0)<<currentFileName;
    //依次写入总大小信息空间,文件名大小信息空间,文件名
    totalBytes += outBlock.size();
    //这里的总大小是文件等信息和实际文件大小的总和
    sendOut.device()->seek(0);
    sendOut<<totalBytes<<qint64(outBlock.size()-sizeof(qint64)*2);
    //返回outBlock的开始,用实际的大小信息代替两个qint64(0)空间
    bytesToWrite = totalBytes - tcpClient ->write(outBlock);
    //发送完头数据后剩余数据的大小
    ui->clientStatuslabel->setText(tr("已连接"));
    outBlock.resize(0);
}
//更新进度条,也就是发送文件的数据
void Widget::updateClientProgress(qint64 numBytes) //更新进度条,实现文件的传送
{
    bytesWritten += (int)numBytes;
    //已经发送loadSize大小的数据,这里设置为4kb,如果剩余的数不足4Kb,就发送剩余数据的大小
    if(bytesToWrite>0)
    {
    outBlock = localFile->read(qMin(bytesToWrite,loadSize));
    //每次发送loadSize大小的数据,这里设置为4Kb,如果剩余的数据不足4Kb
    //就发送剩余数据的大小
    bytesToWrite -= (int)tcpClient->write(outBlock);
    //发送完一次数据后还剩余数据的大小
    outBlock.reserve(0);
    //清空发送缓冲区
    }
    else
    {
        localFile->close();//如果没有发送任何数据,则关闭文件
    }
    ui->clientprogressBar->setMaximum(totalBytes);
    ui->clientprogressBar->setValue(bytesWritten);
    //更新进度条
    if(bytesWritten==totalBytes)    //发送完毕
   {
        ui->clientStatuslabel->setText(tr("传送文件 %1成功").arg(fileName));
        localFile->close();
        tcpClient->close();
    }
}
//实现错误处理函数
void Widget::displayError(QAbstractSocket::SocketError)     //显示错误
{
    qDebug()<<tcpClient->errorString();
    tcpClient->close();
    ui->clientprogressBar->reset();
    ui->clientStatuslabel->setText(tr("客户端就绪"));
    ui->sendButton->setEnabled(true);
}
void Widget::on_openButton_clicked()
{
    openFile();
}
void Widget::on_sendButton_clicked()
{
    send();
}
界面文件:

<?xml version="1.0" encoding="UTF-8"?>
<ui version="4.0">
 <class>Widget</class>
 <widget class="QWidget" name="Widget">
  <property name="geometry">
   <rect>
    <x>0</x>
    <y>0</y>
    <width>400</width>
    <height>300</height>
   </rect>
  </property>
  <property name="windowTitle">
   <string>Widget</string>
  </property>
  <widget class="QProgressBar" name="clientprogressBar">
   <property name="geometry">
    <rect>
     <x>30</x>
     <y>110</y>
     <width>341</width>
     <height>23</height>
    </rect>
   </property>
   <property name="value">
    <number>0</number>
   </property>
  </widget>
  <widget class="QLabel" name="clientStatuslabel">
   <property name="geometry">
    <rect>
     <x>40</x>
     <y>150</y>
     <width>151</width>
     <height>16</height>
    </rect>
   </property>
   <property name="text">
    <string>状态:等待打开文件!</string>
   </property>
  </widget>
  <widget class="QPushButton" name="openButton">
   <property name="geometry">
    <rect>
     <x>50</x>
     <y>190</y>
     <width>75</width>
     <height>23</height>
    </rect>
   </property>
   <property name="text">
    <string>打开</string>
   </property>
  </widget>
  <widget class="QPushButton" name="sendButton">
   <property name="geometry">
    <rect>
     <x>150</x>
     <y>190</y>
     <width>75</width>
     <height>23</height>
    </rect>
   </property>
   <property name="text">
    <string>发送</string>
   </property>
  </widget>
  <widget class="QWidget" name="">
   <property name="geometry">
    <rect>
     <x>30</x>
     <y>60</y>
     <width>189</width>
     <height>22</height>
    </rect>
   </property>
   <layout class="QHBoxLayout" name="horizontalLayout">
    <item>
     <widget class="QLabel" name="label_2">
      <property name="text">
       <string>端口号:</string>
      </property>
     </widget>
    </item>
    <item>
     <widget class="QLineEdit" name="portlineEdit"/>
    </item>
   </layout>
  </widget>
  <widget class="QWidget" name="">
   <property name="geometry">
    <rect>
     <x>30</x>
     <y>30</y>
     <width>177</width>
     <height>22</height>
    </rect>
   </property>
   <layout class="QHBoxLayout" name="horizontalLayout_2">
    <item>
     <widget class="QLabel" name="label">
      <property name="text">
       <string>主机:</string>
      </property>
     </widget>
    </item>
    <item>
     <widget class="QLineEdit" name="hostlineEdit"/>
    </item>
   </layout>
  </widget>
 </widget>
 <layoutdefault spacing="6" margin="11"/>
 <resources/>
 <connections/>
</ui>



QT网络编程----TCP客户端(2)