在 Qt 应用程序中，实现高性能、可靠的 HTTP 客户端是常见需求。Qt 提供了丰富的网络模块，包括 QNetworkAccessManager、QNetworkRequest 和 QNetworkReply 等类，用于简化 HTTP 通信。本文将深入探讨 Qt 网络编程中 HTTP 客户端的进阶实现，包括异步请求、并发控制、请求重试、数据缓存等高级技术。

一、基础 HTTP 请求实现

1. 同步 HTTP 请求
#include <QCoreApplication>
#include <QNetworkAccessManager>
#include <QNetworkRequest>
#include <QNetworkReply>
#include <QEventLoop>
#include <QJsonDocument>
#include <QJsonObject>
#include <QDebug>QByteArray syncHttpGet(const QUrl &url) {QNetworkAccessManager manager;QNetworkRequest request(url);// 设置请求头request.setHeader(QNetworkRequest::UserAgentHeader, "Qt HTTP Client");// 发送请求QNetworkReply *reply = manager.get(request);// 使用事件循环等待请求完成QEventLoop loop;QObject::connect(reply, &QNetworkReply::finished, &loop, &QEventLoop::quit);loop.exec();// 处理响应QByteArray data;if (reply->error() == QNetworkReply::NoError) {data = reply->readAll();} else {qDebug() << "Request failed:" << reply->errorString();}// 清理资源reply->deleteLater();return data;
}int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);QUrl url("https://api.example.com/data");QByteArray response = syncHttpGet(url);if (!response.isEmpty()) {// 解析 JSON 响应QJsonDocument doc = QJsonDocument::fromJson(response);if (doc.isObject()) {QJsonObject obj = doc.object();qDebug() << "Response:" << obj;}}return a.exec();
}
2. 异步 HTTP 请求
#include <QObject>
#include <QNetworkAccessManager>
#include <QNetworkRequest>
#include <QNetworkReply>
#include <QJsonDocument>
#include <QJsonObject>
#include <QDebug>class HttpClient : public QObject {Q_OBJECT
public:explicit HttpClient(QObject *parent = nullptr) : QObject(parent) {manager = new QNetworkAccessManager(this);}void get(const QUrl &url) {QNetworkRequest request(url);request.setHeader(QNetworkRequest::UserAgentHeader, "Qt HTTP Client");QNetworkReply *reply = manager->get(request);connect(reply, &QNetworkReply::finished, this, [this, reply]() {handleResponse(reply);reply->deleteLater();});}signals:void requestCompleted(const QJsonObject &data);void requestFailed(const QString &error);private slots:void handleResponse(QNetworkReply *reply) {if (reply->error() == QNetworkReply::NoError) {QByteArray data = reply->readAll();QJsonDocument doc = QJsonDocument::fromJson(data);if (doc.isObject()) {emit requestCompleted(doc.object());} else {emit requestFailed("Invalid JSON response");}} else {emit requestFailed(reply->errorString());}}private:QNetworkAccessManager *manager;
};

二、高级 HTTP 客户端功能

1. 请求重试机制
class RetryHttpClient : public QObject {Q_OBJECT
public:explicit RetryHttpClient(int maxRetries = 3, QObject *parent = nullptr): QObject(parent), maxRetries(maxRetries) {manager = new QNetworkAccessManager(this);}void get(const QUrl &url) {currentUrl = url;currentRetry = 0;sendRequest();}private slots:void handleResponse(QNetworkReply *reply) {QNetworkReply::NetworkError error = reply->error();QByteArray data = reply->readAll();reply->deleteLater();if (error == QNetworkReply::NoError) {emit requestCompleted(data);} else if (currentRetry < maxRetries) {// 可重试的错误（如网络超时、临时服务器错误）qDebug() << "Request failed, retrying" << currentRetry + 1 << "/" << maxRetries;currentRetry++;sendRequest();} else {emit requestFailed("Max retries exceeded: " + reply->errorString());}}private:void sendRequest() {QNetworkRequest request(currentUrl);request.setHeader(QNetworkRequest::UserAgentHeader, "Qt HTTP Client (Retry)");// 设置超时（需要结合定时器实现）QNetworkReply *reply = manager->get(request);connect(reply, &QNetworkReply::finished, this, [this, reply]() {handleResponse(reply);});}signals:void requestCompleted(const QByteArray &data);void requestFailed(const QString &error);private:QNetworkAccessManager *manager;QUrl currentUrl;int currentRetry;int maxRetries;
};
2. 请求并发控制
class ConcurrentHttpClient : public QObject {Q_OBJECT
public:explicit ConcurrentHttpClient(int maxConcurrent = 5, QObject *parent = nullptr): QObject(parent), maxConcurrent(maxConcurrent), activeRequests(0) {manager = new QNetworkAccessManager(this);}void enqueueRequest(const QUrl &url) {requestQueue.enqueue(url);processQueue();}private slots:void handleResponse(QNetworkReply *reply) {activeRequests--;if (reply->error() == QNetworkReply::NoError) {QByteArray data = reply->readAll();emit requestCompleted(reply->request().url(), data);} else {emit requestFailed(reply->request().url(), reply->errorString());}reply->deleteLater();processQueue();}private:void processQueue() {while (activeRequests < maxConcurrent && !requestQueue.isEmpty()) {QUrl url = requestQueue.dequeue();QNetworkRequest request(url);QNetworkReply *reply = manager->get(request);activeRequests++;connect(reply, &QNetworkReply::finished, this, [this, reply]() {handleResponse(reply);});}}signals:void requestCompleted(const QUrl &url, const QByteArray &data);void requestFailed(const QUrl &url, const QString &error);private:QNetworkAccessManager *manager;QQueue<QUrl> requestQueue;int maxConcurrent;int activeRequests;
};
3. 请求缓存机制
class CachedHttpClient : public QObject {Q_OBJECT
public:explicit CachedHttpClient(QObject *parent = nullptr) : QObject(parent) {manager = new QNetworkAccessManager(this);cacheTimeout = 3600;  // 默认缓存1小时}void get(const QUrl &url, bool forceRefresh = false) {QString cacheKey = url.toString();// 检查缓存if (!forceRefresh && cache.contains(cacheKey)) {CacheEntry entry = cache.value(cacheKey);if (entry.timestamp.secsTo(QDateTime::currentDateTime()) < cacheTimeout) {emit requestCompleted(url, entry.data);return;}}// 发送网络请求QNetworkRequest request(url);QNetworkReply *reply = manager->get(request);connect(reply, &QNetworkReply::finished, this, [this, reply, url, cacheKey]() {if (reply->error() == QNetworkReply::NoError) {QByteArray data = reply->readAll();// 保存到缓存CacheEntry entry;entry.data = data;entry.timestamp = QDateTime::currentDateTime();cache.insert(cacheKey, entry);emit requestCompleted(url, data);} else {emit requestFailed(url, reply->errorString());}reply->deleteLater();});}void setCacheTimeout(int seconds) {cacheTimeout = seconds;}private:struct CacheEntry {QByteArray data;QDateTime timestamp;};QNetworkAccessManager *manager;QHash<QString, CacheEntry> cache;int cacheTimeout;signals:void requestCompleted(const QUrl &url, const QByteArray &data);void requestFailed(const QUrl &url, const QString &error);
};

三、处理不同类型的 HTTP 请求

1. POST 请求
void post(const QUrl &url, const QJsonObject &jsonData) {QNetworkRequest request(url);request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");QJsonDocument doc(jsonData);QByteArray data = doc.toJson();QNetworkReply *reply = manager->post(request, data);connect(reply, &QNetworkReply::finished, this, [this, reply]() {// 处理响应...reply->deleteLater();});
}
2. 上传文件
void uploadFile(const QUrl &url, const QString &filePath) {QFile file(filePath);if (!file.open(QIODevice::ReadOnly)) {emit uploadFailed("Cannot open file: " + filePath);return;}QNetworkRequest request(url);request.setHeader(QNetworkRequest::ContentTypeHeader, "application/octet-stream");QNetworkReply *reply = manager->post(request, &file);connect(reply, &QNetworkReply::uploadProgress, this, [this](qint64 bytesSent, qint64 bytesTotal) {emit uploadProgress(bytesSent, bytesTotal);});connect(reply, &QNetworkReply::finished, this, [this, reply, &file]() {file.close();// 处理响应...reply->deleteLater();});
}
3. 下载文件
void downloadFile(const QUrl &url, const QString &savePath) {QNetworkRequest request(url);QNetworkReply *reply = manager->get(request);QFile file(savePath);if (!file.open(QIODevice::WriteOnly)) {emit downloadFailed("Cannot open file for writing: " + savePath);reply->abort();reply->deleteLater();return;}connect(reply, &QNetworkReply::downloadProgress, this, [this](qint64 bytesReceived, qint64 bytesTotal) {emit downloadProgress(bytesReceived, bytesTotal);});connect(reply, &QNetworkReply::readyRead, this, [reply, &file]() {file.write(reply->readAll());});connect(reply, &QNetworkReply::finished, this, [this, reply, &file, savePath]() {file.close();if (reply->error() == QNetworkReply::NoError) {emit downloadCompleted(savePath);} else {// 删除不完整的文件QFile::remove(savePath);emit downloadFailed(reply->errorString());}reply->deleteLater();});
}

四、HTTP2 支持与性能优化

1. 启用 HTTP2
void enableHttp2() {// Qt 5.15+ 支持 HTTP2// 设置 ALPN 协议优先级QSslConfiguration config = QSslConfiguration::defaultConfiguration();config.setProtocol(QSsl::TlsV1_3);config.setAlpnProtocols({"h2", "http/1.1"});manager->setSslConfiguration(config);
}
2. 连接池优化
void optimizeConnectionPool() {// 设置连接超时manager->setTransferTimeout(30000);  // 30秒// 设置最大连接数QNetworkAccessManager::setMaximumConnectionCountPerHost(10);
}

五、安全与认证

1. 基本认证
void setBasicAuth(const QString &username, const QString &password) {QString credentials = username + ":" + password;QByteArray encoded = credentials.toUtf8().toBase64();authHeader = "Basic " + encoded;
}// 在请求中添加认证头
QNetworkRequest request(url);
request.setRawHeader("Authorization", authHeader);
2. OAuth2 认证
void setOAuthToken(const QString &token) {authHeader = "Bearer " + token.toUtf8();
}// 在请求中添加认证头
QNetworkRequest request(url);
request.setRawHeader("Authorization", authHeader);
3. SSL/TLS 配置
void configureSsl() {QSslConfiguration config = QSslConfiguration::defaultConfiguration();// 验证服务器证书config.setPeerVerifyMode(QSslSocket::VerifyPeer);// 加载 CA 证书QSslCertificate caCert(QSslCertificate::fromPath("/path/to/cacert.pem"));if (!caCert.isEmpty()) {config.addCaCertificate(caCert);}manager->setSslConfiguration(config);
}

六、完整 HTTP 客户端示例

下面是一个整合了上述功能的完整 HTTP 客户端类：

#include <QObject>
#include <QNetworkAccessManager>
#include <QNetworkRequest>
#include <QNetworkReply>
#include <QTimer>
#include <QUrl>
#include <QByteArray>
#include <QJsonObject>
#include <QJsonDocument>
#include <QHash>
#include <QQueue>
#include <QDateTime>
#include <QSslConfiguration>class AdvancedHttpClient : public QObject {Q_OBJECT
public:explicit AdvancedHttpClient(QObject *parent = nullptr);~AdvancedHttpClient() override;// 请求方法void get(const QUrl &url, bool forceRefresh = false);void post(const QUrl &url, const QJsonObject &data);void put(const QUrl &url, const QJsonObject &data);void del(const QUrl &url);// 上传下载void uploadFile(const QUrl &url, const QString &filePath);void downloadFile(const QUrl &url, const QString &savePath);// 配置void setMaxConcurrentRequests(int count);void setRetryCount(int count);void setCacheTimeout(int seconds);void setBasicAuth(const QString &username, const QString &password);void setOAuthToken(const QString &token);void enableHttp2();void configureSsl(const QString &caCertPath = QString());signals:void requestCompleted(const QUrl &url, const QByteArray &data);void requestFailed(const QUrl &url, const QString &error);void uploadProgress(const QUrl &url, qint64 bytesSent, qint64 bytesTotal);void downloadProgress(const QUrl &url, qint64 bytesReceived, qint64 bytesTotal);void uploadCompleted(const QUrl &url, const QByteArray &data);void downloadCompleted(const QUrl &url, const QString &savePath);void uploadFailed(const QUrl &url, const QString &error);void downloadFailed(const QUrl &url, const QString &error);private slots:void onRequestFinished();void onUploadProgress(qint64 bytesSent, qint64 bytesTotal);void onDownloadProgress(qint64 bytesReceived, qint64 bytesTotal);void processQueue();private:struct Request {QUrl url;QByteArray data;QNetworkAccessManager::Operation operation;int retries = 0;bool isDownload = false;QString filePath;};struct CacheEntry {QByteArray data;QDateTime timestamp;};QNetworkAccessManager *manager;QQueue<Request> requestQueue;QHash<QUrl, QNetworkReply*> activeRequests;QHash<QString, CacheEntry> cache;int maxConcurrent = 5;int maxRetries = 3;int cacheTimeout = 3600;QByteArray authHeader;
};

七、总结

Qt 的网络模块提供了强大而灵活的 HTTP 客户端功能，能够满足从简单请求到复杂网络应用的各种需求。通过合理使用异步请求、并发控制、请求重试和数据缓存等技术，可以构建高性能、可靠的 HTTP 客户端。在实际开发中，还应根据具体需求考虑安全认证、HTTPS 支持和性能优化等方面，确保应用程序在各种网络环境下都能稳定运行。

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

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

相关文章

Python Requests-HTML库详解：从入门到实战

Python Requests-HTML库详解：从入门到实战

一、库简介 Requests-HTML是Python中集网络请求与HTML解析于一体的全能型库&#xff0c;由知名开发者Kenneth Reitz团队维护。它完美结合了Requests的易用性和Parsel的选择器功能&#xff0c;并内置JavaScript渲染引擎&#xff0c;特别适合现代动态网页抓取。最新版本&#xf…
阅读更多...
基于springboot的小区车位租售管理系统

基于springboot的小区车位租售管理系统

博主介绍&#xff1a;java高级开发&#xff0c;从事互联网行业六年&#xff0c;熟悉各种主流语言&#xff0c;精通java、python、php、爬虫、web开发&#xff0c;已经做了六年的毕业设计程序开发&#xff0c;开发过上千套毕业设计程序&#xff0c;没有什么华丽的语言&#xff0…
阅读更多...
Kafka 如何优雅实现 Varint 和 ZigZag 编码

Kafka 如何优雅实现 Varint 和 ZigZag 编码

ByteUtils 是 Kafka 中一个非常基础且核心的工具类。从包名 common.utils 就可以看出&#xff0c;它被广泛用于 Kafka 的各个模块中。它的主要职责是提供一套高效、底层的静态方法&#xff0c;用于在字节缓冲区 (ByteBuffer)、字节数组 (byte[]) 以及输入/输出流 (InputStream/…
阅读更多...
局域网 IP地址

局域网 IP地址

很多童鞋搞不清楚局域网ip是什么？ 什么是局域网 IP 地址？ 局域网 IP 地址，也称为 私有 IP 地址（Private IP Address），是用于在局域网内部标识设备的地址。这些地址不能直接在互联网上被访问，通常由路由器自动分配，用于设备之间的内部通信。 局域网 IP 地址的分类 根…
阅读更多...
k8s的service、deployment、探针详解

k8s的service、deployment、探针详解

1.k8s组成图2.service和deployment的流量转发图# Deployment 定义容器端口 apiVersion: apps/v1 kind: Deployment metadata:name: myapp spec:template:spec:containers:- name: nginximage: nginxports:- containerPort: 80 # 容器监听 80name: http # 端口命名&…
阅读更多...
【PostgreSQL教程】PostgreSQL中json类型与jsonb类型的区别

【PostgreSQL教程】PostgreSQL中json类型与jsonb类型的区别

博主介绍：✌全网粉丝23W+，CSDN博客专家、Java领域优质创作者，掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域✌ 技术范围：SpringBoot、SpringCloud、Vue、SSM、HTML、Nodejs、Python、MySQL、PostgreSQL、大数据、物联网、机器学习等设计与开发。 感兴趣的可…
阅读更多...
牛客刷题记录01

牛客刷题记录01

除2&#xff01; 目录 除2&#xff01; 题目描述&#xff1a; ​编辑 题目解析&#xff1a; 代码实现&#xff1a; 数组中两个字符串的最小距离__牛客网 题目描述&#xff1a; 题目解析&#xff1a; 代码实现&#xff1a; 除2&#xff01; 题目描述&#xff1a; 给一个…
阅读更多...
Docker Compose UI远程访问教程：结合贝锐花生壳实现内网穿透

Docker Compose UI远程访问教程：结合贝锐花生壳实现内网穿透

对于很多刚接触Docker的用户来说&#xff0c;命令行操作总带着一丝“劝退感”。尤其是要在Windows上部署服务、开放端口、配置参数时&#xff0c;稍有不慎就容易出错。有没有办法像网页后台一样&#xff0c;用图形界面来管理Docker项目呢&#xff1f;答案是&#xff1a;有&…
阅读更多...
HF83311_VB1/HF83311Q_VB1：高性能USB HiFi音频解码器固件技术解析

HF83311_VB1/HF83311Q_VB1：高性能USB HiFi音频解码器固件技术解析

引言随着高品质音频体验需求的不断增长&#xff0c;音频解码器固件的性能和功能成为决定音频设备品质的关键因素。本文将介绍一款基于XMOS XU316技术的高性能USB HiFi音频解码器固件——HF83311_VB1/HF83311Q_VB1&#xff0c;这是一款专为USB HiFi音频应用设计的软件解决方案。…
阅读更多...
[ComfyUI] -入门1-ComfyUI 是什么？比 Stable Diffusion WebUI 强在哪？

[ComfyUI] -入门1-ComfyUI 是什么？比 Stable Diffusion WebUI 强在哪？

ComfyUI 是一个开源的、节点可视化界面，用于构建与执行 Stable Diffusion 图像生成流程。它把复杂的生成过程拆解为许多“节点”（如提示编码、采样器、控制网络等），用户通过连接节点，就能自由编排工作流 。这种设计适合开发者与进阶用户，更便于微调、多分支与复用流程。 …
阅读更多...
[python][flask]flask接受get或者post参数

[python][flask]flask接受get或者post参数

在 Flask 中&#xff0c;可以通过 request 对象来获取客户端通过 GET 或 POST 方法发送的参数。以下是如何在 Flask 中接收 GET 和 POST 参数的详细说明&#xff1a;1. 接收 GET 参数GET 请求的参数通常通过 URL 的查询字符串传递。例如&#xff0c;对于 URL http://example.co…
阅读更多...
Creo 模块众多，企业如何按需灵活分配许可证资源？

Creo 模块众多，企业如何按需灵活分配许可证资源？

在数字化设计与智能制造深入发展的当下&#xff0c;企业 CAD/CAE 工具的精细化管理越来越重要。Creo&#xff0c;作为 PTC 旗下一体化 3D CAD 平台&#xff0c;以其模块化、可扩展的产品架构&#xff0c;广泛应用于机械、装备、汽车、航空航天等行业。其丰富的模块库覆盖建模设…
阅读更多...
【c++】提升用户体验：问答系统的交互优化实践——关于我用AI编写了一个聊天机器人……（12）

【c++】提升用户体验：问答系统的交互优化实践——关于我用AI编写了一个聊天机器人……（12）

本期依旧使用豆包辅助完成代码。从功能到体验的转变上个版本已经实现了问答系统的核心功能&#xff1a;基于 TF-IDF 算法的问题匹配和回答。它能够读取训练数据&#xff0c;处理用户输入&#xff0c;并返回最相关的答案。但在用户体验方面还有很大提升空间。让我们看看改进版做…
阅读更多...
Android UI 控件详解实践

Android UI 控件详解实践

一、UI 开发基础概念&#xff08;初学者必看&#xff09; 在学习具体控件前&#xff0c;先理解以下核心概念&#xff0c;能大幅降低后续学习难度&#xff1a; 1. View 与 ViewGroup 的关系 View&#xff1a;所有 UI 控件的基类&#xff08;如 Button、TextView&#xff09;&…
阅读更多...
关于linux运维 出现高频的模块认知

关于linux运维 出现高频的模块认知

一、Linux 基础核心&#xff08;必掌握&#xff09;核心工具&#xff1a;Shell 脚本、Systemd、用户权限管理、日志分析&#xff08;journalctl、rsyslog&#xff09;企业需求&#xff1a;中小型公司&#xff1a;需独立完成系统部署、故障排查&#xff0c;对脚本开发&#xff0…
阅读更多...
手语式映射：Kinova Gen3 力控机械臂自适应控制的研究与应用

手语式映射：Kinova Gen3 力控机械臂自适应控制的研究与应用

近日&#xff0c;美国明尼苏达大学研究团队在《从人手到机械臂&#xff1a;遥操作中运动技能具身化研究》中&#xff0c;成功开发出基于​​Kinova的7轴力控机械臂Gen3的智能控制系统。这项创新性技术通过人工智能算法&#xff0c;实现了人类手臂动作到机械臂运动的精准映射&am…
阅读更多...
P5535 【XR-3】小道消息

P5535 【XR-3】小道消息

题目描述 小 X 想探究小道消息传播的速度有多快&#xff0c;于是他做了一个社会实验。 有 n 个人&#xff0c;其中第 i 个人的衣服上有一个数 i1。小 X 发现了一个规律&#xff1a;当一个衣服上的数为 i 的人在某一天知道了一条信息&#xff0c;他会在第二天把这条信息告诉衣…
阅读更多...
ChatGPT Agent架构深度解析：OpenAI如何构建统一智能体系统

ChatGPT Agent架构深度解析：OpenAI如何构建统一智能体系统

引言&#xff1a;AI智能体的范式跃迁 2025年7月17日&#xff0c;OpenAI发布的ChatGPT Agent标志着对话式AI从“被动应答”向主动执行的历史性转变。这款融合Operator网页操作与Deep Research信息分析能力的新型智能体&#xff0c;通过统一架构设计实现了复杂任务的端到端自主执…
阅读更多...
计算机网络（第八版）— 第2章课后习题参考答案

计算机网络（第八版）— 第2章课后习题参考答案

2-01 物理层要解决哪些问题&#xff1f;物理层的主要特点是什么&#xff1f;答&#xff1a;物理层要解决的主要问题&#xff1a;&#xff08;1&#xff09;物理层要尽可能地屏蔽掉物理设备和传输媒体&#xff0c;通信手段的不同&#xff0c;使数据链路层感觉不到这些差异&#…
阅读更多...
Hive【Hive架构及工作原理】

Hive【Hive架构及工作原理】

✨博客主页&#xff1a; https://blog.csdn.net/m0_63815035?typeblog &#x1f497;《博客内容》&#xff1a;.NET、Java.测试开发、Python、Android、Go、Node、Android前端小程序等相关领域知识 &#x1f4e2;博客专栏&#xff1a; https://blog.csdn.net/m0_63815035/cat…
阅读更多...
最新文章

Copyright @ 2022~2023