基于Qt的UDP通信、TCP文件传输程序的设计与实现——QQ聊天群聊

🙌秋名山码民的主页
😂oi退役选手，Java、大数据、单片机、IoT均有所涉猎，热爱技术，技术无罪
🎉欢迎关注🔎点赞👍收藏⭐️留言📝
获取源码，添加WX

目录

  • 前言
  • 一、主界面和聊天窗口
  • 二、UDP聊天
  • 三、TCP文件传输
    • server类
    • Clint类
  • 最后

前言

QQ是一款优秀的聊天软件，本文将提供主要代码和思路来实现一个类似于QQ群聊的网络聊天软件，大致有以下俩个功能：

采用qt5编写，实现基于UDP的文本聊天功能，和基于TCP的文件传输功能

基本聊天会话功能

通过获取每一个用户运行该程序的时候，发送广播来实现，不仅用户登录的时候进行广播，退出、发送信息的时候都使用UDP广播来告知用户，每个用户的聊天窗口为一个端点

文件传输功能实现

文件的传输采用TCP来实现，用C/S架构

  1. 主界面选中要发送的文件，单击传输，打开发送文件对话框
  2. 当用户单击发送的时候，程序通过UDP广播给接收端，接收端在收到文件的UDP消息后，弹出提示框，是否接收
  3. 如果接收，先创建一个TCP通信客户端，双方进行TCP通信，如果拒绝，再通过UDP广播告知发送端

一、主界面和聊天窗口

在这里插入图片描述

#ifndef DRAWER_H
#define DRAWER_H#include <QToolBox>
#include <QToolButton>
#include <QWidget>
#include "myqq.h"class Drawer : public QToolBox
{
public:Drawer();
private:QToolButton *toolBtn1;//聊天对象窗口指针QWidget *chatWidget1;private slots:// 显示聊天对象窗口void showChatWidget1();MyQQ *myqq;};#endif // DRAWER_H

 	setWindowTitle(tr("My QQ v01"));setWindowIcon(QPixmap(":/images/R-C.jpg"));toolBtn1 = new QToolButton;toolBtn1->setText(tr("冰雪奇缘"));toolBtn1->setIcon(QPixmap(":/images/girl1.jpg"));toolBtn1->setAutoRaise(true); //设置toolBtn1在显示时自动提升，使得按钮外观更加立体感。toolBtn1->setToolButtonStyle(Qt::ToolButtonTextBesideIcon); //设置toolBtn1的按钮样式为图标在文本旁边的形式。// 将显示函数与抽屉盒中相对应的用户按钮进行绑定//connect(toolBtn1,SIGNAL(clicked()),this,SLOT(showChatWidget1()));//connect(toolBtn1, &QToolButton::clicked, this, &QToolBox::showChatWidget1);connect(toolBtn1, &QToolButton::clicked, this, &Drawer::showChatWidget1);

二、UDP聊天

原理：如果要进行聊天，则首先要获取所有登录用户的信息，这个功能是通过在每一个用户运行该程序时发送广播实现的，不仅用户登录时要进行广播，而且在用户退出、发送消息时都使用UDP广播来告知所有用户。

#ifndef SERVER_H
#define SERVER_H#include <QDialog>
#include <QFile>
#include <QTcpServer>
#include <QTime>namespace Ui {
class Server;
}class Server : public QDialog
{Q_OBJECTpublic:explicit Server(QWidget *parent = nullptr);~Server();void initSrv(); // 初始化服务器void refused(); // 关闭服务器protected:void closeEvent(QCloseEvent *);void updClntProgress(qint64 numBytes);private slots:void on_Server_accepted();void sendMsg(); //发送数据void updclntProgress(qint64 numBytes); // 更新进度条void on_sOpenBtn_clicked();void on_sSendBtn_clicked();void on_sCloseBtn_clicked();private:Ui::Server *ui;qint16 tPort;QTcpServer *tSrv;QString fileName;QString theFileName;QFile *locFile; //待发送的文件qint64 totalBytes; //总共要发送的qint64 bytesWritten; //已发送的qint64 bytesTobeWrite; //待发送的qint64 payloadSize;  //被初始化为一个常量QByteArray outBlock; // 缓存一次的QTcpSocket *clntConn;QTime time;signals:void sendFileName(QString fileName);
};#endif // SERVER_H
#include "server.h"
#include "ui_server.h"#include <QFile>
#include<QTcpServer>
#include<QTcpSocket>
#include<QMessageBox>
#include <QFileDialog>
#include<QDebug>Server::Server(QWidget *parent) :QDialog(parent),ui(new Ui::Server)
{ui->setupUi(this);setFixedSize(400,207);tPort = 5555;tSrv = new QTcpServer(this);connect(tSrv,&QTcpServer::newConnection,this,&Server::sendMsg);initSrv();
}void Server::initSrv()
{payloadSize = 64*1024;totalBytes = 0;bytesWritten = 0;ui->sOpenBtn->setEnabled(true);ui->sSendBtn->setEnabled(false);tSrv->close();
}// 发送数据
void Server::sendMsg()
{ui->sSendBtn->setEnabled(false);clntConn = tSrv->nextPendingConnection();connect(clntConn,SIGNAL(bytesWritten(gint64)),this,SLOT(updCIntProgress(qint64)));ui->sStatusLabel->setText(tr("开始传送文件 号1 !").arg(theFileName));locFile = new QFile(fileName);if(!locFile->open((QFile::ReadOnly))){QMessageBox::warning(this,tr("应用程序"), tr("无法读取文件号1: n各2").arg(fileName).arg(locFile->errorString()));return;}totalBytes = locFile->size();QDataStream sendOut(&outBlock, QIODevice::WriteOnly);sendOut.setVersion(QDataStream::Qt_4_7);time.start();QString curFile = fileName.right(fileName.size() - fileName.lastIndexOf('/') - 1);sendOut << qint64(0) << qint64((outBlock.size() - sizeof(qint64)*2));bytesTobeWrite = totalBytes - clntConn->write(outBlock);outBlock.reserve(0);
}// 更新进度条
void Server::updClntProgress(qint64 numBytes)
{// 防止传输大文件产生冻结qApp->processEvents();bytesWritten += (int)numBytes;if(bytesTobeWrite > 0){outBlock = locFile->read(qMin(bytesTobeWrite,payloadSize));bytesTobeWrite -= (int)clntConn->write(outBlock);outBlock.resize(0);} else{locFile->close();}ui->progressBar->setMaximum(totalBytes);ui->progressBar->setValue(bytesWritten);float useTime = time.elapsed();double speed = bytesWritten / useTime;ui->sStatusLabel->setText(tr("已发送 %1MB (%2MB/s)\n 共%3MB 已用时：%4s\n 估计剩余时间：%5秒").arg(bytesWritten/(1024*1024)).arg(bytesWritten / (1024*1024)).arg(speed*1000 / (1024*1024),0,'f',0).arg(totalBytes / (1024 * 1024)).arg(useTime/1000,0,'f',0).arg(totalBytes/speed/1000 - useTime/1000,0,'f',0));if(bytesWritten == totalBytes){locFile->close();tSrv->close();ui->sStatusLabel->setText(tr("传送文件 %1 成功").arg(theFileName));}}
Server::~Server()
{delete ui;
}void Server::on_sOpenBtn_clicked()
{fileName = QFileDialog::getOpenFileName(this);if(!fileName.isEmpty()){theFileName = fileName.right(fileName.size() - fileName.lastIndexOf('/')-1);ui->sStatusLabel->setText(tr("要发送的文件为：%1").arg(theFileName));ui->sOpenBtn->setEnabled(false);ui->sSendBtn->setEnabled(true);}
}void Server::on_sSendBtn_clicked()
{if(!tSrv->listen(QHostAddress::Any,tPort)){qDebug() << tSrv ->errorString();close();return;}ui->sStatusLabel->setText("等待……");emit sendFileName(theFileName);
}void Server::on_sCloseBtn_clicked()
{if(tSrv->isListening()){tSrv->close();if(locFile->isOpen())locFile->close();clntConn->abort();}close();
}void Server::closeEvent(QCloseEvent *)
{on_sCloseBtn_clicked();
}void Server::refused()
{tSrv->close();ui->sStatusLabel->setText(tr("对方拒绝！"));
}

三、TCP文件传输

文件的传输采用TCP来实现，用C/S（客户端/服务器）方式，创建俩个新类，client和server类

server类

在这里插入图片描述

#ifndef SERVER_H
#define SERVER_H#include <QDialog>
#include <QFile>
#include <QTcpServer>
#include <QTime>namespace Ui {
class Server;
}class Server : public QDialog
{Q_OBJECTpublic:explicit Server(QWidget *parent = nullptr);~Server();void initSrv(); // 初始化服务器void refused(); // 关闭服务器protected:void closeEvent(QCloseEvent *);void updClntProgress(qint64 numBytes);private slots:void on_Server_accepted();void sendMsg(); //发送数据void updclntProgress(qint64 numBytes); // 更新进度条void on_sOpenBtn_clicked();void on_sSendBtn_clicked();void on_sCloseBtn_clicked();private:Ui::Server *ui;qint16 tPort;QTcpServer *tSrv;QString fileName;QString theFileName;QFile *locFile; //待发送的文件qint64 totalBytes; //总共要发送的qint64 bytesWritten; //已发送的qint64 bytesTobeWrite; //待发送的qint64 payloadSize;  //被初始化为一个常量QByteArray outBlock; // 缓存一次的QTcpSocket *clntConn;QTime time;signals:void sendFileName(QString fileName);
};#endif // SERVER_H
#include "server.h"
#include "ui_server.h"#include <QFile>
#include<QTcpServer>
#include<QTcpSocket>
#include<QMessageBox>
#include <QFileDialog>
#include<QDebug>Server::Server(QWidget *parent) :QDialog(parent),ui(new Ui::Server)
{ui->setupUi(this);setFixedSize(400,207);tPort = 5555;tSrv = new QTcpServer(this);connect(tSrv,&QTcpServer::newConnection,this,&Server::sendMsg);initSrv();
}void Server::initSrv()
{payloadSize = 64*1024;totalBytes = 0;bytesWritten = 0;ui->sOpenBtn->setEnabled(true);ui->sSendBtn->setEnabled(false);tSrv->close();
}// 发送数据
void Server::sendMsg()
{ui->sSendBtn->setEnabled(false);clntConn = tSrv->nextPendingConnection();connect(clntConn,SIGNAL(bytesWritten(gint64)),this,SLOT(updCIntProgress(qint64)));ui->sStatusLabel->setText(tr("开始传送文件 号1 !").arg(theFileName));locFile = new QFile(fileName);if(!locFile->open((QFile::ReadOnly))){QMessageBox::warning(this,tr("应用程序"), tr("无法读取文件号1: n各2").arg(fileName).arg(locFile->errorString()));return;}totalBytes = locFile->size();QDataStream sendOut(&outBlock, QIODevice::WriteOnly);sendOut.setVersion(QDataStream::Qt_4_7);time.start();QString curFile = fileName.right(fileName.size() - fileName.lastIndexOf('/') - 1);sendOut << qint64(0) << qint64((outBlock.size() - sizeof(qint64)*2));bytesTobeWrite = totalBytes - clntConn->write(outBlock);outBlock.reserve(0);
}// 更新进度条
void Server::updClntProgress(qint64 numBytes)
{// 防止传输大文件产生冻结qApp->processEvents();bytesWritten += (int)numBytes;if(bytesTobeWrite > 0){outBlock = locFile->read(qMin(bytesTobeWrite,payloadSize));bytesTobeWrite -= (int)clntConn->write(outBlock);outBlock.resize(0);} else{locFile->close();}ui->progressBar->setMaximum(totalBytes);ui->progressBar->setValue(bytesWritten);float useTime = time.elapsed();double speed = bytesWritten / useTime;ui->sStatusLabel->setText(tr("已发送 %1MB (%2MB/s)\n 共%3MB 已用时：%4s\n 估计剩余时间：%5秒").arg(bytesWritten/(1024*1024)).arg(bytesWritten / (1024*1024)).arg(speed*1000 / (1024*1024),0,'f',0).arg(totalBytes / (1024 * 1024)).arg(useTime/1000,0,'f',0).arg(totalBytes/speed/1000 - useTime/1000,0,'f',0));if(bytesWritten == totalBytes){locFile->close();tSrv->close();ui->sStatusLabel->setText(tr("传送文件 %1 成功").arg(theFileName));}}
Server::~Server()
{delete ui;
}void Server::on_sOpenBtn_clicked()
{fileName = QFileDialog::getOpenFileName(this);if(!fileName.isEmpty()){theFileName = fileName.right(fileName.size() - fileName.lastIndexOf('/')-1);ui->sStatusLabel->setText(tr("要发送的文件为：%1").arg(theFileName));ui->sOpenBtn->setEnabled(false);ui->sSendBtn->setEnabled(true);}
}void Server::on_sSendBtn_clicked()
{if(!tSrv->listen(QHostAddress::Any,tPort)){qDebug() << tSrv ->errorString();close();return;}ui->sStatusLabel->setText("等待……");emit sendFileName(theFileName);
}void Server::on_sCloseBtn_clicked()
{if(tSrv->isListening()){tSrv->close();if(locFile->isOpen())locFile->close();clntConn->abort();}close();
}void Server::closeEvent(QCloseEvent *)
{on_sCloseBtn_clicked();
}void Server::refused()
{tSrv->close();ui->sStatusLabel->setText(tr("对方拒绝！"));
}

Clint类

TCP客户端类，用于接收文件。
在这里插入图片描述

#ifndef CLIENT_H
#define CLIENT_H#include <QDialog>
#include <QHostAddress>
#include <QFile>
#include <QTime>
#include <QTcpSocket>namespace Ui {
class client;
}class client : public QDialog
{Q_OBJECTpublic:explicit client(QWidget *parent = nullptr);~client();void setHostAddr(QHostAddress addr);void setFileName(QString name);protected:void closeEvent(QCloseEvent *);private:Ui::client *ui;QTcpSocket *tClnt;quint16 blockSize;QHostAddress hostAddr;qint16 tPort;qint64 totalBytes;qint64 bytesReceived;qint64 fileNameSize;QString fileName;QFile *locFile;QByteArray inBlock;QTime time;private slots:void newConn(); // 连接到服务器void readMsg(); // 读取文件数据
//    void displayErr(QAbstractSocket::SocketError); // 显示错误信息void on_cCancleBtn_clicked();void on_cCloseBtn_clicked();
};#endif // CLIENT_H
#include "client.h"
#include "ui_client.h"
#include <QDebug>
#include <QMessageBox>
#include <QTime>client::client(QWidget *parent) :QDialog(parent),ui(new Ui::client)
{ui->setupUi(this);setFixedSize(400,190);totalBytes = 0;bytesReceived = 0;fileNameSize = 0;tClnt = new QTcpSocket(this);tPort = 5555;connect(tClnt, &QTcpSocket::readyRead, this, &client::readMsg);}// 连接服务器
void client::newConn()
{blockSize = 0;tClnt->abort();tClnt->connectToHost(hostAddr,tPort);time.start();
}// 发送文件
void client::readMsg()
{QDataStream in(tClnt);in.setVersion(QDataStream::Qt_4_7);float useTime = time.elapsed();if (bytesReceived <= sizeof(qint64)*2){if ((tClnt->bytesAvailable() >= sizeof(qint64)*2) && (fileNameSize == 0)){in>>totalBytes>>fileNameSize;bytesReceived += sizeof(qint64)*2;}if((tClnt->bytesAvailable() >= fileNameSize) && (fileNameSize != 0)){in>>fileName;bytesReceived +=fileNameSize;if(!locFile->open(QFile::WriteOnly)){QMessageBox::warning(this,tr("应用程序"),tr("无法读取文件%1:\n%2.").arg(fileName).arg(locFile->errorString()));}return;}else{return;}}if (bytesReceived < totalBytes){bytesReceived += tClnt->bytesAvailable();inBlock = tClnt->readAll();locFile->write(inBlock);inBlock.resize(0);}ui->progressBar->setMaximum(totalBytes);ui->progressBar->setValue(bytesReceived);double speed = bytesReceived / useTime;ui->label_2->setText(tr("已接收 %1MB (%2MB/s)\n 共%3MB 已用时：%4s\n 估计剩余时间：%5秒").arg(bytesReceived/(1024*1024)).arg(speed*1000 / (1024*1024),0,'f',0).arg(totalBytes / (1024 * 1024)).arg(useTime/1000,0,'f',0).arg(totalBytes/speed/1000 - useTime/1000,0,'f',0));if(bytesReceived == totalBytes){locFile->close();tClnt->close();ui->label->setText(tr("接收文件 %1 成功").arg(fileName));}
}
client::~client()
{delete ui;
}void client::on_cCancleBtn_clicked()
{tClnt->abort();if(locFile->isOpen())locFile->close();}void client::on_cCloseBtn_clicked()
{tClnt->abort();if(locFile->isOpen())locFile->close();close();
}void client::closeEvent(QCloseEvent *)
{on_cCloseBtn_clicked();
}

最后

至此已完成，读者还可根据自己所需来添加一些拓展功能，更改字体、字号和颜色等等……如果本文对你有所帮助，还请三连支持一下博主！
请添加图片描述

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

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

相关文章

深度学习之基于YoloV5车辆和行人目标检测系统

深度学习之基于YoloV5车辆和行人目标检测系统

欢迎大家点赞、收藏、关注、评论啦 &#xff0c;由于篇幅有限&#xff0c;只展示了部分核心代码。 文章目录 一项目简介YOLOv5 简介YOLOv5 特点 车辆和行人目标检测系统 二、功能三、系统四. 总结 一项目简介 # 深度学习之基于 YOLOv5 车辆和行人目标检测系统介绍 深度学习在…
阅读更多...
UML建模图文详解教程——类图

UML建模图文详解教程——类图

版权声明 本文原创作者&#xff1a;谷哥的小弟作者博客地址&#xff1a;http://blog.csdn.net/lfdfhl本文参考资料&#xff1a;《UML面向对象分析、建模与设计&#xff08;第2版&#xff09;》吕云翔&#xff0c;赵天宇 著 类图概述 类图用来描述系统内各种实体的类型以及不同…
阅读更多...
【华为OD题库-033】经典屏保-java

【华为OD题库-033】经典屏保-java

题目 DVD机在视频输出时&#xff0c;为了保护电视显像管&#xff0c;在待机状态会显示"屏保动画”&#xff0c;如下图所示,DVD Logo在屏幕内来回运动&#xff0c;碰到边缘会反弹:请根据如下要求&#xff0c;实现屏保Logo坐标的计算算法 1、屏幕是一个800 * 600像素的矩形&…
阅读更多...
一文搞懂什么是 GNU/Linux 操作系统

一文搞懂什么是 GNU/Linux 操作系统

Author&#xff1a;rab 目录 前言一、UNIX二、Linux三、GNU 前言 你是否经常看见或听说过这么一句话&#xff1a;这是一个类 Unix 的 GNU/Linux 操作系统&#xff0c;你是怎么理解这句话的呢&#xff1f;想要搞懂这句话的含义&#xff0c;你需要了解以下三点基本常识。 一、U…
阅读更多...
【C++干货铺】list的使用 | 模拟实现

【C++干货铺】list的使用 | 模拟实现

个人主页点击直达&#xff1a;小白不是程序媛 C专栏&#xff1a;C干货铺 代码仓库&#xff1a;Gitee 目录 list的介绍及使用 list的介绍 list的使用 list的构造 list迭代器的使用 list的增删查改 list的模拟实现 结点的封装 迭代器的封装 list成员变量 构造函数 …
阅读更多...
Apache POI简介

Apache POI简介

三十二、Apache POI 32.1 介绍 Apache POI 是一个处理Miscrosoft Office各种文件格式的开源项目。简单来说就是&#xff0c;我们可以使用POI在Java程序中对Miscrosoft Office各种文件进行读写操作。 一般情况下&#xff0c;POI都是用于操作Excel文件。 Apache POI 的应用场…
阅读更多...
MySQL 事务的底层原理和 MVCC（二）

MySQL 事务的底层原理和 MVCC（二）

7.2. undo 日志 7.2.1. 事务回滚的需求 我们说过事务需要保证原子性&#xff0c;也就是事务中的操作要么全部完成&#xff0c;要么什么也不做。但是偏偏有时候事务执行到一半会出现一些情况&#xff0c;比如&#xff1a; 情况一&#xff1a;事务执行过程中可能遇到各种错误&a…
阅读更多...
image process那个项目的图片上色问题 第二版再说吧 这个是一个可行的方案 cv.histogram 的颜色问题

image process那个项目的图片上色问题 第二版再说吧 这个是一个可行的方案 cv.histogram 的颜色问题

Color Image Histograms and equalization with OpenCV - FreedomVC
阅读更多...
从mysql源码编译出相应的库和可执行文件及搭建mysql服务端

从mysql源码编译出相应的库和可执行文件及搭建mysql服务端

目录 1. 问题的提出 2. 源码下载 3. 升级或安装某些前置软件 3.1. 升级CMake 3.2. 升级gcc、g 4. 安装依赖库 4.1. 安装OpenSSL 4.2. 安装Curses 4.3. 安装pkg-config 5. 编译、安装 6. 编译结果、配置 7. 编译错误处理 7.1. 错误1 7.2. 错误2 8. 搭建mysql数…
阅读更多...
RedisTemplate使用详解

RedisTemplate使用详解

RedisTemplate介绍StringRedisTemplate介绍RedisConnectionFactory介绍RedisConnectionFactory源码解析 RedisOperations介绍RedisOperations源码解析 RedisTemplate使用连接池配置RedisTemplate连接池连接池配置 RedisTemplate应用场景RedisTemplate主要特点RedisTemplate使用…
阅读更多...
强化学习--多维动作状态空间的设计

强化学习--多维动作状态空间的设计

目录 一、离散动作二、连续动作1、例子12、知乎给出的示例2、github里面的代码 免责声明&#xff1a;以下代码部分来自网络&#xff0c;部分来自ChatGPT&#xff0c;部分来自个人的理解。如有其他观点&#xff0c;欢迎讨论&#xff01; 一、离散动作 注意&#xff1a;本文均以…
阅读更多...
给定一个非严格递增排列的有序数组，删除数组中的重复项

给定一个非严格递增排列的有序数组，删除数组中的重复项

实例要求&#xff1a;1、给定一个非严格递增排列的有序数组 nums &#xff1b;2、原地 删除重复出现的元素&#xff0c;使每个元素 只出现一次 &#xff1b;3、返回删除后数组的新长度&#xff1b;4、元素的 相对顺序 应该保持 一致 &#xff1b;5、然后返回 nums 中唯一元素的…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023