Qt开发TCPIP网络通信
TCP/IP通信(即SOCKET通信)是通过网线将 服务器Server端 和 客户机Client端 进行连接,在遵循ISO/OSI模型的四层层级构架的基础上通过TCP/IP协议建立的通讯。控制器可以设置为服务器端或客户端。
关于TCP/IP协议可详看:TCP/IP协议详解 - 知乎 (zhihu.com)
总的来说,TCP/IP通讯有两个部分: 客户端 和 服务器 QTcpServer(监听套接字) 和 QTcpSocket(通讯套接字)
监听套接字,顾名思义,监听关于各种通讯的状态,一旦进行通讯,监听套接字会启动通讯套接字,进行通讯
客户端使用connectToHost函数主动连接服务器后,服务器会触发newConnectio这个槽函数,并进行取出QTcpServer(监听套接字),将相关内容取出并赋给QTcpSocket(通讯套接字)。
客户端向服务器发送数据,触发readyRead(),进行处理,彼此传递时,原理都是这样的。
对双方来说都起作用的部分: 一旦建立连接,就会触发connected,服务器特殊一点,触发的是newConnectio 互传数据也是一样的,一旦接受到,就会触发readyread
服务器中,需要监听套接字以及通讯套接字,监听套接字用于监听客户端是否给服务器发送请求
本篇博文做了初步的学习与尝试,编写了一个客户端和服务器基于窗口通信以及文件传输的小例程。 一,客户端
客户端的代码比服务器稍简单,总的来说,使用QT中的 QTcpSocket类 与服务器进行通信只需要以下5步:
(1)创建QTcpSocket套接字对象 socket = new QTcpSocket(this);
(2)使用这个对象连接服务器 QString ip = ui.lineEdit_ip->text();//获取ip int port = ui.lineEdit_2->text().toInt();//获取端口数据 socket->connectToHost(ip, port);
(3)使用write函数向服务器发送数据 QByteArray data = ui.lineEdit_3->text().toUtf8();//获取lineEdit控件中的数据并发送给服务器 socket->write(data);
(4)当socket接收缓冲区有新数据到来时,会发出readRead()信号,因此为该信号添加槽函数以读取数据 connect(socket, &QTcpSocket::readyRead, this, &QTcpClinet::ReadData); void QTcpClinet::ReadData() { QByteArray buf = socket->readAll(); ui.textEdit->append(buf); }
(5)断开与服务器的连接(关于close()和disconnectFromHost()的区别,可以按F1看帮助) socket->disconnectFromHost();
客户端例程:(新建一个qt项目QTcpClinet(客户机)) ui界面
本地回路ip:127.0.0.1 可以连接到本地ip(电脑内部循环的ip)
如果要和局域网其他ip连接 -> 在运行(win+R)+cmd+ipconfig ->ipv4地址 查看本机ip
点击领取Qt学习资料+视频教程~「链接」
QTcpClinet.h #include #include "ui_QTcpClinet.h" #include"QTcpSocket.h" #pragma execution_character_set("utf-8") class QTcpClinet : public QWidget { Q_OBJECT public: QTcpClinet(QWidget *parent = Q_NULLPTR); ~QTcpClinet(); public slots: void on_btn_connect_clicked(); void ReadData(); void on_btn_push_clicked(); private: Ui::QTcpClinetClass ui; QTcpSocket* socket;//创建socket指针 };QTcpClinet.cpp #include "QTcpClinet.h" QTcpClinet::QTcpClinet(QWidget *parent) : QWidget(parent) { ui.setupUi(this); socket = new QTcpSocket(this); } QTcpClinet::~QTcpClinet() { delete this->socket;//回收内存 } void QTcpClinet::on_btn_connect_clicked() { if (ui.btn_connect->text()==tr("连接服务器")) { QString ip = ui.lineEdit_ip->text();//获取ip int port = ui.lineEdit_2->text().toInt();//获取端口数据 //取消已有的连接 socket->abort(); //连接服务器 socket->connectToHost(ip, port); bool isconnect = socket->waitForConnected();//等待直到连接成功 //如果连接成功 if (isconnect) { ui.textEdit->append("The connection was successful!!"); ui.btn_push->setEnabled(true);//按钮使能 //修改按键文字 ui.btn_connect->setText("断开服务器连接"); //接收缓冲区(服务器)信息 connect(socket, &QTcpSocket::readyRead, this, &QTcpClinet::ReadData); } else { ui.textEdit->append("The connection falied!!"); } } else { //断开连接 socket->disconnectFromHost(); ui.btn_connect->setText("连接服务器"); ui.btn_push->setEnabled(false);//关闭发送按钮使能 } } //接收缓冲区信息函数 void QTcpClinet::ReadData() { QByteArray buf = socket->readAll(); ui.textEdit->append(buf); } //发送按钮事件 void QTcpClinet::on_btn_push_clicked() { QByteArray data = ui.lineEdit_3->text().toUtf8();//获取lineEdit控件中的数据并发送给服务器 socket->write(data); //判断是否写入成功 bool iswrite = socket->waitForBytesWritten(); if (iswrite) { //写入成功 } else { //没有写入成功 } }二,服务器(需要一直运行哦)
服务器除了使用到了 QTcpSocket类 ,还需要用到 QTcpSever类 。即便如此,也只是比客户端复杂一点点,用到了6个步骤:
(1)创建QTcpSever对象 server = new QTcpServer(this);
(2)侦听一个端口,使得客户端可以使用这个端口访问服务器 server->listen(QHostAddress::Any, 6677);//监听所有ip和6677端口
(3)当服务器被客户端访问时,会发出newConnection()信号,因此为该信号添加槽函数,并用一个QTcpSocket对象接受客户端访问 connect(server, &QTcpServer::newConnection, this, &TcpServer::ClientConnect); void TcpServer::ClientConnect() { //解析所有客户连接 while (server->hasPendingConnections()) { //连接上后通过socket(QTcpSocket对象)获取连接信息 socket = server->nextPendingConnection(); QString str = QString("[ip:%1,port:%2]").arg(socket->peerAddress().toString()).arg(socket->peerPort());//监听客户端是否有消息发送 connect(socket, &QTcpSocket::readyRead, this, &TcpServer::ReadData1); } }
(4)使用socket的write函数向客户端发送数据 socket->write(data);
(5)当socket接收缓冲区有新数据到来时,会发出readRead()信号,因此为该信号添加槽函数以读取数据 //监听客户端是否有消息发送 connect(socket, &QTcpSocket::readyRead, this, &TcpServer::ReadData1); //获取客户端向服务器发送的信息 void TcpServer::ReadData1() { QByteArray buf = socket->readAll();//readAll最多接收65532的数据 QString str = QString("[ip:%1,port:%2]").arg(socket->peerAddress().toString()).arg(socket->peerPort()); ui.textEdit_server->append(str +QString(buf)); //socket->write("ok");//服务器接收到信息后返回一个ok }
(6)取消侦听 server->close();
服务器例程:(添加一个新的qt项目TcpServer(服务器)) ui界面 TcpServer.h #include #include"ui_TcpServer.h" #include"qtcpserver.h" #include"qtcpsocket.h" class TcpServer : public QWidget { Q_OBJECT public: TcpServer(QWidget *parent = Q_NULLPTR); ~TcpServer(); public slots: void on_btn_server_clicked(); void on_btn_listen_clicked(); private: Ui::TcpServerClass ui; QTcpServer* server; QTcpSocket* socket;//一个客户端对应一个socket void ClientConnect(); void ReadData1(); };TcpServer.cpp #include "TcpServer.h" #include"qstring.h" #include"qdebug.h" #pragma execution_character_set("utf-8") TcpServer::TcpServer(QWidget *parent) : QWidget(parent) { ui.setupUi(this); server = new QTcpServer(this); //客户机连接信号槽 connect(server, &QTcpServer::newConnection, this, &TcpServer::ClientConnect); } TcpServer::~TcpServer() { server->close(); server->deleteLater(); } void TcpServer::on_btn_listen_clicked() { if (ui.btn_listen->text()=="侦听") { //从输入框获取端口号 int port = ui.lineEdit_port->text().toInt(); //侦听指定端口的所有ip if (!server->listen(QHostAddress::Any, port)) { //若出错,则输出错误信息 qDebug() << server->errorString(); return; } //修改按键文字 ui.btn_listen->setText("取消侦听"); } else { socket->abort(); //取消侦听 server->close(); //修改按键文字 ui.btn_listen->setText("侦听"); } } void TcpServer::ClientConnect() { //解析所有客户连接 while (server->hasPendingConnections()) { //连接上后通过socket获取连接信息 socket = server->nextPendingConnection(); QString str = QString("[ip:%1,port:%2]").arg(socket->peerAddress().toString()).arg(socket->peerPort()); //提示连接成功 ui.textEdit_server->append(str+"Connect to the server"); //复选框选项为连接服务器的ip ui.comboBox->addItem(str); //将socket地址放入combobox属性内 //ui.comboBox->setItemData(ui.comboBox->count()-1, QVariant((int)socket)); //监听客户端是否有消息发送 connect(socket, &QTcpSocket::readyRead, this, &TcpServer::ReadData1); } } //获取客户端向服务器发送的信息 void TcpServer::ReadData1() { QByteArray buf = socket->readAll();//readAll最多接收65532的数据 QString str = QString("[ip:%1,port:%2]").arg(socket->peerAddress().toString()).arg(socket->peerPort()); ui.textEdit_server->append(str +QString(buf)); } //服务器向客户端发送信息 void TcpServer::on_btn_server_clicked() { if(ui.comboBox->count()== 0)return; //QTcpSocket* skt= (QTcpSocket*)ui.comboBox->itemData(ui.comboBox->currentIndex()).value(); socket->write(ui.lineEdit1->text().toUtf8()); }
注意 :write中需要写入char类型的元素或QByteArray类型的元素
效果展示:
三,TCP/IP文件传输
上文实现了消息的传输,由于 socket->readAll();(readAll最多接收65532的数据) ,因此对于大文件的传输用此方法是不可取的。
点击领取Qt学习资料+视频教程~「链接」
TCP/IP文件传输的思路: 客户端和服务器连接 客户端选择文件,并发送文件给服务器(发送的是文件的帧头,格式:文件名&大小) 服务器触发readyRead,然后解析文件帧头(获取文件名和大小),并返回客户端一个ok消息 客户端触发readyRead,然后发送文件数据,通过progressBar显示进度 服务器再次触发readyRead,接收文件数据,并保存(通过ishead判断接收的是文件帧头还是文件数据)
代码实现:
新建服务器项目(TcpServer) TcpServer.h #pragma once #include #include "ui_TcpServer.h" #include"qtcpserver.h" #include"qtcpsocket.h" #pragma execution_character_set("utf-8") class TcpServer : public QWidget { Q_OBJECT public: TcpServer(QWidget *parent = Q_NULLPTR); void hasConnect(); private: Ui::TcpServerClass ui; QTcpServer* server; QTcpSocket* socket; bool ishead; QString fileName; int fileSize;//接收文件的总大小 int recvSize;//当前接收文件的大小 QByteArray filebuf;//当前接收的文件数据 };TcpServer.cpp #include "TcpServer.h" #include"qfile.h" TcpServer::TcpServer(QWidget *parent) : QWidget(parent) { ishead = true; ui.setupUi(this); server = new QTcpServer(this); //监听1122端口的ip server->listen(QHostAddress::Any, 1122); //如果有用户连接触发槽函数 connect(server, &QTcpServer::newConnection, this, &TcpServer::hasConnect); } void TcpServer::hasConnect() { while (server->hasPendingConnections()>0)//判断当前连接了多少人 { //用socket和我们的客户端连接,一个客户端对应一个套接字socket socket = server->nextPendingConnection(); //服务器界面上输出客户端信息 ui.textEdit->append(QString("%1:新用户连接").arg(socket->peerPort())); //如果客户端发送信息过来了,触发匿名函数 connect(socket, &QTcpSocket::readyRead, [=]() { QByteArray buf = socket->readAll(); //用一个标志位ishead判断是头还是数据位 if (ishead) { //如果是头,解析头(文件名,文件大小) QString str = QString(buf); ui.textEdit->append(str); QStringList strlist = str.split("&"); fileName = strlist.at(0);//解析帧头文件名 fileSize = strlist.at(1).toInt();//解析帧头文件大小 ishead = false;//下次接收到的文件就是我们的数据 recvSize = 0; filebuf.clear(); socket->write("ok"); } else { //根据文件名和文件大小接收和保存文件 filebuf.append(buf); recvSize += buf.size();//每接收一次文件,当前文件大小+1 //当接收文件大小等于总文件大小,即文件数据接收完毕 if (recvSize>=fileSize) { //保存文件 QFile file(ui.lineEdit->text() + fileName); file.open(QIODevice::WriteOnly); file.write(filebuf); file.close(); ishead = true; } } }); } }
新建客户端项目(QTcpClient) QTcpClient.h #include #include"ui_QTcpClient.h" #include"qtcpsocket.h" #pragma execution_character_set("utf-8") class QTcpClient : public QWidget { Q_OBJECT public: QTcpClient(QWidget *parent = Q_NULLPTR); public slots: void on_btn_connect_clicked(); void on_btn_choose_clicked(); void on_btn_open_clicked(); private: Ui::QTcpClientClass ui; QTcpSocket* socket; };QTcpClient.cpp #include "QTcpClient.h" #include"qfiledialog.h" #include"qfileinfo.h" QTcpClient::QTcpClient(QWidget *parent) : QWidget(parent) { ui.setupUi(this); socket = new QTcpSocket(this); } void QTcpClient::on_btn_connect_clicked() { QString ip = ui.lineEdit_ip->text();//获取ip int port = ui.lineEdit_port->text().toInt();//获取端口数据 socket->connectToHost(ip, port);//连接服务器 //等待连接成功 if (socket->waitForConnected()) { ui.textEdit->append("连接服务器成功!"); ui.btn_open->setEnabled(true); //如果服务器发送信息到客户端,触发匿名函数 connect(socket, &QTcpSocket::readyRead, [=]() { //读取服务器发送的信息(即缓冲区信息) QByteArray buf = socket->readAll(); if (buf=="ok") { QFile file = (ui.label_path->text()); if (!file.open(QIODevice::ReadWrite)) { //读取文件失败 return; } qint64 currentlen = 0;//当前已经发送的大小 qint64 allLength = file.size();//总文件大小 do { char data[1024]; qint64 msize = file.read(data, 1024);//读文件放入打他数组中,返回读取到的大小 socket->write(data, msize);//把读取到的data数据发送给服务器 currentlen += msize;//实时获取当前发送的文件大小 ui.progressBar->setValue(currentlen *100 / allLength);//更新界面进度条 } while (currentlen < allLength);//当发送文件等于文件大小时,发送完毕,循环结束 } }); } else { ui.textEdit->append("连接服务器失败!"); } } //选择文件事件 void QTcpClient::on_btn_choose_clicked() { QString path = QFileDialog::getOpenFileName(this, "打开文件", "", "(*.*)"); ui.label_path->setText(path); } //发送文件事件 void QTcpClient::on_btn_open_clicked() { QFileInfo info(ui.label_path->text()); //用QFileInfo::fileName,size获取文件名和大小 格式:文件名&大小 //服务器用该格式解析文件名和大小 QString head = QString("%1&%2").arg(info.fileName()).arg(info.size()); //将该格式发送给服务器 toUtf8:QString转QByteArray或char类型 socket->write(head.toUtf8()); }
效果展示:
漫谈圆明春到圆明园绮春园写生早春时节的圆明园碧水春波,柳丝吐绿。进圆明园南门沿湖慢行,绮春园的柳梢传递着春的消息,不记得谁曾说过柳如烟,大概就是指这个乍暖还寒的早春时节吧,经历过寒冬的洗理,终于见到了春的色彩
寻访银洲湖秘藏着最美的植物活化石林,还有湿地江景和渔村沿着新建的万里碧道骑行到西盛村河堤,有一片树林显得特别引人注目潮涨,犹如如镜江面的一片绿叶潮退,仿佛是泊在江边的一艘绿舟。这就是位于新会城西盛村外银湖滩涂上的一片被誉为植物活化石的
东风标致全新4008草原天路自驾游如果要在北方选一条短途自驾路线,还是那种唯美的带治愈性质的公路,草原天路首当其冲。为什么我要这么说呢?先看看它的抬头中国十大公路之一。再看看它的火爆历史曾经因为过度火爆,差点收费。
同为87年,易建联已迟暮之年,韩德君却依然生猛广东队遭遇辽宁30横扫回家后,很多人把责任归咎于易建联,前国手马健甚至说易建联已经成了广东队的软肋。不得不承认,如今的阿联,对广东队已经没有贡献了,最直接的原因就是败给岁月。35岁
美丽新疆一江春水向西流的伊犁河人间无水不朝东,伊犁河水向西流。汪曾祺先生在散文伊犁河中,对伊犁河水的描述。一江春水向西流的伊犁河,穿城而过,把伊宁市分为南北两岸。在伊犁河北岸核心区,最引人注目的是全长3。4公里
美丽千户苗寨西江千户苗寨可以去,但不要太期待,如果你喜欢美景,那这个现实版的千与千寻真的在相不过了。如果你想体验苗族的文化生活,那附近随便找个村子进去待两天就好了,还免门票。来到这儿,你只能把
我有两块显示屏,体验能翻倍吗?其实在我眼中,便携式显示器这一细分品类面向的客户更多的是商务一族和游戏玩家居多,如果你最近在想添置一款便携式显示器,不妨可以看看这款雕塑家MF16LC便携式显示器在连接多设备上,有
因生产制作绰子而得名的许昌此村,故事怪多哩周末,跟着老梁逛许昌第234站绰韩村因生产制作绰子而得名的许昌此村,故事怪多哩文图梁耀国相约周六要去老七上班的地方玩,我连忙上卫星地图搜附近可去可写的村庄。还别说,一输老七的位置,
青藏行之十三稻城亚丁自驾十年(2016)虽然宾馆舒服,但是晚上渴醒了几次,睡的不太好,早起感觉头还是阵痛,高原干燥的嗓子冒烟,鼻子有些出血,稍微走走就气喘吁吁,其实本来这个海拔不至于这样,主要是昨天过于疲惫导致的,由此总
运动鞋不流行搭配运动裤了,配裙子更好看,怎么穿都有女人味穿运动鞋是很多女人的习惯,她们不喜欢高跟鞋特别板正的款式,也不喜欢太过严肃的气质,穿运动鞋既放松舒适,还比较的清爽,同时大家在搭配运动鞋的时候,也喜欢选择运动裤这种舒服的服装。运动
赵丽颖出席新代言活动,现场生图被传开,网友越来越有女人味了赵丽颖的名字再次成为热门搜索列表中的一个词条。自上次热门搜索以来已经有一段时间了。当时,赵丽颖出现在机场,但因其腰围小而引起了所有人的注意。最近,由于出色的身材和腰线,她的名字再次
怀念过去的伤感文案短句导语精选15条怀念过去的伤感文案短句1不要总是怀念过去,过去里没有一个人在等你。2当初我们说好的天长地久,现在看来不过是当初为了在一起的借口。3要么努力,要么忘记。4回忆里的人我永
夏夜喜雨,都活起来了夏天的雨,让人喜欢,让人兴奋。一场雨,浇灭了火般的炽热,带来了阵阵清凉。傍晚时分,一阵凉意飘来,正午时分的余热悄悄散去,所有的生命异样的兴奋起来,再一次活了过来。云,飘了过来,越积
盘点搭载麒麟820的手机1荣耀30S麒麟820LPDDR4XUFS2。16。5英寸60HzLCD直屏4000mAh40W有线充电后置6400万三星GW1主摄800万超广角800万长焦(3X光变30X数变)
小白学习日记佳能打印机TS3480无线WiFi设置教程佳能喷墨打印机手机WiFi设置难?哪怕跟着说明书操作都不成功?学到就是赚到,求人不如求己我是打印机小助手让你更懂如何使用你的打印机。今天为大家讲解一下佳能TS3480无线连接功能如
三星exynos2200怎么样三星exynos2200处理器相当于骁龙多少?三星目前Zui强的手机移动芯片已经推出了,三星exynos2200作为三星Zui新的旗舰手机芯片,拥有Zui强的性能,但是很多用户想要知道三星exynos2200相当于骁龙多少,因
vivos15pro酷安评分9。5,来看看网友们对这款手机的评价吧首先说一下,这款手机真正开售也就一个月左右,评价的人并不是很多,一共好像就是66个,但是几十个也是可以参考的,对不对?而且酷安并不像安兔兔或者其他的,我还是比较喜欢的。那我们废话不
世界联赛第二周1胜3负,中国男排基本完成任务张景胤(左)在比赛中扣球。图新华社6月26日晚,2022年世界男排联赛菲律宾奎松站结束,中国男排以0比3不敌意大利男排,3局比分为21比2518比2519比25。本站比赛取得1胜3
日本女排先别高兴,国际排联官宣,中国女排总决赛成最大赢家北京时间6月27日,中国女排正在保加利亚备战第三周世界联赛,球队将会在28日晚上22点迎来与巴西女排的较量,对于中国女排来说能否打好第三周的比赛,直接决定了中国女排的世联赛排名以及
让中国智造走出国门的企业到底有多强2020年初,一场突如其来的疫情,席卷全国。口罩供应制约疫情防控,成为左右人们生命的安全线。危急时刻,一家企业站了出来。3000名工程师,3天出图纸,7天出设备,10天出产品,zu
三人篮球世界杯中国女队获铜牌当地时间6月26日,在比利时安特卫普举行的2022国际篮联三人篮球世界杯女子组铜牌争夺赛中,中国队以21比11战胜立陶宛队,获得铜牌。中国队主教练许佳敏(左)和球员张芷婷在赛后拥抱
孩子王2022最新母婴行业研究报告56页纸完整版内容这是一份2022年中国母婴行业研究报告,艾瑞咨询出品,一共56纸内容。本报告中的母婴市场只为预产期女性和014岁婴童提供商品和服务的市场。母婴市场主要分为产品和服务两大类,每大类可