支持语音与视频即时通讯项目杂记（一）

    

第一部分解释服务端的实现。

（服务端结构）

   下面一个用于实现TCP服务器的代码，包括消息服务器（TcpMsgServer）和文件中转服务器（TcpFileServer）。

首先，TcpServer是TcpMsgServer和TcpFileServer的基类，它负责创建QTcpServer对象并监听端口。通过StartListen()函数可以启动监听，传入指定的端口号进行监听。CloseListen()函数用于关闭监听。

TcpMsgServer是消息服务器，继承自TcpServer类。它通过重写SltNewConnection()函数来处理新客户端连接的逻辑。当有新的客户端连接到服务器时，会创建一个ClientSocket对象来管理该客户端连接。在SltConnected()函数中，对连接进行验证后，将客户端对象添加到容器m_clients中，并建立与该客户端的信号与槽连接。在SltDisConnected()函数中，处理客户端下线的情况，从容器中移除对应的客户端对象，并断开相关的信号与槽连接。SltMsgToClient()函数用于消息转发控制，根据收到的消息类型、目标客户端ID和消息内容，找到对应的客户端对象，并调用其SltSendMessage()函数将消息发送给客户端。

TcpFileServer是文件中转服务器，同样继承自TcpServer类。它也重写了SltNewConnection()函数来处理新的客户端连接。在SltConnected()函数中，将连接上的客户端对象添加到容器m_clients中。SltDisConnected()函数处理客户端断连的情况，从容器中移除对应的客户端对象，并断开相关的信号与槽连接。SltClientDownloadFile()函数处理客户端请求下载文件的情况，根据收到的消息中的来源ID和文件名，在容器m_clients中找到对应的客户端对象，调用其StartTransferFile()函数开始文件传输过程。

在代码中，TcpMsgServer和TcpFileServer都采用了容器来管理连接的客户端对象，以便进行消息转发和文件传输等操作。

#include "tcpserver.h"
#include "clientsocket.h"
#include "myapp.h"
#include "databasemagr.h"#include <QHostAddress>/
/// 服务器类，是TcpMsgServer和TcpFileServer的基类
TcpServer::TcpServer(QObject *parent) :QObject(parent)
{m_tcpServer = new QTcpServer(this);connect(m_tcpServer, SIGNAL(newConnection()), this, SLOT(SltNewConnection()));
}TcpServer::~TcpServer()
{if (m_tcpServer->isListening()) m_tcpServer->close();
}///启动监听
bool TcpServer::StartListen(int port)
{if (m_tcpServer->isListening()) m_tcpServer->close();bool bOk = m_tcpServer->listen(QHostAddress::Any, port);return bOk;
}///关闭监听
void TcpServer::CloseListen()
{m_tcpServer->close();
}/
/// 消息服务器
TcpMsgServer::TcpMsgServer(QObject *parent) :TcpServer(parent)
{
}TcpMsgServer::~TcpMsgServer()
{qDebug() << "tcp server close";foreach (ClientSocket *client, m_clients) {m_clients.removeOne(client);client->Close();}
}/// 新客户端连接处理
void TcpMsgServer::SltNewConnection()
{ClientSocket *client = new ClientSocket(this, m_tcpServer->nextPendingConnection());connect(client, SIGNAL(signalConnected()), this, SLOT(SltConnected()));connect(client, SIGNAL(signalDisConnected()), this, SLOT(SltDisConnected()));
}///通过验证后，才可以加入容器进行管理
void TcpMsgServer::SltConnected()
{ClientSocket *client = (ClientSocket *)this->sender();if (NULL == client) return;connect(client, SIGNAL(signalMsgToClient(quint8,int,QJsonValue)),this, SLOT(SltMsgToClient(quint8,int,QJsonValue)));connect(client, SIGNAL(signalDownloadFile(QJsonValue)), this, SIGNAL(signalDownloadFile(QJsonValue)));m_clients.push_back(client);qDebug() << "TcpMsgServer::SltConnected. last m_nId=" + QString::number(m_clients[m_clients.size()-1]->GetUserId());
}///有客户端下线
void TcpMsgServer::SltDisConnected()
{//找到断连的socketClientSocket *client = (ClientSocket *)this->sender();if (NULL == client) return;//移除对应socketfor (int i = 0; i < m_clients.size(); i++) {if (client == m_clients.at(i)){m_clients.remove(i);return;}}disconnect(client, SIGNAL(signalConnected()), this, SLOT(SltConnected()));disconnect(client, SIGNAL(signalDisConnected()), this, SLOT(SltDisConnected()));disconnect(client, SIGNAL(signalMsgToClient(quint8,int,QJsonValue)),this, SLOT(SltMsgToClient(quint8,int,QJsonValue)));disconnect(client, SIGNAL(signalDownloadFile(QJsonValue)), this, SIGNAL(signalDownloadFile(QJsonValue)));
}///消息转发控制
void TcpMsgServer::SltMsgToClient(const quint8 &type, const int &id, const QJsonValue &json)
{// 查找要发送过去的idfor (int i = 0; i < m_clients.size(); i++) {if (id == m_clients.at(i)->GetUserId()){qDebug()<<"TcpMsgServer::SltMsgToClient. send to:"+QString::number(id);m_clients.at(i)->SltSendMessage(type, json);return;}}
}///传送文件到指定ID的客户端
void TcpMsgServer::SltTransFileToClient(const int &userId, const QJsonValue &json)
{// 查找要发送过去的idfor (int i = 0; i < m_clients.size(); i++) {if (userId == m_clients.at(i)->GetUserId()){m_clients.at(i)->SltSendMessage(SendFile, json);return;}}
}//
/// 文件中转服务器，客户端先把待转发的文件保存在服务器
/// 服务器接受完成后，通知其他客户端来下载
TcpFileServer::TcpFileServer(QObject *parent) :TcpServer(parent)
{
}TcpFileServer::~TcpFileServer()
{qDebug() << "tcp server close";foreach (ClientFileSocket *client, m_clients) {m_clients.removeOne(client);client->Close();}
}///客户端与文件服务器新建连接
void TcpFileServer::SltNewConnection()
{//新建槽函数与socketClientFileSocket *client = new ClientFileSocket(this, m_tcpServer->nextPendingConnection());connect(client, SIGNAL(signalConnected()), this, SLOT(SltConnected()));connect(client, SIGNAL(signalDisConnected()), this, SLOT(SltDisConnected()));
}/// socket管理
void TcpFileServer::SltConnected()
{//连接时将Client放入vector m_clientsClientFileSocket *client = (ClientFileSocket *)this->sender();if (NULL == client) return;m_clients.push_back(client);
}/// 客户端断连
void TcpFileServer::SltDisConnected()
{ClientFileSocket *client = (ClientFileSocket *)this->sender();if (NULL == client) return;for (int i = 0; i < m_clients.size(); i++) {if (client == m_clients.at(i)){m_clients.remove(i);return;}}disconnect(client, SIGNAL(signalConnected()), this, SLOT(SltConnected()));disconnect(client, SIGNAL(signalDisConnected()), this, SLOT(SltDisConnected()));
}/// 客户端请求下载文件
void TcpFileServer::SltClientDownloadFile(const QJsonValue &json)
{// 根据ID寻找连接的socketif (json.isObject()) {QJsonObject jsonObj = json.toObject();qint32 nId = jsonObj.value("from").toInt();//qint32 nWid = jsonObj.value("id").toInt();;//QString fileName = jsonObj.value("msg").toString();qDebug() << "get file" << jsonObj << m_clients.size();for (int i = 0; i < m_clients.size(); i++) {if (m_clients.at(i)->CheckUserId(nId, nWid)){m_clients.at(i)->StartTransferFile(fileName);return;}}}
}

       当服务端端通过accpt收到一个请求后，创建一个ClientSocket，处理客户端消息。
        下面是一个Qt中的客户端socket管理类，用于与服务端进行通信。其中包含两个类，一个是ClientSocket，用于处理普通消息，另一个是ClientFileSocket，用于处理文件传输。

在ClientSocket中，包含了一些信号和槽函数，用于处理连接、数据接收、关闭等操作。同时还有一些私有函数，用于解析不同类型的消息，并且把解析后的数据发送到前台界面进行展示。

在ClientFileSocket中，主要有两个功能：文件接收和文件发送。对于文件接收，分别记录了已经接收到的数据大小、文件名大小、要接收的文件等信息；对于文件发送，记录了文件大小、已经发送的数据大小、剩余数据大小、要发送的文件等信息。同时还有一些私有函数，用于初始化socket、处理接收到的数据、更新发送进度等操作。

总的来说，这个类是一个很重要的网络通信模块，可以实现与服务端的双向交互，包括文字、图片、文件等。

#ifndef CLIENTSOCKET_H
#define CLIENTSOCKET_H#include <QObject>
#include <QTcpSocket>
#include <QFile>
#include <QApplication>/// 服务端socket管理类
class ClientSocket : public QObject
{Q_OBJECT
public:explicit ClientSocket(QObject *parent = 0, QTcpSocket *tcpSocket = NULL);~ClientSocket();int GetUserId() const;void Close();
signals:void signalConnected();void signalDisConnected();void signalDownloadFile(const QJsonValue &json);void signalMsgToClient(const quint8 &type, const int &id, const QJsonValue &dataVal);
public slots:private:QTcpSocket *m_tcpSocket;int         m_nId;public slots:// 消息回发void SltSendMessage(const quint8 &type, const QJsonValue &json);private slots:void SltConnected();void SltDisconnected();void SltReadyRead();private:// 消息解析和抓转发处理void ParseLogin(const QJsonValue &dataVal);void ParseUserOnline(const QJsonValue &dataVal);void ParseLogout(const QJsonValue &dataVal);void ParseUpdateUserHead(const QJsonValue &dataVal);void ParseReister(const QJsonValue &dataVal);void ParseAddFriend(const QJsonValue &dataVal);void ParseAddGroup(const QJsonValue &dataVal);void ParseCreateGroup(const QJsonValue &dataVal);void ParseGetMyFriend(const QJsonValue &dataVal);void ParseGetMyGroups(const QJsonValue &dataVal);void ParseRefreshFriend(const QJsonValue &dataVal);void ParseRefreshGroups(const QJsonValue &dataVal);void ParseFriendMessages(const QByteArray &reply);void ParseGroupMessages(const QByteArray &reply);
};

ClientSocket::ClientSocket(QObject *parent, QTcpSocket *tcpSocket) :QObject(parent)
{qRegisterMetaType<QAbstractSocket::SocketError>("QAbstractSocket::SocketError");m_nId = -1;if (tcpSocket == NULL) m_tcpSocket = new QTcpSocket(this);m_tcpSocket = tcpSocket;connect(m_tcpSocket, SIGNAL(readyRead()), this, SLOT(SltReadyRead()));//处理客户端信息connect(m_tcpSocket, SIGNAL(connected()), this, SLOT(SltConnected()));//处理登录成功信号connect(m_tcpSocket, SIGNAL(disconnected()), this, SLOT(SltDisconnected()));//处理登出信号
}

处理客户端消息，根据消息类型进行不同的处理：

void ClientSocket::SltReadyRead()
{// 读取socket数据QByteArray reply = m_tcpSocket->readAll();QJsonParseError jsonError;// 转化为 JSON 文档QJsonDocument doucment = QJsonDocument::fromJson(reply, &jsonError);// 解析未发生错误if (!doucment.isNull() && (jsonError.error == QJsonParseError::NoError)) {// JSON 文档为对象if (doucment.isObject()) {// 转化为对象QJsonObject jsonObj = doucment.object();int nType = jsonObj.value("type").toInt();QJsonValue dataVal = jsonObj.value("data");switch (nType) {case Register:{ParseReister(dataVal);}break;case Login:{ParseLogin(dataVal);}break;case UserOnLine:{ParseUserOnline(dataVal);}break;case Logout:{ParseLogout(dataVal);Q_EMIT signalDisConnected();m_tcpSocket->abort();}break;case UpdateHeadPic:{ParseUpdateUserHead(dataVal);}break;case AddFriend:{ParseAddFriend(dataVal);}break;case AddGroup:{ParseAddGroup(dataVal);}break;case CreateGroup:{ParseCreateGroup(dataVal);}break;case GetMyFriends:{ParseGetMyFriend(dataVal);}break;case GetMyGroups:{ParseGetMyGroups(dataVal);}break;case RefreshFriends:{ParseRefreshFriend(dataVal);}break;case RefreshGroups:{ParseRefreshGroups(dataVal);}break;case SendMsg:case SendFile:case SendPicture:{ParseFriendMessages(reply);}break;case SendGroupMsg:{ParseGroupMessages(reply);}break;case SendFace:{ParseGroupMessages(reply);}break;case SendFileOk:{}break;case GetFile:{Q_EMIT signalDownloadFile(dataVal);}break;default:break;}}}
}

登录的处理：

void ClientSocket::ParseLogin(const QJsonValue &dataVal)
{// data 的 value 也是JSON对象if (dataVal.isObject()) {QJsonObject dataObj = dataVal.toObject();QString strName = dataObj.value("name").toString();QString strPwd = dataObj.value("passwd").toString();QJsonObject jsonObj = DataBaseMagr::Instance()->CheckUserLogin(strName, strPwd);m_nId = jsonObj.value("id").toInt();qDebug() << "login" << jsonObj;//验证成功才向server发送信号说明可以将socket加入容器管理if (m_nId > 0) Q_EMIT signalConnected();// 发送查询结果至客户端SltSendMessage(Login, jsonObj);;}
}

余略.....

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

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

相关文章

语音识别whisper的介绍、安装、错误记录

语音识别whisper的介绍、安装、错误记录

介绍 Whisper是OpenAI于2022年9月份开源的通用的语音识别模型。它是在各种音频的大型数据集上训练的模型&#xff0c;也是一个可以执行多语言语音识别、语音翻译和语言识别的多任务模型。 论文链接&#xff1a;https://arxiv.org/abs/2212.04356 github链接&#xff1a;https:…
阅读更多...
手部关键点检测4：Android实现手部关键点检测(手部姿势估计)含源码 可实时检测

手部关键点检测4：Android实现手部关键点检测(手部姿势估计)含源码 可实时检测

目录 1. 前言 2.手部关键点检测(手部姿势估计)方法 (1)Top-Down(自上而下)方法 (2)Bottom-Up(自下而上)方法&#xff1a; 3.手部关键点检测模型训练 4.手部关键点检测模型Android部署 &#xff08;1&#xff09; 将Pytorch模型转换ONNX模型 &#xff08;2&#xff09; …
阅读更多...
日常中msvcp71.dll丢失怎样修复？分享5个修复方法

日常中msvcp71.dll丢失怎样修复？分享5个修复方法

在 Windows 系统中&#xff0c;msvcp71.dll 是一个非常重要的动态链接库文件&#xff0c;它承载了许多应用程序和游戏的运行。如果您的系统中丢失了这个文件&#xff0c;那么您可能会遇到无法打开程序、程序崩溃或出现错误提示等问题。本文将介绍 5 个快速修复 msvcp71.dll 丢失…
阅读更多...
Linux —— 网络基础（一）

Linux —— 网络基础（一）

目录 一&#xff0c;计算机网络背景 二&#xff0c;网络协议初识 三&#xff0c;网络传输基本流程 四&#xff0c;网络中的地址管理 一&#xff0c;计算机网络背景 网络发展 独立模式&#xff0c;计算机之间相互独立&#xff1b;网络互联&#xff0c;多台计算机连接在一起…
阅读更多...
新手如何找到Docker容器（redis）中的持久化文件？

新手如何找到Docker容器（redis）中的持久化文件？

具体步骤 要查看Docker容器的dump.rdb和appendonly.aof文件&#xff08;如果启用了AOF持久化&#xff09;的位置&#xff0c;我们需要知道容器中Redis配置文件的内容或者容器的数据卷的挂载位置。 这里是一般步骤&#xff1a; 查找容器的数据卷挂载位置 使用docker inspect命令…
阅读更多...
无人机UAV目标检测与跟踪（代码+数据）

无人机UAV目标检测与跟踪（代码+数据）

前言 近年来&#xff0c;随着无人机的自主性、灵活性和广泛的应用领域&#xff0c;它们在广泛的消费通讯和网络领域迅速发展。无人机应用提供了可能的民用和公共领域应用&#xff0c;其中可以使用单个或多个无人机。与此同时&#xff0c;我们也需要意识到无人机侵入对空域安全…
阅读更多...
最新视频/图集去水印小程序源码/步数小程序源码/王者战力小程序源码/红包封面小程序源码

最新视频/图集去水印小程序源码/步数小程序源码/王者战力小程序源码/红包封面小程序源码

自带多平台解析接口 短视频去水印图集水印小程序源码 &#xff0c;这是一款支持多种平台去水印的一款微信小程序源码 支持短视频去水印&#xff0c;还有图集去水印等。内含多平台去水印接口&#xff0c;响应的速度也是非常的快&#xff0c;这是一款非常值得推荐的一款小程序源…
阅读更多...
云表|低代码开发崛起：重新定义企业级应用开发

云表|低代码开发崛起：重新定义企业级应用开发

低代码开发这个概念在近年来越来越受到人们的关注&#xff0c;市场对于低代码的需求也日益增长。据Gartner预测&#xff0c;到2025年&#xff0c;75&#xff05;的大型企业将使用至少四种低代码/无代码开发工具&#xff0c;用于IT应用开发和公民开发计划。 那么&#xff0c;为什…
阅读更多...
Shiro安全框架登录验证实例解析

Shiro安全框架登录验证实例解析

一、Shiro框架简单介绍 Apache Shiro是Java的一个安全框架&#xff0c;旨在简化身份验证和授权。Shiro在JavaSE和JavaEE项目中都可以使用。它主要用来处理身份认证&#xff0c;授权&#xff0c;企业会话管理和加密等。Shiro的具体功能点如下&#xff1a; &#xff08;1&#…
阅读更多...
java并发编程之基础与原理1

java并发编程之基础与原理1

java多线程基础 下面说一下线程的7种状态 下面我重点来说一下阻塞状态 阻塞状态是可以分很多种的&#xff1a; 下面用另外一张图来说明这种状态 简单说一下线程的启动原理 下面说一下java中的线程 java线程的异步请求方式 上面就会先把main执行出来&#xff0c;等阻塞结束之后…
阅读更多...
Keil实现Flash升级跳转(STM32/GD32/HC32)

Keil实现Flash升级跳转(STM32/GD32/HC32)

编写BOOT程序&#xff0c;和APP程序。 BOOT程序检查OTA参数&#xff0c;执行OTA升级&#xff0c;然后跳转到APP代码。 记录一下跳转APP需要修改得东西&#xff1a; 1、BOOT程序 修改跳转地址 先检查APP地址是否有效 然后关闭外设 反初始化 设置MSP指针&#xff0c;进行跳转 …
阅读更多...
工控机通过Profinet转Modbus RTU网关连接变频器与电机通讯案例

工控机通过Profinet转Modbus RTU网关连接变频器与电机通讯案例

在工业自动化系统中&#xff0c;工控机扮演着重要的角色&#xff0c;它是数据采集、处理和控制的中心。工控机通过Profinet转Modbus RTU网关连接变频器与电机通讯&#xff0c;为工业自动化系统中的设备之间的通信提供了解决方案。工控机通过Profinet转Modbus RTU网关的方式&…
阅读更多...
C语言进行实验：通过程序实现线算图取值【支持VC++ 6.0编辑器环境运行】

C语言进行实验：通过程序实现线算图取值【支持VC++ 6.0编辑器环境运行】

背景&#xff1a; 一、实验目的和要求 1、能描述数据基本类型及其常量的表示方法&#xff1b; 2、会对变量进行定义及初始化&#xff1b; 3、能使用运算符与表达式对变量赋值&#xff1b; 4、会描述C语句的概念及种类、C语言常用的输入/出方式&#xff1b; 5、会设计顺序…
阅读更多...
python+pytest接口自动化之测试函数、测试类/测试方法的封装

python+pytest接口自动化之测试函数、测试类/测试方法的封装

前言 今天呢&#xff0c;笔者想和大家聊聊pythonpytest接口自动化中将代码进行封装&#xff0c;只有将测试代码进行封装&#xff0c;才能被测试框架识别执行。 例如单个接口的请求代码如下&#xff1a; import requestsheaders {"user-agent": "Mozilla/5.0…
阅读更多...
【微信小程序】自定义组件布局会议OA其他页面（附源码）

【微信小程序】自定义组件布局会议OA其他页面（附源码）

&#x1f389;&#x1f389;欢迎来到我的CSDN主页&#xff01;&#x1f389;&#x1f389; &#x1f3c5;我是Java方文山&#xff0c;一个在CSDN分享笔记的博主。&#x1f4da;&#x1f4da; &#x1f31f;推荐给大家我的专栏《微信小程序开发实战》。&#x1f3af;&#x1f3a…
阅读更多...
JOSEF约瑟 JD3-40/23 JD3-70/23漏电继电器 AC220V\0.05-0.5A

JOSEF约瑟 JD3-40/23 JD3-70/23漏电继电器 AC220V\0.05-0.5A

JD3系列漏电继电器&#xff08;以下简称继电器&#xff09;适用于交流电压至1140V&#xff0c;频率为50Hz&#xff0c;该继电器与分励脱扣器或失压脱扣器的断路器、交流接触器、磁力启动器等组成漏电保护装置&#xff0c;作漏电和触电保护之用&#xff0c;可配备蜂鸣器、信号等…
阅读更多...
【会议征稿通知】第三届大数据经济与数字化管理国际学术会议（BDEDM 2024）

【会议征稿通知】第三届大数据经济与数字化管理国际学术会议（BDEDM 2024）

2024 3rd International Conference on Big Data Economy and Digital Management 第三届大数据经济与数字化管理国际学术会议&#xff08;BDEDM 2024&#xff09; 第三届大数据经济与数字化管理国际学术会议&#xff08;BDEDM 2024&#xff09;将于2024年1月12-14日于宁波召…
阅读更多...
性能测试-redis常见问题

性能测试-redis常见问题

缓存击穿、缓存穿透、缓存雪崩 缓存雪崩 解决办法 1.设置缓存失效时间&#xff0c;不要在同一时间 2.redis集群部署 3.不设置缓存设置时间 4.定时刷缓存的时间 缓存穿透 请求不管返回什么数据都返回给redis对参数合法器进行验证&#xff0c;不合法的时候直接过滤掉使用布…
阅读更多...
周四见｜物流人的一周资讯

周四见｜物流人的一周资讯

中国生鲜快消品电商渗透率居全球首位 10月19日消息&#xff0c;中国连锁经营协会与贝恩公司近日联合发布《2023中国生鲜快消品零售业态发展趋势研究》&#xff0c;报告指出&#xff0c;当前&#xff0c;中国生鲜快消品零售市场正处于电商渗透率引领全球&#xff0c;但集中度较…
阅读更多...
python使用dataset快速使用SQLite

python使用dataset快速使用SQLite

目录 一、官网地址 二、安装 三、 快速使用 一、官网地址 GitHub - pudo/dataset: Easy-to-use data handling for SQL data stores with support for implicit table creation, bulk loading, and transactions. 二、安装 pip install dataset 如果是mysql&#xff0c;则…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023