QT实现TCP协议

devtools/2024/9/19 11:30:28/ 标签: qt, 服务器, 网络

QT中实现服务器原理

QT中实现客户端原理

网络聊天室服务器实现

  • 用QTcpServer服务器类实例化一个服务器对象
  • 通过listen()函数,监听客户端,监听可以监听指定主机,也可以监听任意主机,监听的端口号,可以是系统提供的端口号,也可以是指定的端口号。
  • 如果有客户端发来连接请求,那么服务器就会自动触发一个newConnection()信号,我们就可以将该信号连接到自定义的槽函数中,获取最新连接客户端的套接字
  • 调用newPaddingConnection()函数获取最新连接客户端的套接字,放入客户端的容器中
  • 此时说明客户端和服务器建立了连接,那么如果有客户端向服务器发来数据,那么客户端就会自动发射一个readyRead()信号,我们就可以将该信号连接到自定义的槽函数中,读取客户端的数据
  • 调用read(),read Line(),read All()读取客户端的数据,调用write()往套接字中写入数据
  • 调用close()关闭服务器

头文件

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpServer>   //服务器类
#include <QMessageBox>
#include <QDebug>
#include <QTcpSocket>  //客户端类
#include <QList>  //链表容器QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_start_clicked();void newConnection_slots();  //newConnection对应的槽函数声明void readyRead_slots();  //readyRead对应的槽函数声明private:Ui::Widget *ui;QTcpServer *server;//定义一个客户端容器QList<QTcpSocket *> socketlist;
};
#endif // WIDGET_H

源文件

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget), server(new QTcpServer(this))
{ui->setupUi(this);
}Widget::~Widget()
{delete ui;
}void Widget::on_start_clicked()
{qint16 port = ui->port->text().toUInt(); //将字符串转换为整型//参数一:监听的主机,可以是任意,可以是指定//参数二:监听的端口号//返回值:监听成功返回true,失败返回falseif(server->listen(QHostAddress::Any,port)){//监听成功QMessageBox::information(this, "", "服务器已启动");ui->start->setEnabled(false);}else{//监听失败QMessageBox::information(this, "", "服务器启动失败");return;  //启动失败终止程序}//程序运行至此,说明监听成功,如果有客户端发来连接请求,那么服务器就会自动//发射一个newConnection,我们就可以将该信号连接到自定义的槽函数中处理相关逻辑代码connect(server,&QTcpServer::newConnection,this,&Widget::newConnection_slots);
}//newConnection对应的槽函数
void Widget::newConnection_slots()
{qDebug() << "有新的客户端连接";//获取最新连接客户端的套接字QTcpSocket * s = server->nextPendingConnection();//将客户端放入客户端容器中socketlist.push_back(s);//说明客户端和服务器已经建立了连接,如果客户端向服务器发来数据,客户端会自动发射一个readyRead()信号//我们就可以将该信号连接到自定义的槽函数中,读取该数据connect(s,&QTcpSocket::readyRead,this,&Widget::readyRead_slots);}//readyRead对应的槽函数
void Widget::readyRead_slots()
{//读取客户端的数据//遍历客户端容器,移除无效客户端for(int i = 0;i < socketlist.count();i++)  //count表示容器里的元素个数,等价于size{//判断客户端和服务器的连接状态//未连接状态的枚举值为0if(socketlist.at(i)->state() == 0)    //==0为无效客户端{//移除无效客户端socketlist.removeAt(i);}}//遍历客户端容器,判断哪个客户端有数据待读for(int i = 0;i<socketlist.count();i++){//判断哪个客户端有数据待读if(socketlist.at(i)->bytesAvailable() != 0){//读取数据QByteArray msg = socketlist.at(i)->readAll();//将读取到的数据放入ui界面上ui->listWidget->addItem(QString::fromLocal8Bit(msg));//将数据广播给所有客户端for(int j = 0;j<socketlist.count();j++){socketlist.at(j)->write(msg);}}}
}

网络聊天室客户端实现

  • 用QTcpSocket客户端类实例化一个服务器对象
  • 用connectToHost()连接服务器
  • 如果有客户端成功连接到服务器,那么客户端就会自动发射一个connected()信号,我们就可以将信号连接到自定义槽函数中处理逻辑代码
  • 此时说明客户端和服务器建立了连接,如果服务器向客户端发送数据,那么客户端就会自动发射一个readyRead()信号,我们就可以将信号连接到自定义槽函数中处理逻辑代码
  • 调用read(),read Line(),read All()读取客户端的数据,调用write()往套接字中写入数据
  • 调用disconnectFromHost()断开与服务器的连接,如果成功断开连接,那么客户端就会自动发射一个disconnected()信号,我们就可以将信号连接到自定义槽函数中处理逻辑代码。

头文件

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpSocket>QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_connnect_clicked();void connected_slots(); //connected信号对应的槽函数声明void readyRead_slots(); //readyRead信号对应的槽函数声明void disconnected_slots(); //disconnected信号对应的槽函数声明void on_send_clicked();void on_disconnect_clicked();private:Ui::Widget *ui;//实例化一个客户端指针QTcpSocket *socket;//定义一个存储用户名的变量QString username;QString msg1;
};
#endif // WIDGET_H

源文件

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget), socket(new QTcpSocket(this))
{ui->setupUi(this);//初始化界面ui->chat->setEnabled(false);ui->send->setEnabled(false);ui->disconnect->setEnabled(false);//如果客户端成功连接服务器,那么客户端就会自动发送一个connected()信号//我们就可以将该信号连接到自定义的槽函数中处理逻辑代码//由于只需要连接一次,所以连接函数写在构造函数中connect(socket,&QTcpSocket::connected,this,&Widget::connected_slots);//如果服务器向客户端发来数据,那么客户端就会自动发送一个readyRead信号//我们就可以将该信号连接到自定义的槽函数中获取服务器发来的数据//由于只需要连接一次,所以连接函数写在构造函数中connect(socket,&QTcpSocket::readyRead,this,&Widget::readyRead_slots);//如果成功与服务器断开连接,客户端自动发送disconnected信号//我们就可以将该信号连接到自定义的槽函数中处理逻辑代码//由于只需要连接一次,所以连接函数写在构造函数中connect(socket,&QTcpSocket::disconnected,this,&Widget::disconnected_slots);
}Widget::~Widget()
{delete ui;
}//连接服务器按钮对应的槽函数
void Widget::on_connnect_clicked()
{//获取ui界面上的ip和端口号QString ip = ui->ip->text();qint16 port = ui->port->text().toUInt(); //将字符串转换为整型//让客户端连接服务器//参数一:连接服务器的ip地址//参数二:连接服务器的端口号socket->connectToHost(ip,port);}//connected信号对应的槽函数
void Widget::connected_slots()
{username = ui->username->text();//告诉服务器,我来了QString msg = username + ":进入聊天室";//将消息发送给服务器socket->write(msg.toLocal8Bit());ui->chat->setEnabled(true);ui->send->setEnabled(true);ui->disconnect->setEnabled(true);ui->username->setEnabled(false);ui->ip->setEnabled(false);ui->port->setEnabled(false);ui->connnect->setEnabled(false);}//发送按钮对应的槽函数
void Widget::on_send_clicked()
{//获取ui界面上的文本msg1 = username + ":" + ui->chat->text();//将信息发送给服务器socket->write(msg1.toLocal8Bit());qDebug() << msg1;//清空输入框ui->chat->clear();}//readyRead信号对应的槽函数
void Widget::readyRead_slots()
{//读取服务器发来的数据QByteArray msg = socket->readAll();if(msg1 == QString::fromLocal8Bit(msg)){QListWidgetItem* item = new QListWidgetItem(ui->listWidget);item->setText(QString::fromLocal8Bit(msg));item->setTextAlignment(Qt::AlignRight);ui->listWidget->addItem(item);}else{qDebug() << "2";//将读取到的数据放到ui界面上ui->listWidget->addItem(QString::fromLocal8Bit(msg));}}//disconnected信号对应的槽函数
void Widget::disconnected_slots()
{ui->chat->setEnabled(false);ui->send->setEnabled(false);ui->disconnect->setEnabled(false);ui->username->setEnabled(true);ui->ip->setEnabled(true);ui->port->setEnabled(true);ui->connnect->setEnabled(true);
}//断开连接按钮对应的槽函数
void Widget::on_disconnect_clicked()
{//告诉服务器,以下线QString msg = username + "已下线";socket->write(msg.toLocal8Bit());//断开与服务器的连接socket->disconnectFromHost();
}

练习

 

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget), socket(new QTcpSocket(this))
{ui->setupUi(this);//初始化界面ui->chat->setEnabled(false);ui->send->setEnabled(false);ui->disconnect->setEnabled(false);//如果客户端成功连接服务器,那么客户端就会自动发送一个connected()信号//我们就可以将该信号连接到自定义的槽函数中处理逻辑代码//由于只需要连接一次,所以连接函数写在构造函数中connect(socket,&QTcpSocket::connected,this,&Widget::connected_slots);//如果服务器向客户端发来数据,那么客户端就会自动发送一个readyRead信号//我们就可以将该信号连接到自定义的槽函数中获取服务器发来的数据//由于只需要连接一次,所以连接函数写在构造函数中connect(socket,&QTcpSocket::readyRead,this,&Widget::readyRead_slots);//如果成功与服务器断开连接,客户端自动发送disconnected信号//我们就可以将该信号连接到自定义的槽函数中处理逻辑代码//由于只需要连接一次,所以连接函数写在构造函数中connect(socket,&QTcpSocket::disconnected,this,&Widget::disconnected_slots);
}Widget::~Widget()
{delete ui;
}//连接服务器按钮对应的槽函数
void Widget::on_connnect_clicked()
{//获取ui界面上的ip和端口号QString ip = ui->ip->text();qint16 port = ui->port->text().toUInt(); //将字符串转换为整型//让客户端连接服务器//参数一:连接服务器的ip地址//参数二:连接服务器的端口号socket->connectToHost(ip,port);}//connected信号对应的槽函数
void Widget::connected_slots()
{username = ui->username->text();//告诉服务器,我来了QString msg = username + ":进入聊天室";//将消息发送给服务器socket->write(msg.toLocal8Bit());ui->chat->setEnabled(true);ui->send->setEnabled(true);ui->disconnect->setEnabled(true);ui->username->setEnabled(false);ui->ip->setEnabled(false);ui->port->setEnabled(false);ui->connnect->setEnabled(false);}//发送按钮对应的槽函数
void Widget::on_send_clicked()
{//获取ui界面上的文本msg1 = username + ":" + ui->chat->text();//将信息发送给服务器socket->write(msg1.toLocal8Bit());qDebug() << msg1;//清空输入框ui->chat->clear();}//readyRead信号对应的槽函数
void Widget::readyRead_slots()
{//读取服务器发来的数据QByteArray msg = socket->readAll();  //自己的消息靠右显示if(msg1 == QString::fromLocal8Bit(msg)){QListWidgetItem* item = new QListWidgetItem(ui->listWidget);item->setText(QString::fromLocal8Bit(msg));item->setTextAlignment(Qt::AlignRight);ui->listWidget->addItem(item);}else{qDebug() << "2";//将读取到的数据放到ui界面上ui->listWidget->addItem(QString::fromLocal8Bit(msg));}}//disconnected信号对应的槽函数
void Widget::disconnected_slots()
{ui->chat->setEnabled(false);ui->send->setEnabled(false);ui->disconnect->setEnabled(false);ui->username->setEnabled(true);ui->ip->setEnabled(true);ui->port->setEnabled(true);ui->connnect->setEnabled(true);
}//断开连接按钮对应的槽函数
void Widget::on_disconnect_clicked()
{//告诉服务器,以下线QString msg = username + "已下线";socket->write(msg.toLocal8Bit());//断开与服务器的连接socket->disconnectFromHost();
}

 


http://www.ppmy.cn/devtools/114126.html

相关文章

数据库连接池与Druid【后端 16】

数据库连接池与Druid 在现代软件开发中&#xff0c;数据库连接池作为一种关键的技术手段&#xff0c;被广泛用于提升数据库访问的效率和稳定性。本文将深入探讨数据库连接池的概念、常见实现&#xff0c;并重点介绍我国阿里集团开源的数据库连接池——Druid&#xff0c;以及如何…

10款超好用的文档加密软件|企业常用的文档加密软件排行榜

在当今信息化时代&#xff0c;文档加密已成为企业保障数据安全的关键手段之一。无论是保护敏感的财务数据、合同文件&#xff0c;还是防止机密信息泄露&#xff0c;文档加密软件都是企业日常运营不可或缺的工具。本文将介绍10款企业常用的文档加密软件&#xff0c;并为您提供详…

web技术栈总体概念

Web技术栈是指用于开发和运行Web应用程序的一组技术集合&#xff0c;它涵盖了前端、后端、数据库以及相关的开发工具和实用程序等多个方面。具体来说&#xff0c;Web技术栈主要包括以下几个部分&#xff1a; 一、前端技术栈 前端技术栈主要负责构建用户界面和处理用户交互。它…

【TabBar嵌套Navigation案例-复习昨天的内容-预习今天的内容 Objective-C语言】

一、复习与预习 1.我们昨天呢,是从发现开始讲的 发现那个页面,就是一个静态单元格, 点第一个合买,首先,隐藏tabbar, 一开始,是用hideBottomBarOnPush,然后,你需要把你自定义的这个tabbar,加到系统的tabbar里边,然后,再去勾选这个选项,因为那个选项,只是隐藏系统…

C++编程:多线程环境下std::vector内存越界导致的coredump问题分析

文章目录 1. 背景描述2. 问题分析3. 问题复现示例4. 数据竞争&#xff1a;并发访问未加锁的共享数据 5. 解决方案5.1 方法一&#xff1a;提前resize分配足够的内存5.2 方法二&#xff1a;使用同步机制保护共享资源&#xff08;最优解&#xff09; 6. 问题定位总结6.1 内存越界难…

6年前倒闭的机器人独角兽,再次杀入AGV市场

导语 大家好&#xff0c;我是社长&#xff0c;老K。专注分享智能制造和智能仓储物流等内容。 新书《智能物流系统构成与技术实践》 在科技创新的浪潮中&#xff0c;一个曾经辉煌又迅速陨落的企业正悄然重生&#xff0c;引发业界广泛关注。 曾经的协作机器人鼻祖Rethink Robotic…

堆的概念与实现

目录 一、堆的介绍 1.堆的概念 2.堆的性质&#xff1a; 3.堆的结构 二、堆的实现 1.堆的定义 2.接口函数 三、堆的实现 1.堆的初始化 2.堆的销毁 3.获取堆顶数据 4.判断堆是否为空 5. 堆的插入 向上调整算法&#xff08;重点&#xff09; 向下调整算法(重点) 6.删除…

el-table多选,分页切换时,选中内容不变;清空多选的内容

el-table中添加:row-key“getRowKeys” 设置true【 :reserve-selection“true”】 :row-key"getRowKeys" <el-table-column type"selection" :reserve-selection"true" width"55" align"center" fixed"left" …

day14-单例设计模式动态代理

一、单例设计模式 单例设计模式作用&#xff1a;确保一个类只有一个对象。场景&#xff1a;计算机中的回收站、任务管理器、Java中的Runtime类等好处&#xff1a;在这些业务场景下&#xff0c;使用单例模式&#xff0c;可以避免浪费内存。 1.1 饿汉式 饿汉式(提前创建对象)把类…

828华为云征文|华为云Flexus X实例docker部署Rocket.Chat构建属于自己的团队通讯协作平台

828华为云征文&#xff5c;华为云Flexus X实例docker部署Rocket.Chat构建属于自己的团队通讯协作平台 华为云最近正在举办828 B2B企业节&#xff0c;Flexus X实例的促销力度非常大&#xff0c;特别适合那些对算力性能有高要求的小伙伴。如果你有自建MySQL、Redis、Nginx等服务…

闲鱼网页版开放,爬虫的难度指数级降低。

爬虫&#xff0c;可以说是程序员最基础的热手项目。 之前我也一直说阿里系的签名系统搞得太复杂&#xff0c;风控太高&#xff0c;很不利于正常的自动化工具开发&#xff0c;这对于需要阿里应用的客户来说&#xff0c;也是一个很难覆盖的成本支出不是。 当然&#xff0c;我做项…

iPhone 16系列:摄影艺术的全新演绎,探索影像新境界

在科技的浪潮中&#xff0c;智能手机摄影功能的进化从未停歇。 苹果公司即将推出的iPhone 16系列&#xff0c;以其卓越的相机升级和创新特性&#xff0c;再次站在了手机摄影的前沿。 从硬件到软件&#xff0c;从拍照体验到图像处理&#xff0c;iPhone 16系列都展现了其在移动…

python毕业设计基于django+vue医院社区医疗挂号预约综合管理系统7918h-pycharm-flask

目录 技术栈和环境说明预期达到的目标具体实现截图系统设计Python技术介绍django框架介绍flask框架介绍解决的思路性能/安全/负载方面可行性分析论证python-flask核心代码部分展示python-django核心代码部分展示操作可行性技术路线感恩大学老师和同学详细视频演示源码获取 技术…

数据结构与算法-18算法专向(hash)

话题引入&#xff1a; 给你N&#xff08;1<N<10&#xff09;个自然数,每个数的范围为&#xff08;1~10000000000&#xff09;。现在让你以最快的速度判断某一个数是否在这N个数内&#xff0c;不得使用已经封装好的类&#xff0c;该如何实现。 A[] new int[N1]&#xff…

k8s1.27.7部署higress,代理非k8s集群业务

一、简介 Higress是基于阿里内部的Envoy Gateway实践沉淀、以开源Istio + Envoy为核心构建的云原生API网关,实现了流量网关 + 微服务网关 + 安全网关三合一的高集成能力,深度集成Dubbo、Nacos、Sentinel等微服务技术栈,能够帮助用户极大的降低网关的部署及运维成本且能力不…

使用llama.cpp 在推理MiniCPM-1.2B模型

llama.cpp 是一个开源项目&#xff0c;它允许用户在C中实现与LLaMA&#xff08;Large Language Model Meta AI&#xff09;模型的交互。LLaMA模型是由Meta Platforms开发的一种大型语言模型&#xff0c;虽然llama.cpp本身并不包含LLaMA模型的训练代码或模型权重&#xff0c;但它…

SQL数据库(MySQL)

一、在Ubuntu系统下安装MySQL数据库 1、更新软件源&#xff0c;在确保ubuntu系统能正常上网的情况下执行以下命令 sudo apt-get update 2、安装MySQL数据库及相关软件包 # 安装过程中设置root用户的密码 123456 sudo apt-get install mysql-server ​ # 安装访问数据库的客…

scanf()函数的介绍及基础用法

目录 scanf&#xff08;&#xff09;函数的介绍及基础用法 一&#xff1a;头文件 二&#xff1a;一般用法 三&#xff1a;返回值 1. 正整数的情况&#xff1a; 2. 0 的情况&#xff1a; 3. EOF的情况&#xff1a; 四&#xff1a;说明 scanf&#xff08;&#xff09;函数…

IP池对数据爬取工作的帮助

在数据爬取的过程中&#xff0c;IP池&#xff08;也称为代理IP池&#xff09;是一个极为重要的工具&#xff0c;它为数据抓取工作提供了多方面的支持和便利。本文将详细探讨IP池在数据爬取工作中的具体作用&#xff0c;以及它如何帮助提升数据抓取的效率、稳定性和合规性。 一…

新手教学系列——基于统一页面的管理后台设计(一)

在现代企业级应用中,后台管理系统往往是核心组成部分,特别是随着业务规模的扩展,如何在多个后端服务模块的基础上实现统一的登录验证、权限控制和页面管理,成为许多开发者面对的挑战。本文将以实际项目为例,详细讲解如何设计一个多模块的后台管理系统,满足不同服务模块的…