Qt中的网络通信

C++没有封装专门的网络套接字的类,因此C++只能调用C对应的API,而在Linux和Windows环境下的API都是不一样的
Qt作为一个C++框架提供了相关封装好的套接字通信类
在Qt中需要用到两个类,两个类都属于network且都是属于IO操作,只不过这两个类是对网络传过来数据进行IO操作
使用前需要再.pro文件里添加 += network
QTcpServer 服务器类,用于监听客户端连接和与客户端创建连接
QTcpSocket 通信的套接字类,服务器和客户端都要使用

QTcpServer常用API

常用函数

构造函数

参数指定父对象,目的是利用Qt对象树机制

QTcpServer::QTcpServer(QObject *parent = nullptr)

给套接字设置监听

//第一个参数,绑定本地地址,默认是任意一个地址,使用时建议用默认值,代表自动绑定
//第二个参数是端口号
bool QTcpServer::listen(const QHostAddress &address = QHostAddress::Any, quint16 port = 0)//判断当前对象是否在监听,是返回true,否返回false
bool QTcpServer::isListening() const//如果当前对象正在监听,返回监听的服务器地址信息否则返回QHostAddress::Null
QHostAddress QTcpServer::serverAddress() const//如果当前对象正在监听,返回监听的服务器端口号,否则返回0
quint16 QTcpServer::serverPort() const

注:
1.listen函数的两个参数都有默认值,但是端口号必须由程序员指定,否则系统会随机绑定一个端口,这样就无法连接了。建议使用5000以上的端口

获取通信套接字

此函数会获得通信使用的套接字对象,这个对象是QTcpServer的子对象,当父对象被析构时,子对象也会被析构

QTcpSocket *QTcpServer::nextPendingConnection()

本函数是一个阻塞函数。当启动服务器线程后调用这个函数后就会阻塞服务器并等待客户端连接,直到客户端连接后解除阻塞,但是不推荐使用,建议使用信号

bool QTcpServer::waitForNewConnection(int msec = 0, bool *timedOut = nullptr)
  • 第一个参数设置最大阻塞时间,单位毫秒
  • 第二个参数是个传出参数true为超时解除阻塞,false为非超时解除阻塞

信号

[signal] void QTcpServer::newConnection()

每次有新连接时都会发出newConnection信号

[signal, since 5.0] void QTcpServer::acceptError(QAbstractSocket::SocketError socketError)

当接受新连接导致错误时,会发出acceptError信号,socketError参数描述了错误信息

QTcpSocket常用API

Qt读写网络上传过来的数据,本质上是对本地的数据进行读写,因为Qt会对接收的数据放入一块分配好的内存,然后对这块内存进行读写

常用函数

构造函数

QTcpSocket::QTcpSocket(QObject *parent = nullptr)

连接服务器,指定端口和IP地址等需要的信息
第一个参数是服务器地址(IP地址),第二个参数是服务器端口,服务器绑定了哪个端口就连接哪个端口,第三个参数是打开方式,第四个参数一般不做修改

[virtual] void QAbstractSocket::connectToHost(const QString &hostName, quint16 port, QIODeviceBase::OpenMode openMode = ReadWrite, QAbstractSocket::NetworkLayerProtocol protocol = AnyIPProtocol)void QAbstractSocket::connectToHost(const QHostAddress &address, quint16 port, QIODeviceBase::OpenMode openMode = ReadWrite)

在这里插入图片描述
在这里插入图片描述

通信流程

在这里插入图片描述
在这里插入图片描述

网络通信发送文件与进度条处理

服务端

子线程文件

#include "recvfile.h"
#include <QFile>RecvFile::RecvFile(QTcpSocket* tcp,QObject *parent): QThread{parent}
{m_tcp = tcp;
}void RecvFile::run()
{QFile *file = new QFile("recv.txt");file->open(QFile::WriteOnly);//接受数据connect(m_tcp,&QTcpSocket::readyRead,this,[=](){static int count = 0;static int total = 0;if (count == 0){m_tcp->read((char*)&total,4);}//读出剩余的数据QByteArray all = m_tcp->readAll();count += all.size();file->write(all);if (count == total){m_tcp->close();m_tcp->deleteLater();file->close();file->deleteLater();emit over();}});//进入事件循环,要一直等有没有文件发过来exec();
}

主线程文件

#include "mainwindow.h"
#include "ui_mainwindow.h"
#include "recvfile.h"
#include <QMessageBox>
#include <QTcpSocket>
#include <QDebug>MainWindow::MainWindow(QWidget *parent): QMainWindow(parent), ui(new Ui::MainWindow)
{ui->setupUi(this);qDebug() << "服务器主线程:" << QThread::currentThread();m_s = new QTcpServer(this);//有连接的信号槽处理connect(m_s,&QTcpServer::newConnection,this,[=](){QTcpSocket* m_tcp = m_s->nextPendingConnection();//创建子线程对象RecvFile* subThread = new RecvFile(m_tcp);subThread->start();connect(subThread,&RecvFile::over,this,[=](){subThread->quit();subThread->wait();subThread->deleteLater();QMessageBox::information(this,"信息","文件传输完毕");});});
}MainWindow::~MainWindow()
{delete ui;
}void MainWindow::on_setListen_clicked()
{unsigned short port = ui->port->text().toUShort();m_s->listen(QHostAddress::Any,port);
}

客户端

工作类

#include "sendfile.h"
#include <QFile>
#include <QFileInfo>
#include <QHostAddress>SendFile::SendFile(QObject *parent): QObject{parent}
{}void SendFile::connectToServer(unsigned short port, QString ip)
{m_socket = new QTcpSocket;//连接服务器m_socket->connectToHost(QHostAddress(ip),port);//检测服务器和客户端是否连接成功connect(m_socket,&QTcpSocket::connected,this,&SendFile::connetOK);//断开连接操作connect(m_socket,&QTcpSocket::disconnected,this,[=](){m_socket->close();m_socket->deleteLater();emit fileFinish();});}void SendFile::sendFile(QString path)
{//打开文件QFile file(path);//第一次发送时要获取文件大小QFileInfo info(path);//文件大小int fileSize = info.size();file.open(QFile::ReadOnly);//文件没读完就一直读while (!file.atEnd()){//第一次循环就发送文件大小static int num = 0;if (num == 0){m_socket->write((char*)&fileSize,4);}QByteArray line = file.readLine();num += line.size();//计算当前的发送百分比int percent = num * 100 / fileSize;//发送对应用于进度条维护的信号emit curPercent(percent);//发送信息m_socket->write(line);}}

主窗口

#include "mainwindow.h"
#include "ui_mainwindow.h"
#include <QThread>
#include "sendfile.h"
#include <QMessageBox>
#include <QFileDialog>MainWindow::MainWindow(QWidget *parent): QMainWindow(parent), ui(new Ui::MainWindow)
{ui->setupUi(this);//初始化端口,ip和进度条ui->ip->setText("127.0.0.1");ui->port->setText("8989");ui->progressBar->setRange(0,100);ui->progressBar->setValue(0);//创建线程对象QThread* t = new QThread;//创建任务对象SendFile* worker = new SendFile;//将任务移动到线程里worker->moveToThread(t);//发送信号告诉子线程什么时候连接服务器,什么时候发送文件connect(this,&MainWindow::startConnect,worker,&SendFile::connectToServer);connect(this,&MainWindow::sendFile,worker,&SendFile::sendFile);//处理子线程发出来的信号connect(worker,&SendFile::connetOK,this,[=](){QMessageBox::information(this,"连接服务器","服务器连接成功!");});//更新进度条处理connect(worker,&SendFile::curPercent,ui->progressBar,&QProgressBar::setValue);//文件发完了就释放资源connect(worker,&SendFile::fileFinish,this,[=](){//资源释放t->quit();t->wait();worker->deleteLater();t->deleteLater();});t->start();}MainWindow::~MainWindow()
{delete ui;
}void MainWindow::on_connect_clicked()
{QString ip = ui->ip->text();unsigned short port = ui -> port->text().toUShort();emit startConnect(port,ip);
}void MainWindow::on_selFile_clicked()
{QString path = QFileDialog::getOpenFileName();if (path.isEmpty()){QMessageBox::warning(this,"警告","文件路径不能为空!");return;}ui->filePath->setText(path);
}void MainWindow::on_sendFile_clicked()
{emit sendFile(ui->filePath->text());
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/808583.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

第3章 存储系统(2)

3.3 主存储器与CPU连接 3.3.1 连接原理 现代计算机的MAR和MDR都在CPU内部。 (1)主存储器通过数据总线,地址总线,控制总线与CPU连接。 (2)数据传输率数据总线宽度*总线频率。 (4)控制总线(读写线)控制读写操作。 3.3.2 主存的扩展 数据总线宽度等于存储字长 1.位扩展法【增加…

Java-Web过滤器

文章目录 1.基本介绍1.为什么需要过滤器&#xff1f;2.基本介绍3.过滤器的基本原理 2.快速入门1.文件目录2.环境配置创建maven项目&#xff0c;导入依赖 3.代码实现1.login.jsp2.LoginCheck.java3.ManagerFilter.java编写过滤规则4.配置web.xml告诉tomcat5.admin.jsp 3.Filter的…

springboot如何切换内置web服务器?

切换内置web服务器 这是没有引入web依赖的服务 这是引入web依赖的服务 由此可知默认是tomcat服务器 那么如何切换内置服务器 只要有对应服务器的坐标即可自动切换&#xff0c;先排除tomcat再引入依赖&#xff0c;比如切换成jetty服务器 <dependency><groupId>org…

飞腾银河麒麟(ARM架构)离线安装MySql8.0.28版本

下载安装包 下载地址&#xff1a;https://downloads.mysql.com/archives/community/ 解压后上传到服务器(或者直接上传到服务器用tar -zxvf xxx.tar命令解压) 卸载mariadb 卸载命令&#xff1a;yum remove mariadb-server mariadb 检查是否还有未删除的包&#xff1a; rpm -…

模型训练----apex库报错IndexError: tuple index out of range

问题描述 在训练模型的过程中遇到了apex库的报错IndexError: tuple index out of range导致无法训练。在github查询后找到了解决方法 问题解决 需要修改/apex-master/apex/amp/utils.py这个文件的代码 从93行开始修改 if x in cache:cached_x cache[x]next_functions_ava…

【UE Niagara】蓝图获取粒子数据

目录 效果 步骤 一、创建粒子 二、创建蓝图接收Niagara参数 效果 步骤 一、创建粒子 1. 新建一个Niagara发射器&#xff0c;使用Empty模板&#xff0c;打开后先添加“Spawn Rate”模块&#xff0c;这里设置粒子生成速率为0.7 在“Initialize Particle”模块中设置粒子颜色…

Eland上传bge-base-zh-v1.5向量化模型到ElasticSearch中

最近需要做一些向量检索&#xff0c;试试ES 一、准备 系统&#xff1a;MacOS 14.3.1 ElasticSearch&#xff1a;8.13.2 Kibana&#xff1a;8.13.2 本地单机环境&#xff0c;无集群&#xff0c;也不基于Docker BGE是一个常见的文本转向量的模型&#xff0c;在很多大模型RAG应…

MobX 中 runInAction 的威力:构建原子性状态更新

"原子性状态更新"这个词可以很好地概括 runInAction 的核心功能,即将一组相关的状态更新作为一个整体,要么全部成功,要么全部失败。这种特性对于复杂的异步操作和状态管理非常重要。可以帮助我们构建更加可靠和可预测的 React 应用程序。 怎么理解原子性操作 "…

华为OD技术面试-爬楼计数(动态规划)

背景 2024-03-16 华为od 技术面试&#xff0c;记录题目和模型 题目 分析 入门级的 动态规划算法&#xff0c;直接写就行了 缓存递归 代码 DZs {} def climbStairs(n):if n<0:return 0if DZs.get(n, 0)>0 :return DZs[n]if n2:jf 2elif n1:jf 1;else:jf1 climb…

vue2+codemirror实现在线编辑java代码(一 配置)

使用vue2+codemirror实现java代码回显和编辑功能。 效果图如下: 1、安装 vue-codemirror // 指定安装4.x版本 // 目前最新版本6.x,仅支持Vue3.0 npm i vue-codemirror@4.x --save// codemirror 需要与 vue-codemirror 同时安装 npm i codemirror@5.x --save 2、引入配置文…

javaee前后端交互

1.选择Java Enterprise创建项目 2.勾选Web Profile 3.项目名称 4.创建包和类 5.继承HttpServlet并重写方法doGet和doPost 6.在web.xml里添加代码 7.点击Add Configuration,进去后点击加号 8.选择选项 9.调整如图&#xff0c;后选择Deployment进入 10.点击加号选择第一个 11.…

Java二叉树(2)

一、二叉树的链式存储 二叉树的存储分为顺序存储和链式存储 &#xff08;本文主要讲解链式存储&#xff09; 二叉树的链式存储是通过一个一个节点引用起来的&#xff0c;常见的表示方式有二叉三叉 // 孩子表示法 class Node { int val; // 数据域 Node left; // 左孩子的引用…

我为什么选择成为程序员?

前言&#xff1a; 我选择成为程序员不是兴趣所在&#xff0c;也不是为了职业发展&#xff0c;全是生活所迫&#xff01; 第一章&#xff1a;那年&#xff0c;我双手插兜&#xff0c;对外面的世界一无所知 时间回到2009年&#xff0c;时间过得真快啊&#xff0c;一下就是15年前…

6.12物联网RK3399项目开发实录-驱动开发之UART 串口的使用(wulianjishu666)

嵌入式实战开发例程【珍贵收藏&#xff0c;开发必备】&#xff1a; 链接&#xff1a;https://pan.baidu.com/s/1tkDBNH9R3iAaHOG1Zj9q1Q?pwdt41u UART 使用 简介 AIO-3399J 支持 SPI 桥接/扩展 4 个增强功能串口&#xff08;UART&#xff09;的功能&#xff0c;分别为 UA…

如何在群晖本地搭建在线PS工具Potopea并实现无公网IP远程编辑图片

文章目录 1. 部署Photopea2. 运行Photopea3. 群晖安装Cpolar4. 配置公网地址5. 公网访问测试6. 固定公网地址 本文主要介绍如何在群晖NAS使用Docker部署Potopea在线图片编辑工具&#xff0c;并结合cpolar内网穿透实现公网环境可以远程访问本地部署的Potopea. Photopea是一款强大…

[通俗易懂]《动手学强化学习》学习笔记2-第2、3、4章

文章目录 前言小总结&#xff08;前文回顾&#xff09;第二章 多臂老虎机2.2.2形式化描述 第三章 马尔可夫决策过程3.6 占用度量 代码3.6 占用度量 定理2 第四章 动态规划算法4.3.3 策略迭代算法 代码 总结 前言 参考&#xff1a; 《动手学强化学习》作者&#xff1a;张伟楠&a…

爬取豆瓣(线程、Session)优化版本

爬取豆瓣&#xff08;线程、Session&#xff09;优化版本 该文章只是为了精进基础&#xff0c;对Session、threading、网站请求解析的理解。 此版本没有爬取详情页。还在学习阶段的读者可以尝试一下。 适用于基础刚开始学习爬虫的&#xff01; 1.改进点&#xff1a; 将普通的r…

利用alibaba.item_get API接口,跨境电商如何快速获取商品详情?

利用alibaba.item_get API接口&#xff0c;跨境电商可以快速获取商品详情&#xff0c;为业务的开展提供有力支持。alibaba.item_get API接口是阿里巴巴开放平台提供的一项服务&#xff0c;它允许开发者通过调用API接口&#xff0c;获取阿里巴巴平台上商品的详细信息。以下是如何…

Android8.1 代码编译报错

注&#xff1a; 本文只是博主学习记录分享&#xff0c;仅供参考。如有错误肯定是博主理解有问题&#xff0c;谢谢&#xff01; 1. Android8.1 编译报 java 环境错误 1.1. 具休描述 Android8.1 代码编译报 Failed to run java: exce: "java": excutable file not fo…

【全网独家】oceanbase容器重启时报obshell failed错误,无法正常启动的问题处理

正常运行的oceanbase容器&#xff0c;重新启动该容器却启动不了&#xff0c;重启服务器也无法恢复&#xff0c;报obshell failed错误&#xff0c;无法正常启动&#xff0c;本文记录了问题处理过程。 一、问题现象 1、正常运行的oceanbase容器&#xff0c;重启却启动不了 2、运…