Qt 网络编程

QT 网络编程

TCP 编程

模块引入

QT += network

在这里插入图片描述

头文件

#include <QTcpServer> // TCP服务器端使用
#include <QTcpSocket> // TCP服务器和客户端都使用

编程流程

服务端

1）实例化 QTcpServer 对象 -----------------------------> socket
2）进入监听状态 ----> listen（QTcpServer类） // 不需要再绑定了----------->bind + listen
3）监测客户端连接 ---- newConnection 信号（QTcpServer类）
----------------> 有新连接过来，server 就能收到 newConnection 信号
4）QTcpSocket *client <---- 获得连接 ---- nextPendingConnection(QTcpServer类) ---->accept
5）连接对端接收信号 ------ readyRead（QTcpSocket类）
---------------------->如果对端有数据发送，server 就能收到 readyRead 信号
6）读取客户端消息 ------ readAll（QTcpSocket类） --------------------------> recv：读取数据
7）发送数据 ------ write（QTcpSocket类） ----> send：发数据
8）关闭连接 ------ disconnectFromHost() -------------------> close
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

客户端

1）实例化 QTcpSocket 对象；
2）连接服务器 ------ connectToHost ------> 接下来使用 waitForConnected 来判断是否连接成功
3）连接对端接收信号 ------ readyRead 信号
4）发送数据 ------ write()
5）关闭连接 ------ disconnectFromHost()
在这里插入图片描述
在这里插入图片描述

💡 客户端实现

widget.h
#ifndef WIDGET_H
#define WIDGET_H#include <QtWidgets>
#include <QTcpSocket>namespace Ui {
class Widget;
}class Widget : public QWidget
{Q_OBJECTpublic:explicit Widget(QWidget *parent = 0);~Widget();private slots:void on_connectBtn_clicked();void recvSlot();void on_sendBtn_clicked();
//    void whetherConnectedSlot();		// 判断是否连接成功，方法二private:Ui::Widget *ui;QTcpSocket *client;bool flag;
};#endif // WIDGET_H
widget.cpp
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent) :QWidget(parent),ui(new Ui::Widget)
{ui->setupUi(this);this->setWindowTitle("客户端");client = new QTcpSocket(this);QObject::connect(client, SIGNAL(readyRead()), this,  SLOT(recvSlot()));// 判断是否连接成功，方法二
//    QObject::connect(client, SIGNAL(connected()), this,  SLOT(whetherConnectedSlot()));
}Widget::~Widget()
{delete ui;
}// void Widget::whetherConnectedSlot()			// 判断是否连接成功，方法二
// {
//     flag = true;
// }void Widget::on_connectBtn_clicked()
{client->connectToHost(ui->ipEdit->text(), ui->portEdit->text().toShort());// 判断是否连接成功，方法一if (!client->waitForConnected(1000))           {qDebug() << "Failed to connect. ";return ;}qDebug() << "Connected successfully! ";ui->connectBtn->setText("断开");
}void Widget::recvSlot()
{QByteArray buffer = client->readAll();ui->recvEdit->setText(QString::fromLocal8Bit(buffer));
}void Widget::on_sendBtn_clicked()
{QString buffer = ui->sendEdit->toPlainText();client->write(buffer.toLocal8Bit());
}

在这里插入图片描述

💡 服务器实现

widget.h
#ifndef WIDGET_H
#define WIDGET_H#include <QtWidgets>
#include <QTcpServer>
#include <QTcpSocket>namespace Ui {
class Widget;
}class Widget : public QWidget
{Q_OBJECTpublic:explicit Widget(QWidget *parent = 0);~Widget();private slots:void on_connectBtn_clicked();void connectSlot();void recvSlot();void on_sendBtn_clicked();private:Ui::Widget *ui;QTcpServer *server;QTcpSocket *client;
};#endif // WIDGET_H
widget.cpp
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent) :QWidget(parent),ui(new Ui::Widget)
{ui->setupUi(this);server = new QTcpServer(this);this->setWindowTitle("服务器");// 这个信号触发，代表有客户端连接QObject::connect(server, SIGNAL(newConnection()), this,  SLOT(connectSlot()));
}Widget::~Widget()
{delete ui;
}void Widget::on_connectBtn_clicked()
{// 监听是否有客户端连入，不阻塞等待if (!server->listen(QHostAddress::Any, ui->portEdit->text().toUShort())){qDebug() << "Failed to listen. ";return ;}ui->connectBtn->setText("关闭");
}void Widget::connectSlot()
{// 接受新的客户端连接client = server->nextPendingConnection();if (client == 0){qDebug() << "There are no pending connections. ";return ;}// 一定要等到接受连接后，再去做客户端的信号连接QObject::connect(client, SIGNAL(readyRead()), this,  SLOT(recvSlot()));
}void Widget::recvSlot()
{QByteArray buffer = client->readAll();// 编码转换：对方必须按照 GBK 格式发送ui->recvEdit->setText(QString::fromLocal8Bit(buffer));
}void Widget::on_sendBtn_clicked()
{QString buffer = ui->sendEdit->toPlainText();	// 从textEdit中获取的内容一定是utf8编码client->write(buffer.toLocal8Bit());
}

在这里插入图片描述

💡 服务器与客户端交互

在这里插入图片描述

UDP 编程

模块引入

QT += network

在这里插入图片描述

头文件

#include

编程流程

1）实例化 QUdpSocket 对象 ------------------------------------------> socket
2）绑定地址、端口 ------ bind(QHostAddress::LocalHost,8888) -----> bind
3）收发报文 ------ readDatagram、writeDatagram ------------------> recvfrom/sendto
在这里插入图片描述

// 类和接口
bool 	QUdpSocket::hasPendingDatagrams() const;
qint64 	QUdpSocket::readDatagram(char * data, qint64 maxSize, QHostAddress * address = 0, quint16 * port = 0);
qint64 	QUdpSocket::writeDatagram(const char * data, qint64 size, const QHostAddress & address, quint16 port);

实现一个聊天功能，使用 UDP 通信。首先通过一个登录界面，输入服务器的 IP 和端口，点击登录后，将 IP 和端口传到聊天界面，然后通过 UDP 进行聊天（服务器）。

💡 服务器实现

在这里插入图片描述

chatpage.h
#ifndef CHATPAGE_H
#define CHATPAGE_H#include <QtWidgets>
#include <QUdpSocket>
#include "globalvalue.h"namespace Ui {
class ChatPage;
}class ChatPage : public QWidget
{Q_OBJECTpublic:explicit ChatPage(QWidget *parent = 0);~ChatPage();private:Ui::ChatPage *ui;QUdpSocket *socket;QHostAddress sender;        // 定义对端的地址，以便后续发送使用quint16 senderPort;private slots:void readPendingDatagrams();void on_sendBtn_clicked();
};#endif // CHATPAGE_H
chatpage.cpp
#include "chatpage.h"
#include "ui_chatpage.h"ChatPage::ChatPage(QWidget *parent) :QWidget(parent),ui(new Ui::ChatPage)
{ui->setupUi(this);this->setWindowTitle("聊天");// 初始化一个 QUdpSocket 对象socket = new QUdpSocket(this);// 绑定服务器的地址和IP，客户端省略此句socket->bind(QHostAddress(GlobalValue::ipaddr), GlobalValue::port);connect(socket, SIGNAL(readyRead()), this, SLOT(readPendingDatagrams()));
}ChatPage::~ChatPage()
{delete ui;
}void ChatPage::readPendingDatagrams()
{// 如果udp缓冲区有报文数据的话while (socket->hasPendingDatagrams()){QByteArray datagram;    // 初始化一个字节流缓冲区datagram.resize(socket->pendingDatagramSize());		// 重设缓冲区的大小socket->readDatagram(datagram.data(), datagram.size(), &sender, &senderPort);// 对方发送的字节流必须是GBK编码ui->recvEdit->setText(QString::fromLocal8Bit(datagram));}
}
void ChatPage::on_sendBtn_clicked()
{// 如果已经接收过消息，那么sender和senderPort已经有对方的地址了socket->writeDatagram(ui->sendEdit->toPlainText().toLocal8Bit(), sender, senderPort);
}

在这里插入图片描述

globalvalue.h
#ifndef GLOBALVALUE_H
#define GLOBALVALUE_H#include <QString>class GlobalValue           // 此类仅用于存放静态变量
{
public:GlobalValue();static QString ipaddr;static quint16 port;
};#endif // GLOBALVALUE_H
globalvalue.cpp
#include "globalvalue.h"QString GlobalValue::ipaddr;
quint16 GlobalValue::port;GlobalValue::GlobalValue()
{
}
userver.h
#ifndef USERVER_H
#define USERVER_H#include <QtWidgets>
#include "chatpage.h"
#include "globalvalue.h"namespace Ui {
class UServer;
}class UServer : public QWidget
{Q_OBJECTpublic:explicit UServer(QWidget *parent = 0);~UServer();private slots:void on_pushButton_clicked();private:Ui::UServer *ui;ChatPage *chatting;
};#endif // USERVER_H
userver.cpp
#include "userver.h"
#include "ui_userver.h"UServer::UServer(QWidget *parent) :QWidget(parent),ui(new Ui::UServer)
{ui->setupUi(this);this->setWindowTitle("登录");
}UServer::~UServer()
{delete ui;
}void UServer::on_pushButton_clicked()
{GlobalValue::ipaddr = ui->ipEdit->text();GlobalValue::port = ui->portEdit->text().toUShort();chatting = new ChatPage;chatting->show();   // 初始化一个新的界面，然后进行跳转this->close();
}

运行效果如下：
在这里插入图片描述
在这里插入图片描述

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

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

相关文章

HDU 5037 Frog(2014年北京网络赛 F 贪心)

HDU 5037 Frog(2014年北京网络赛 F 贪心)

开始就觉得有思路&#xff0c;结果越敲越麻烦。。。 　　题意很简单&#xff0c;就是说一个青蛙从0点跳到m点&#xff0c;最多可以跳l的长度&#xff0c;原有石头n个&#xff08;都仅表示一个点&#xff09;。但是可能跳不过去&#xff0c;所以你是上帝&#xff0c;可以随便在哪…
阅读更多...
Kafka高性能高吞吐的原因总结

Kafka高性能高吞吐的原因总结

1、磁盘顺序读写 保证了消息的堆积 顺序读写 磁盘会预读,预读即在读取的起始地址连续读取多个页面&#xff0c;主要时间花费在了传输时间,而这个时间两种读写可以认为是一样的。 随机读写 因为数据没有在一起&#xff0c;将预读浪费掉了&#xff0c;需要多次寻道和旋…
阅读更多...
日利率

日利率

2019独角兽企业重金招聘Python工程师标准>>> 利率计算 转载于:https://my.oschina.net/u/3342652/blog/1649028
阅读更多...
linux下使用tar命令

linux下使用tar命令

解压语法&#xff1a;tar [主选项辅选项] 文件或者目录 使用该命令时&#xff0c;主选项是必须要有的&#xff0c;它告诉tar要做什么事情&#xff0c;辅选项是辅助使用的&#xff0c;可以选用。主选项&#xff1a;c 创建新的档案文件。如果用户想备份一个目录或是一些文件&…
阅读更多...
Kafka 安装详解

Kafka 安装详解

注意&#xff1a;确保有JDK1.8版本及以上 官方文档&#xff1a;https://kafka.apache.org/quickstart 清华镜像下载&#xff1a;https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/ 首先下载安装包&#xff0c;在linux及Windows都可以使用。 1. Centos 安装部署 1.1 下载 将下…
阅读更多...
【Maui正式版】创建可跨平台的Maui程序，以及有关依赖注入、MVVM双向绑定的实现和演示...

【Maui正式版】创建可跨平台的Maui程序，以及有关依赖注入、MVVM双向绑定的实现和演示...

前言&#xff1a;Maui终于在2022年8月9日推送出来了。今儿就迫不及待来把玩一下先。A、我本地已有VS2022&#xff0c;不过版本比较老&#xff0c;此处选择更新。工具 -> 获取功能和更新里面&#xff0c;可以获取到新版本更新。B、最新版本是17.3.0&#xff0c;我本地只有17.…
阅读更多...
学go语言能做什么工作？

学go语言能做什么工作？

Go语言主要用作服务器端开发&#xff0c;其定位是用来开发“大型软件”的&#xff0c;适合于很多程序员一起开发大型软件&#xff0c;并且开发周期长&#xff0c;支持云计算的网络服务。Go语言能够让程序员快速开发&#xff0c;并且在软件不断的增长过程中&#xff0c;它能让程…
阅读更多...
WebSQL存储

WebSQL存储

2019独角兽企业重金招聘Python工程师标准>>> WebSQL这种存储技术&#xff0c;相对于学过数据库的人来说&#xff0c;还是比较容易理解和上手的&#xff0c;主要就是它的存储风格和我们一般所学的SQL Server 和Oracle比较像&#xff0c;对于HTML5来说&#xff0c;当然…
阅读更多...
软件工程第一次作业补充

软件工程第一次作业补充

1.关注《构建之法》的作者邹欣老师的博客&#xff1b;2.花二十分钟写一个能自动生成小学四则运算题目的“软件”&#xff0c;要求除了整数以外&#xff0c;还要支持真分数的四则运算。将代码上传至coding.net,并将地址发布至自己的博客。代码地址&#xff1a; https://coding.n…
阅读更多...
抖音服务器带宽有多大，才能供上亿人同时刷？

抖音服务器带宽有多大，才能供上亿人同时刷？

最近看到一个有意思的提问&#xff1a;抖音服务器带宽有多大&#xff0c;为什么能够供那么多人同时刷&#xff1f;今天来给小伙伴们科普一下。 抖音&#xff0c;百度&#xff0c;阿里云&#xff0c;腾讯都是自建的数据中心&#xff0c;都是 T 级别出口带宽&#xff08;总出口带…
阅读更多...
ASP.NET Core 5.0中的Host.CreateDefaultBuilder执行过程

ASP.NET Core 5.0中的Host.CreateDefaultBuilder执行过程

通过Rider调试的方式看了下ASP.NET Core 5.0的Web API默认项目&#xff0c;重点关注Host.CreateDefaultBuilder(args)中的执行过程&#xff0c;主要包括主机配置、应用程序配置、日志配置和依赖注入配置这4个部分。由于水平和篇幅有限&#xff0c;先整体理解、建立框架&#xf…
阅读更多...
404和302

404和302

为什么80%的码农都做不了架构师&#xff1f;>>> 404 php中用header()函数是可以为返回页面添加404的头信息的&#xff0c;从而提示浏览器该网页找不到了。 所以可以使用&#xff1a;header("HTTP/1.0 404 Not Found");或者&#xff1a;header("Stat…
阅读更多...
oracle sqlplus使用

oracle sqlplus使用

2019独角兽企业重金招聘Python工程师标准>>> 1、常用连接方式 sqlplus / as sysdba 无需数据库进入可用状态&#xff0c;就可用用该命令登录&#xff0c;运行startup来启动。 sqlplus username/pwdhost/service_name&#xff0c;如&#xff1a; sqlplus tiger/scott…
阅读更多...
20款IDEA 神级插件 效率提升 30 倍，写代码必备

20款IDEA 神级插件 效率提升 30 倍，写代码必备

插件目录 1. Alibaba Java Coding Guidelines 2.GsonFormat 3.A8Translation 4.Maven Helper 5.Free Mybatis plugin 6.Grep Console 7.Lombok 8.Nyan progress bar 9.FindBugs-IDEA 10.Key Promoter X 11.JavaDoc 12.ignore 13.RainbowBrackets 14.Activate-power-mode 15.C…
阅读更多...
【温故知新】C# Linq中 Where使用技巧

【温故知新】C# Linq中 Where使用技巧

微信公众号&#xff1a;趣编程ACE关注可了解更多的.NET日常实战开发技巧&#xff0c;如需源码 后台回复 源码 即可;如果觉得对你有帮助&#xff0c;欢迎关注C# Linq中 Where使用技巧hello 大家好&#xff0c;很开心又能重新分享C#编程开发技巧了&#xff0c;之前因为工作和生活…
阅读更多...
JS引用类型 -- Array类型

JS引用类型 -- Array类型

ECMAScript数组与其他语言中的数组都是数据的有序列表&#xff0c;但与其他语言不同的是&#xff0c;ECMAScript数组的每一项可以保存任何类型的数据。而且ECMAScript数组的大小是可以动态调整的&#xff0c;即可以随着数据的添加自动增长。 创建数组的基本方式有两种&#xff…
阅读更多...
分布式id解决方案

分布式id解决方案

文章目录 1.分布式id实现方案 1.1.uuid1.2 数据库主键自增1.3 Redis自增1.4 号段模式1.5 雪花算法&#xff08;snowflake&#xff09; 1.5.1 百度&#xff08;uid-generator&#xff09;1.5.2 美团&#xff08;Leaf&#xff09;所谓id就是能够用作唯一标识的记号。 在我们日常的…
阅读更多...
我和大象的十年往事 - 感恩、感谢、加油、腾飞

我和大象的十年往事 - 感恩、感谢、加油、腾飞

背景 http://www.idcquan.com/Special/OSCAR2018/index.html 由中国信息通信研究院主办、中国通信标准化协会支持的"OSCAR云计算开源产业大会"于2018年3月21日&#xff0d;22日在国家会议中心举行。 非常有幸获得了“OSCAR尖峰开源人物”奖项。 奖项不敢自居&#xf…
阅读更多...
Httpclient发送json请求

Httpclient发送json请求

一、Httpclient发送json请求 public String RequestJsonPost(String url){ String strresponse null; try{ HttpClient hc new DefaultHttpClient(); HttpPost hp new HttpPost(url); JSONObject jsonParam new JSONObject(); jsonParam.pu…
阅读更多...
基于ABP的AppUser对象扩展

基于ABP的AppUser对象扩展

在ABP中AppUser表的数据字段是有限的&#xff0c;现在有个场景是和小程序对接&#xff0c;需要在AppUser表中添加一个OpenId字段。今天有个小伙伴在群中遇到的问题是基于ABP的AppUser对象扩展后&#xff0c;用户查询是没有问题的&#xff0c;但是增加和更新就会报"XXX fie…
阅读更多...
最新文章

Copyright @ 2022~2023