QT实现TCP通信(服务器与客户端搭建)

一、TCP通信框架

二、QT中的服务器操作

  1. 创建一个QTcpServer类对象,该类对象就是一个服务器
  2. 调用listen函数将该对象设置为被动监听状态,监听时,可以监听指定的ip地址,也可以监听所有主机地址,可以通过指定端口号,也可以让服务器自动选择
  3. 当有客户端发来连接请求时,该服务器会自动发射一个newConnection信号,我们可以将该信号连接到自定义槽函数处理相关逻辑
  4. 在槽函数中,可以调用nextPendingConnection函数可以获得最新连接的客户端套接字地址,我们可以将该套接字地址存储到容器中
  5. 此时服务器与客户端已经建立连接,如果有客户端向服务器发来数据,那么对应的客户端套接字就会发射一个readyRead信号
  6. 读取套接字中的数据使用read、readLine、readAll函数来完成
  7. 向套接字中写数据,可以使用write
  8. 关闭服务器,使用close来完成

Server界面代码:

系统管理文件:

QT       += core gui networkgreaterThan(QT_MAJOR_VERSION, 4): QT += widgetsCONFIG += c++11# The following define makes your compiler emit warnings if you use
# any Qt feature that has been marked deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the
# deprecated API in order to know how to port your code away from it.
DEFINES += QT_DEPRECATED_WARNINGS# You can also make your code fail to compile if it uses deprecated APIs.
# In order to do so, uncomment the following line.
# You can also select to disable deprecated APIs only up to a certain version of Qt.
#DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000    # disables all the APIs deprecated before Qt 6.0.0SOURCES += \main.cpp \widget.cppHEADERS += \widget.hFORMS += \widget.ui# Default rules for deployment.
qnx: target.path = /tmp/$${TARGET}/bin
else: unix:!android: target.path = /opt/$${TARGET}/bin
!isEmpty(target.path): INSTALLS += target

 头文件:

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpServer>   //服务器头文件
#include <QTcpSocket>   //客户端头文件
#include <QList>    //链表头文件用来存放客户端容器
#include <QDebug>
#include <QMessageBox>  //消息对话框QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_pushButton_clicked();void newConnection_slot();void readyRead_slot();  //自定义处理readyRead信号的槽函数private:Ui::Widget *ui;//定义服务器指针QTcpServer *server;//定义客户端指针链表容器QList<QTcpSocket *> clientList;};
#endif // WIDGET_H

主函数:

#include "widget.h"#include <QApplication>int main(int argc, char *argv[])
{QApplication a(argc, argv);Widget w;w.show();return a.exec();
}

主要功能函数:

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//给服务器指针实例化对象server = new QTcpServer(this);  //服务器创建完成}Widget::~Widget()
{delete ui;
}//启动服务器按钮对应的槽函数
void Widget::on_pushButton_clicked()
{//获取UI界面的端口号quint16 port = ui->lineEdit->text().toUInt();//将服务器设置为被动监听状态//bool QTcpServer::listen(const QHostAddress &address = QHostAddress::Any, quint16 port = 0)//参数1:要监听的主机地址,如果是any,表示监听所有主机地址,也可以给特定的主机地址进行监听//参数2:通过指定的端口号进行访问服务器,如果是0,表示由服务器自动分配。如果非0,则表示指定端口号//返回值:成功返回真,失败返回假if(!server->listen(QHostAddress::Any,port)){QMessageBox::critical(this, "失败", "服务器启动失败");}else{QMessageBox::information(this, "成功", "服务器启动成功");}//执行到这表明服务器启动成功,并对客户端连接进行监听,如果有客户端向服务器发来连接请求,那么该服务器就会自动发射一个newConnection信号//我们可以将信号连接到对应的槽函数中处理相关逻辑connect(server, &QTcpServer::newConnection, this, &Widget::newConnection_slot);
}void Widget::newConnection_slot()
{qDebug() <<"有客户端申请连接";//获取最新连接的客户端套接字//[virtual] QTcpSocket *QTcpServer::nextPendingConnection()QTcpSocket *s = server->nextPendingConnection();//将获取的套接字存放到客户端容器中clientList.push_back(s);//此时,客户端就和服务器建立起来联系了//如果客户端有数据向服务器发送过来,那么该套接字就会自动发送一个readyread信号//我们可以将该信号连接到自定义的槽函数中处理相关逻辑connect(s, &QTcpSocket::readyRead, this, &Widget::readyRead_slot);
}//关于readyRead信号对应槽函数的实现
void Widget::readyRead_slot()
{//删除客户端链表中的无效客户端套接字for(int i=0; i<clientList.count(); i++){//判断套接字的状态//函数原型     SocketState state() const;//功能:返回客户端状态//返回值:客户端状态,如果是0,表示无连接if(clientList[i]->state() == 0){clientList.removeAt(i);     //将下标为i的客户端移除}}//遍历所有客户端,查看是哪个客户端发来数据for(int i=0; i<clientList.count(); i++){//函数原型:qint64 bytesAvailable() const override;//功能:返回当前客户端套接字中的可读数据字节个数//返回值:当前客户端待读的字节数,如果该数据0,表示无待读数据if(clientList[i]->bytesAvailable() != 0){//读取当前客户端的相关数据//函数原型:QByteArray readAll();//功能:读取当前套接字中的所有数据,并返回一个字节数组//返回值:数据的字节数组QByteArray msg = clientList[i]->readAll();//将数据战术到ui界面上ui->listWidget->addItem(QString::fromLocal8Bit(msg));//将接收到的该消息,发送给所有客户端for(int j=0; j<clientList.count(); j++){clientList[j]->write(msg);}}}}

所用组件:

 三、QT中的客户端操作

  1. 实例化一个QTcpSocket类对象
  2. 调用该对象的成员函数connectToHost连接到服务器,连接服务器时,需要给定服务器的ip地址和端口号
  3. 如果连接服务器成功,那么该客户端就会自动发送一个connected信号,我们可以将该信号连接到自定义槽函数中处理相关逻辑
  4. 如果服务器向客户端发来数据,那么该客户端就会自动发射一个readyRead信号,我们可以将该信号连接到自定义的槽函数中处理相关逻辑
  5. 可以使用read、readLine、readAll读取客户端中的数据
  6. 可以使用write向服务器发送数据
  7. 使用成员函数disConnectFromHost断开与服务器的连接
  8. 如果成功断开与服务器的连接,那么该套接字就会自动发射一个disconn信号

Client界面代码:

 系统管理文件:

QT       += core gui networkgreaterThan(QT_MAJOR_VERSION, 4): QT += widgetsCONFIG += c++11# The following define makes your compiler emit warnings if you use
# any Qt feature that has been marked deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the
# deprecated API in order to know how to port your code away from it.
DEFINES += QT_DEPRECATED_WARNINGS# You can also make your code fail to compile if it uses deprecated APIs.
# In order to do so, uncomment the following line.
# You can also select to disable deprecated APIs only up to a certain version of Qt.
#DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000    # disables all the APIs deprecated before Qt 6.0.0SOURCES += \main.cpp \widget.cppHEADERS += \widget.hFORMS += \widget.ui# Default rules for deployment.
qnx: target.path = /tmp/$${TARGET}/bin
else: unix:!android: target.path = /opt/$${TARGET}/bin
!isEmpty(target.path): INSTALLS += target

 头文件:

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpSocket>
#include <QMessageBox>QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_pushButton_2_clicked();void connected_slot();  //自定义处理信号的槽函数void readyRead_slot();  //自定义处理readyRead信号的槽函数void disconnected_slot();   //自定义处理disconnected信号的槽函数void on_pushButton_clicked();void on_pushButton_3_clicked();private:Ui::Widget *ui;//定义一个客户端指针QTcpSocket *socket;//用户名QString userName;
};
#endif // WIDGET_H

主函数:

#include "widget.h"#include <QApplication>int main(int argc, char *argv[])
{QApplication a(argc, argv);Widget w;w.show();return a.exec();
}

主要功能函数:

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//给客户端指针实例化空间socket = new QTcpSocket(this);//如果连接服务器成功,该客户端就会发射一个connected信号//我们可以将该信号连接到自定义的槽函数中处理相关逻辑//由于该连接只需要连接一次。所有在构造函数中即可connect(socket, &QTcpSocket::connected, this, &Widget::connected_slot);//客户端与服务器连接成功后,如果服务器向客户端发来数据,那么该客户端就会自动发射一个readyRead信号//我们可以将该信号连接到自定义槽函数中处理相关逻辑connect(socket, &QTcpSocket::readyRead, this, &Widget::readyRead_slot);//当客户端与服务器断开连接后,该客户端就会自动发射1一个disconnected信号//我们可以将该信号与自定义的槽函数连接//由于只需要连接一下,所有该连接写到构造函数即可connect(socket, &QTcpSocket::disconnected, this, &Widget::disconnected_slot);
}Widget::~Widget()
{delete ui;
}//连接服务器按钮对应的槽函数
void Widget::on_pushButton_2_clicked()
{//获取UI界面的信息userName = ui->lineEdit_2->text();  //获取用户名QString hostName = ui->lineEdit_3->text();  //获取主机地址quint16 port = ui->lineEdit_4->text().toUInt();     //获取端口号//调用函数连接到主机//函数原型:[virtual] void QAbstractSocket::connectToHost(const QString &hostName, quint16 port)//参数1:服务器的主机地址//参数2:端口号//返回值:无socket->connectToHost(hostName,port);}//关于处理connected信号的槽函数
void Widget::connected_slot()
{QMessageBox::information(this,"成功","连接服务器成功");//顺便向服务器发送一条消息,说:xxx进入聊天室QString msg = userName + "进入聊天室";socket->write(msg.toLocal8Bit());
}//关于readyRead信号对应槽函数的实现
void Widget::readyRead_slot()
{//读取该客户端中的数据//返回值:QBytearrayQByteArray msg = socket->readAll();//将数据展示在UI界面ui->listWidget->addItem(QString::fromLocal8Bit(msg));}void Widget::on_pushButton_clicked()
{//获取UI界面中的编辑的文本内容QString m = ui->lineEdit->text();//整合要发送的信息QString msg = userName + ": " + m;//将消息发送给服务器socket->write(msg.toLocal8Bit());//将消息编辑框中的内容清空ui->lineEdit->clear();
}//断开服务器按钮对应的槽函数
void Widget::on_pushButton_3_clicked()
{//准备要发送的信息QString msg = userName + ": 离开聊天室";socket->write(msg.toLocal8Bit());//调用成员函数disconnectFromHost//函数原型:virtual void disconnectFromHost();//功能:断开服务器与客户端的连接//参数:无//返回值:无socket->disconnectFromHost();
}//disconn信号对应槽函数的实现
void Widget::disconnected_slot()
{QMessageBox::information(this, "退出", "断开成功");
}

 所用组件:

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

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

相关文章

mysql trace

optimizer_trace 它可以跟踪优化器做出的各种决策&#xff08;比如访问表的方法、各种开销计算、各种转换等&#xff09;&#xff0c;并将跟踪结果记录到 information_schema 数据库中的 optimizer_trace 表中。 mysql 默认是关闭 追踪的 开启、并设置格式为 josn,同时设置trac…

unity 之参数类型之引用类型

文章目录 引用类型引用类型与值类型的差异 引用类型 在Unity中&#xff0c;引用类型是指那些在内存中存储对象引用的数据类型。以下是在Unity中常见的引用类型的介绍&#xff1a; 节点&#xff08;GameObject&#xff09;&#xff1a; 在Unity中&#xff0c;游戏对象&#xff…

手写Mybatis:第20章-Mybatis 框架源码10种设计模式分析

文章目录 一、类型&#xff1a;创建型模式1.1 工厂模式1.2 单例模式1.3 建造者模式 二、类型&#xff1a;结构型模式2.1 适配器模式2.2 代理模式2.3 组合模式2.4 装饰器模式 三、类型&#xff1a;行为型模式3.1 模板模式3.2 策略模式3.3 迭代器模式 一、类型&#xff1a;创建型…

机器学习算法详解1:基础知识合集

机器学习算法详解1&#xff1a;基础知识合集 前言 ​ 本系列主要对机器学习上算法的原理进行解读&#xff0c;给大家分享一下我的观点和总结。 本篇前言 ​ 开一个新系列&#xff0c;另外现在开学了&#xff0c;忙起来了&#xff0c;所以更新会很慢。 目录结构 文章目录 机器学…

RS-485/RS-422收发器电路 DP3085 国产低成本替代MAX3085

DP3085是5V、半双工、15kV ESD 保护的 RS-485/RS-422 收发器电路&#xff0c;电路内部包含一路驱动器和一路接收器。 DP3085具有增强的摆率限制&#xff0c;助于降低输出 EMI 以及不匹配的终端连接引起的反射&#xff0c;实现 500kbps 的无误码数据传输。 DP3085芯片接收器输入…

使用Puppeteer进行游戏数据可视化

导语 Puppeteer是一个基于Node.js的库&#xff0c;可以用来控制Chrome或Chromium浏览器&#xff0c;实现网页操作、截图、测试、爬虫等功能。本文将介绍如何使用Puppeteer进行游戏数据的爬取和可视化&#xff0c;以《英雄联盟》为例。 概述 《英雄联盟》是一款由Riot Games开…

uni-app 之 图片

uni-app 之 图片 获取图片 v-bind 动态绑定 image.png <template><view><view>--- 获取图片1 ---<image src"../../static/img/tabbar_home1.png"></image></view><view>--- 获取图片2 v-bind 动态绑定---<image v-bi…

实现Android APK瘦身99.99%

摘要&#xff1a; 如何瘦身是 APK 的重要优化技术。APK 在安装和更新时都需要经过网络下载到设备&#xff0c;APK 越小&#xff0c;用户体验越好。本文作者通过对 APK 内在机制的详细解析&#xff0c;给出了对 APK 各组成成分的优化方法及技术&#xff0c;并实现了一个基本 APK…

90、00后严选出的数据可视化工具:奥威BI工具

90、00后主打一个巧用工具&#xff0c;绝不低效率上班&#xff0c;因此当擅长大数据智能可视化分析的BI数据可视化工具出现后&#xff0c;自然而然地就成了90、00后职场人常用的数据可视化工具。 奥威BI工具三大特点&#xff0c;让职场人眼前一亮&#xff01; 1、零编程&…

MyBatis-Plus深入 —— 条件构造器与插件管理

前言 在前面的文章中&#xff0c;荔枝梳理了一个MyBatis-Plus的基本使用、配置和通用Service接口&#xff0c;我们发现在MyBatis-Plus的辅助增强下我们不再需要通过配置xml文件中的sql语句来实现基本的sql操作了&#xff0c;不愧是最佳搭档&#xff01;在这篇文章中&#xff0c…

关于使用RT-Thread系统读取stm32的adc无法连续转换的问题解决

关于使用RT-Thread系统读取stm32的adc无法连续转换的问题解决 今天发现rt系统的adc有一个缺陷&#xff08;也可能是我移植的方法有问题&#xff0c;这就不得而知了&#xff01;&#xff09;&#xff0c;就是只能单次转换&#xff0c;事情是这样的&#xff1a; 我在stm32的RT-T…

开源照片管理服务LibrePhotos

本文是为了解决网友 赵云遇到的问题&#xff0c;顺便折腾的。虽然软件跑起来了&#xff0c;但是他遇到的问题&#xff0c;超出了老苏的认知。当然最终问题还是得到了解决&#xff0c;不过与 LibrePhotos 无关&#xff1b; 什么是 LibrePhotos ? LibrePhotos 是一个自托管的开源…