草庐IT

使用QT编写TCP服务器与客户端程序

自由的好好干活 2023-06-15 原文

建立工程

在学习了霍亚飞的《Qt Creator快速入门(第3版)》后,参考“18.4 TCP”中的示例程序,编写了一个在同一个工程中实现服务器与客户端的习作程序,变量名命名方式和示例程序大体一致,程序实现了TCP客户端发送文件,服务器接收文件的功能,用到了QFile,QDataStream,QTcpServer,QTcpSocket等QT类。本文记录了编写过程,主要目的就是为了熟悉QT下TCP编程。
首先新建工程,选择“Qt Widget Application”,工程名称是“TcpFileServerClient”,下一步到“Class Information”的时候基类选择QWidget,Class Name改成Client,如下图所示:

点击下一步直到完成。
在项目栏中双击工程文件名:

在QT += core gui后面添加network,变成这样:
QT += core gui network
这个操作将会把QT网络编程需要的库文件添加进来。

设计客户端界面

双击client.ui文件,进入设计师界面,在界面上先放一个窗体布局控件(Form Layout),然后在里面右键添加“窗体布局行”,标签文字“主机:”,字段名称改成hostEdit,如下图所示:

然后用相同方法添加“端口:”,字段名称改成portEdit
然后添加进度条(Progress Bar),使用默认名称progressBar即可
添加一个标签控件(label),名称改成labelStatus,文本内容改成“请先打开文件”
添加两个按钮(Push Button),一个按钮文本改成“打开文件”,名称改成openButton;一个按钮文本改成“发送文件”,名称改成sendButton
最终界面如下图所示:

编写客户端代码

修改client.h文件,在里面添加如下内容:

//这个头文件中定义了网络错误处理槽函数测参数类型。
#include <QAbstractSocket>

client.h里面只是使用到了类指针,可以前置声明这个类来减少编译时间。

//前置声明类
class QTcpSocket;
class QFile;

……

//定义私有变量
private:
    QTcpSocket* tcpClient;//客户端连接
    QFile* localFile;//文件操作
    qint64 totalBytes;//总传输字节数
    qint64 bytesToWrite;//还剩下要写的字节数
    qint64 bytesWritten;//已经写的字节数
    qint64 payloadSize;//每次传输字节数
    QString fileName;//包含了全路径的文件名
    QByteArray outBlock;//输出缓冲区
//定义私有槽函数,全都是和网络相关的
private slots:
	//建立连接成功后槽函数,开始传输
    void startTransfer();
    //发送完成槽函数,更新进度条,开始下一批传输
    void sendFile(qint64 numSend);
    //网络错误处理槽函数
    void displayError(QAbstractSocket::SocketError);

修改client.c文件
包含必要头文件:

#include <QtNetwork>
#include <QFileDialog>
#include <QDebug>

此时可以先编译一下,不用考虑是否会成功,主要目的是为了生成ui对象中包含的窗体对象变量,这样后续编程会比较方便。
在构造函数中实例化客户端对象,并且关联相关槽函数。

//实例化客户端对象
    tcpClient = new QTcpSocket(this);
    //关联建立连接成功槽函数
    connect(tcpClient, &QTcpSocket::connected, this, &Client::startTransfer);
//建立发送完成槽函数
    connect(tcpClient, &QTcpSocket::bytesWritten, this, &Client::sendFile);

    //关联错误处理槽函数,因为error是一个多态函数,所以只能使用SIGNAL关键字来关联
    connect(tcpClient, SIGNAL(error(QAbstractSocket::SocketError)),
            this, SLOT(displayError(QAbstractSocket::SocketError)));
    ui->sendButton->setEnabled(false);
	ui->hostEdit->setText(tr("localhost"));
    ui->portEdit->setText(tr("6666"));

双击client.ui进入设计师界面,然后在打开文件按钮上右键选择转到槽,选择默认的clicked(),点击OK按钮后会自动生成
void Client::on_openButton_clicked()
这个函数将在单击按钮时执行。此函数代码如下:

void Client::on_openButton_clicked()
{
    //通过对话框得到含有全路径的文件名
    fileName = QFileDialog::getOpenFileName(this);
    if (!fileName.isEmpty())
    {
        ui->sendButton->setEnabled(true);
        ui->labelStatus->setText(tr("等待传输文件%1").arg(fileName));
    }
}

然后使用设计师界面自动生成发送文件按钮的槽函数,具体如下:

void Client::on_sendButton_clicked()
{
    //打开文件
    localFile = new QFile(fileName);
    if (!localFile->open(QFile::ReadOnly))
    {
        qDebug() << localFile->errorString();
ui->labelStatus->setText(tr("打开文件失败!"));
        return;
    }
ui->labelStatus->setText(tr("连接中……"));
    tcpClient->connectToHost(ui->hostEdit->text(),
                             ui->portEdit->text().toInt());
}

接下来写建立连接成功槽函数,在函数中发送文件头,包含了总传输数据量和文件名称等信息:

void Client::startTransfer()
{
    //注意QDataStream是写操作的时候,需要传递缓冲区指针
    QDataStream out(&outBlock, QIODevice::WriteOnly);
    //发送和接收版本号要一致
    out.setVersion(QDataStream::Qt_5_9);
    //得到去掉路径的文件名
    QString currentFileName =
            fileName.right(fileName.size() -
                           fileName.lastIndexOf('/') - 1);
    //前面保留出总字节数和文件名字节数。
    out << qint64(0) << qint64(0) << currentFileName;
    totalBytes = localFile->size() + outBlock.size();
    //得到文件名占用字节数,注意QDataStream有其单独的数据结构
    //所以文件名占用的字节数不能使用currentFileName.size()获得。
    qint64 fileNameSize = outBlock.size() - sizeof(qint64) * 2;
    out.device()->seek(0);
    out << totalBytes << fileNameSize;
    //先将文件头写出去
    bytesToWrite = totalBytes - tcpClient->write(outBlock);
}

接下来在发送完成槽函数中将文件全部传输完毕,并且更新进度条:

void Client::sendFile(qint64 numSend)
{
    bytesWritten += numSend;
    if (bytesToWrite > 0)
    {
        outBlock = localFile->read(qMin(bytesToWrite, payloadSize));
        bytesToWrite -= tcpClient->write(outBlock);
    }
    //更新进度条
    ui->progressBar->setMaximum(totalBytes);
    ui->progressBar->setValue(bytesWritten);
    if (bytesWritten == totalBytes)
    {
        localFile->close();
        tcpClient->close();
        ui->labelStatus->setText("发送文件成功!");
    }
}

最后在网络错误槽函数中处理错误信息

void Client::displayError(QAbstractSocket::SocketError)
{
    qDebug() << tcpClient->errorString();
    tcpClient->close();
    localFile->close();
    ui->sendButton->setEnabled(true);
}

设计服务器端界面

在工程名上点击右键选择Add New,如下图所示:

选择Qt,Qt界面设计师类,如下图所示:

然后选择Widget,下一步,选择类名的时候改成Server,如下图所示:

下一步,完成。然后在窗体设计界面中添加一个进度条,一个标签,一个按钮,将标签文本修改成“正在监听localhost的6666端口”,将按钮文本修改成“开始监听”。如下图所示:

编写服务器端代码

首先在头文件server.h中添加包含的头文件和类声明:

#include <QAbstractSocket>
#include <QTcpServer>

class QTcpSocket;
class QFile;

然后在Server类中声明必要的成员函数与槽函数:

//进行网络通讯和传输文件所需变量
private:
    QTcpServer tcpServer;
    QTcpSocket* tcpConnection;//保存客户端连接
    QFile* localFile;
    qint64 fileNameSize;
    qint64 bytesReceived;
    qint64 totalBytes;
    QString fileName;

private slots:
    void newConnection();//客户端建立连接槽函数
    void readyRead();//端口数据可读槽函数
    void displayError(QAbstractSocket::SocketError);//网络错误处理函数
    void on_pushButton_clicked();

修改Server.c文件
首先包含必要头文件:

#include <QtNetwork>
#include <QFile>
#include <QDebug>

在构造函数中关联新建连接槽函数:

connect(&tcpServer, &QTcpServer::newConnection, 
         this, &Server::newConnection);

接下来实现新建连接槽函数,实现读数据槽函数,错误处理函数,以及单击按钮槽函数:

void Server::newConnection()
{
    //保存连接实例
    tcpConnection = tcpServer.nextPendingConnection();
    //关联读数据槽函数
    connect(tcpConnection, &QTcpSocket::readyRead, this, &Server::readyRead);
    //关联网络错误槽函数
    connect(tcpConnection, SIGNAL(error(QAbstractSocket::SocketError)),
            this, SLOT(displayError(QAbstractSocket::SocketError)));
    fileNameSize = 0;
    totalBytes = 0;
    bytesReceived = 0;
    //已经成功和客户端建立连接,可以关闭端口
    tcpServer.close();
}

void Server::readyRead()
{
    if (bytesReceived <= sizeof(qint64) * 2)
    {//先接收头部信息,获取总数居字节数和文件名
        QDataStream in(tcpConnection);
        in.setVersion(QDataStream::Qt_5_9);
        //先获取总数居个数和文件名大小
        if (!fileNameSize &&
                tcpConnection->bytesAvailable() >= sizeof(qint64)*2)
        {
            in >> totalBytes >> fileNameSize;
            bytesReceived += sizeof(qint64) * 2;
        }
        else
        {
            return;
        }
        //获取文件名
        if (fileNameSize &&
                tcpConnection->bytesAvailable() >= fileNameSize)
        {
            in >> fileName;
            localFile = new QFile(fileName);
            if (!localFile->open(QFile::WriteOnly))
            {
                qDebug() << localFile->errorString();
                tcpConnection->close();
                ui->label->setText(tr("写文件错误"));
                return;
            }
            bytesReceived += fileNameSize;
        }
        else
           return;
    }

    if (bytesReceived < totalBytes)
    {
        //从网络缓冲区读取数据
        bytesReceived += tcpConnection->bytesAvailable();
        QByteArray inBlock = tcpConnection->readAll();
        //写入文件
        localFile->write(inBlock);
    }
    //更新进度条
    ui->progressBar->setMaximum(totalBytes);
    ui->progressBar->setValue(bytesReceived);

    if (bytesReceived == totalBytes)
    {//传输完成
        localFile->close();
        tcpConnection->close();
        ui->label->setText(tr("接收文件%1成功!").arg(fileName));
        ui->pushButton->setEnabled(true);
    }
}

void Server::displayError(QAbstractSocket::SocketError)
{
    qDebug() << tcpConnection->errorString();
    ui->label->setText(tr("网络错误:%1").arg(tcpConnection->errorString()));
    tcpConnection->close();
}

void Server::on_pushButton_clicked()
{
    if (!tcpServer.listen(QHostAddress::LocalHost, 6666))
    {
        qDebug() << tcpServer.errorString();
        ui->label->setText(tr("监听失败!"));
    }
    ui->label->setText(tr("正在监听localhost的6666端口"));
    ui->progressBar->setValue(0);
    ui->pushButton->setEnabled(false);
}

将服务器和客户端对话框同时显示

修改“main.cpp”文件如下所示:

#include "client.h"
#include "server.h"

#include <QApplication>

int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    Client w;
    w.show();
    Server s;
    s.show();
    return a.exec();
}

至此,大功告成,可以到我的资源里面下载源程序。
QT编写的TCP服务端和客户端传输文件的源程序

有关使用QT编写TCP服务器与客户端程序的更多相关文章

  1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

    我正在学习如何使用Nokogiri,根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

  2. ruby - 使用 RubyZip 生成 ZIP 文件时设置压缩级别 - 2

    我有一个Ruby程序,它使用rubyzip压缩XML文件的目录树。gem。我的问题是文件开始变得很重,我想提高压缩级别,因为压缩时间不是问题。我在rubyzipdocumentation中找不到一种为创建的ZIP文件指定压缩级别的方法。有人知道如何更改此设置吗?是否有另一个允许指定压缩级别的Ruby库? 最佳答案 这是我通过查看ruby​​zip内部创建的代码。level=Zlib::BEST_COMPRESSIONZip::ZipOutputStream.open(zip_file)do|zip|Dir.glob("**/*")d

  3. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法? - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  4. ruby-on-rails - 使用 Ruby on Rails 进行自动化测试 - 最佳实践 - 2

    很好奇,就使用ruby​​onrails自动化单元测试而言,你们正在做什么?您是否创建了一个脚本来在cron中运行rake作业并将结果邮寄给您?git中的预提交Hook?只是手动调用?我完全理解测试,但想知道在错误发生之前捕获错误的最佳实践是什么。让我们理所当然地认为测试本身是完美无缺的,并且可以正常工作。下一步是什么以确保他们在正确的时间将可能有害的结果传达给您? 最佳答案 不确定您到底想听什么,但是有几个级别的自动代码库控制:在处理某项功能时,您可以使用类似autotest的内容获得关于哪些有效,哪些无效的即时反馈。要确保您的提

  5. ruby - 在 Ruby 中使用匿名模块 - 2

    假设我做了一个模块如下:m=Module.newdoclassCendend三个问题:除了对m的引用之外,还有什么方法可以访问C和m中的其他内容?我可以在创建匿名模块后为其命名吗(就像我输入“module...”一样)?如何在使用完匿名模块后将其删除,使其定义的常量不再存在? 最佳答案 三个答案:是的,使用ObjectSpace.此代码使c引用你的类(class)C不引用m:c=nilObjectSpace.each_object{|obj|c=objif(Class===objandobj.name=~/::C$/)}当然这取决于

  6. ruby - 使用 ruby​​ 和 savon 的 SOAP 服务 - 2

    我正在尝试使用ruby​​和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封,在我看来soap请求没有正确的命名空间。任何人都可以建议我

  7. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声? - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。

  8. ruby-on-rails - 'compass watch' 是如何工作的/它是如何与 rails 一起使用的 - 2

    我在我的项目目录中完成了compasscreate.和compassinitrails。几个问题:我已将我的.sass文件放在public/stylesheets中。这是放置它们的正确位置吗?当我运行compasswatch时,它不会自动编译这些.sass文件。我必须手动指定文件:compasswatchpublic/stylesheets/myfile.sass等。如何让它自动运行?文件ie.css、print.css和screen.css已放在stylesheets/compiled。如何在编译后不让它们重新出现的情况下删除它们?我自己编译的.sass文件编译成compiled/t

  9. ruby - 具有身份验证的私有(private) Ruby Gem 服务器 - 2

    我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时,它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器?这是不可能的吗?谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..

  10. ruby - 使用 ruby​​ 将 HTML 转换为纯文本并维护结构/格式 - 2

    我想将html转换为纯文本。不过,我不想只删除标签,我想智能地保留尽可能多的格式。为插入换行符标签,检测段落并格式化它们等。输入非常简单,通常是格式良好的html(不是整个文档,只是一堆内容,通常没有anchor或图像)。我可以将几个正则表达式放在一起,让我达到80%,但我认为可能有一些现有的解决方案更智能。 最佳答案 首先,不要尝试为此使用正则表达式。很有可能你会想出一个脆弱/脆弱的解决方案,它会随着HTML的变化而崩溃,或者很难管理和维护。您可以使用Nokogiri快速解析HTML并提取文本:require'nokogiri'h

随机推荐