Qt 網絡編程進階：HTTP 客戶端實現

在 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