QNetworkAccessManager、QNetworkRequest和QNetworkReply与http通讯
admin
2024-03-24 02:44:05
0

QNetworkAccessManager、QNetworkRequest和QNetworkReply三者关系:
QNetworkAccessManager是主体,它负责发送和接收,也就是get和post,并且他还能判断网络连接状态,通过networkSessionConnected信号判断。
QNetworkRequest是请求,它是要访问的内容,并且它也能对这些内容进行配置,它放在QNetworkAccessManager的get和post中使用。
QNetworkReply它是回复,即返回结果,它能获取到get,post后得到的结果,包括正常的和异常的。
拓展:QSslConfiguration它是QNetworkRequest的一个访问设置类,如下设置协议类型支持https:

  QNetworkRequest req(url);QSslConfiguration config;config.setPeerVerifyMode(QSslSocket::VerifyNone);config.setProtocol(QSsl::AnyProtocol);req.setSslConfiguration(config);

QNetworkRequest可以通过设置head来设置发送类型的格式,如下:
字符串模式:

  req.setHeader(QNetworkRequest::ContentTypeHeader,QVariant("application/x-www-form-urlencoded"));

json模式:

  req.setHeader(QNetworkRequest::ContentTypeHeader,QVariant("application/json"));

这里简单介绍下QNetworkAccessManager的get和post,它们都是访问服务器,但是get一般是不带参数的,post一般会有参数的。当然get也可以带参数,例如QNetworkRequest设置的url里面带有参数,例如这种格式:http://testurl?id=666&name=“xiaoming”;

QNetworkReply作为获取返回值和获取连接状态来使用,它可以同步获取,也可以异步获取。
同步获取:使用QEventloop来做一个非阻塞延时。
异步获取:通过关联信号readyRead来获取。
同步访问后台使用实例:
.h

#ifndef HTTPCLIENT_H
#define HTTPCLIENT_H#include 
#include class HttpClient : public QObject {Q_OBJECT
public:HttpClient(QObject *parent = 0);QByteArray get(const QString &url, int timeout);QByteArray post(const QString &url, const QByteArray &data, int timeout);QByteArray posttojson(const QString &url, const QByteArray &data, int timeout);
private slots:void replyFinished(QNetworkReply *reply);protected:QByteArray request(QNetworkReply *reply, int timeout);private:QNetworkAccessManager *m_manager;QString m_recvData;
};#endif // HTTPCLIENT_H

cpp:

#include "httpclient.h"
#include 
#include 
#include 
#include 
#include 
#include 
#define HTTP_HEADER_KEY       "X-Version"
#define HTTP_HEADER_VALUE       "1.0"HttpClient::HttpClient(QObject *parent) : QObject(parent) {m_recvData = "";m_manager = new QNetworkAccessManager(this);connect(m_manager, SIGNAL(finished(QNetworkReply *)), this,SLOT(replyFinished(QNetworkReply *)));
}QByteArray HttpClient::get(const QString &url, int timeout) {QNetworkRequest req(url);//下边的四行代码是做验证处理的,方式不止这一种QSslConfiguration config;config.setPeerVerifyMode(QSslSocket::VerifyNone);config.setProtocol(QSsl::AnyProtocol);req.setSslConfiguration(config);req.setRawHeader(HTTP_HEADER_KEY,HTTP_HEADER_VALUE);req.setHeader(QNetworkRequest::ContentTypeHeader,QVariant("application/x-www-form-urlencoded"));return request(m_manager->get(req), timeout);
}QByteArray HttpClient::post(const QString &url, const QByteArray &data,int timeout) {QNetworkRequest req(url);//下边的四行代码是做验证处理的,方式不止这一种QSslConfiguration config;config.setPeerVerifyMode(QSslSocket::VerifyNone);config.setProtocol(QSsl::AnyProtocol);req.setSslConfiguration(config);req.setRawHeader(HTTP_HEADER_KEY,HTTP_HEADER_VALUE);req.setHeader(QNetworkRequest::ContentTypeHeader,QVariant("application/x-www-form-urlencoded"));return request(m_manager->post(req, data), timeout);
}QByteArray HttpClient::posttojson(const QString &url, const QByteArray &data,int timeout) {QNetworkRequest req(url);//下边的四行代码是做验证处理的,方式不止这一种QSslConfiguration config;config.setPeerVerifyMode(QSslSocket::VerifyNone);config.setProtocol(QSsl::AnyProtocol);req.setSslConfiguration(config);req.setRawHeader(HTTP_HEADER_KEY,HTTP_HEADER_VALUE);req.setHeader(QNetworkRequest::ContentTypeHeader,QVariant("application/json"));return request(m_manager->post(req, data), timeout);
}void HttpClient::replyFinished(QNetworkReply *reply) {QVariant status_code =reply->attribute(QNetworkRequest::HttpStatusCodeAttribute);QByteArray bytes = reply->readAll();QTextCodec *pCodec = QTextCodec::codecForName("UTF-8");m_recvData = pCodec->toUnicode(bytes);if (reply->error() != QNetworkReply::NoError) {qWarning() << "http通信返回错误" <url()<deleteLater(); //要删除reply,要调用deletelater;
}QByteArray HttpClient::request(QNetworkReply *reply, int timeout) {QEventLoop loop;QTimer timer;connect(&timer, SIGNAL(timeout()), &loop, SLOT(quit()));connect(reply, SIGNAL(finished()), &loop, SLOT(quit()));timer.start(timeout);loop.exec();return m_recvData.toUtf8();
}

从服务器下载文件实例:
.h

#ifndef HTTPDOWNLOADBUSSSINESS_H
#define HTTPDOWNLOADBUSSSINESS_H#include #include 
#include 
#include class Reply;class HttpDownloadBussiness : public QObject {Q_OBJECT
public:HttpDownloadBussiness (QString url,QString fileName,QObject *parent = 0);//  bool getRunningStatus() const;
public slots:bool download();//  bool stopDownload(QString url);public slots:void handleFinished();void handleReadyRead();void updateDownloadProgress(qint64, qint64);void handleError(QNetworkReply::NetworkError error);private:bool raiseFailed();void raiseCompleted();//  void raiseStop();
signals:void progressChangedSig(quint64 p, quint64 t);void downloadCompletedSig();void downloadFailedSig();//  void downloadStopSig();private:QNetworkAccessManager *m_manager;QNetworkReply *m_netReply;Reply *m_reply;quint64 m_total;bool m_isRunning;QFile *m_file;QUrl m_url;QString m_fileTemp;qint64 m_existSize;//  bool m_isStop;
};class Reply : public QObject {Q_OBJECTpublic:Reply(QNetworkReply *reply);enum { Head, Get };int method() const { return m_method; }void setMethod(int method) { m_method = method; }void abort() { m_reply->abort(); }QVariant header(QNetworkRequest::KnownHeaders header) const {return m_reply->header(header);}QNetworkReply *reply() const { return m_reply; }quint64 current;
signals:void finished();void errorOccurred(QNetworkReply::NetworkError);void readyRead();void updateDownloadProgress(qint64, qint64);private:QNetworkReply *m_reply;int m_method;
};#endif // HTTPDOWNLOADBUSSSINESS_H

.cpp

#include "httpdownloadbussiness.h"
#include 
#include 
#include 
#include 
#include HttpDownloadBussiness ::HttpDownloadBussiness(QString url,QString fileName,QObject *parent) : QObject(parent) {m_isRunning = false;m_url = QUrl(url);m_fileTemp = fileName + "_tmp";//    m_isStop = false;}bool HttpDownloadBussiness ::download() {m_manager = new QNetworkAccessManager;m_isRunning = true;m_existSize = 0;m_file = new QFile(m_fileTemp, this);if (!m_file->open(QFile::WriteOnly | QIODevice::Append)) {raiseFailed();return false;}QNetworkRequest req(m_url);//下边的四行代码是做验证处理的,方式不止这一种QSslConfiguration config;config.setPeerVerifyMode(QSslSocket::VerifyNone);config.setProtocol(QSsl::AnyProtocol);req.setSslConfiguration(config);QNetworkAccessManager *accessManager = new QNetworkAccessManager(this);qDebug() << "当前支持协议:"<supportedSchemes();//    req.setRawHeader("Range", pos.toLatin1());//  if (m_manager->networkAccessible() == QNetworkAccessManager::NotAccessible) {//    m_manager->setNetworkAccessible(QNetworkAccessManager::Accessible);//  }m_reply = new Reply(m_manager->get(req));m_reply->current = 0;qWarning() << QString::fromUtf8("%1文件开始下载...").arg(m_fileTemp)<reply()->abort();if (m_reply)m_reply->reply()->deleteLater();m_isStop = true;}}emit downloadStopSig();return true;}return false;
}bool HttpDownloadBussiness ::getRunningStatus() const { return m_isRunning; }
#endifvoid HttpDownloadBussiness ::handleFinished() {if (m_isRunning){//        m_isStop = true;m_file->close();int index = m_fileTemp.lastIndexOf("_tmp");QString realName = m_fileTemp.left(index);bool ok = QFile::rename(m_fileTemp, realName);qWarning() <<__FUNCTION__ << __LINE__<(sender());QByteArray content = reply->reply()->readAll();m_file->seek(reply->current);m_file->write(content);reply->current += content.length();
}void HttpDownloadBussiness ::updateDownloadProgress(qint64 part, qint64 total) {
//    qDebug()<close();//暂时屏蔽该代码,使用恢复下载超时处理,if (!QFile::remove(m_file->fileName())) {qDebug() << "remove failed";}}emit downloadFailedSig();
}bool HttpDownloadBussiness ::raiseFailed() {m_isRunning = false;m_file->close();if (!QFile::remove(m_file->fileName())) {qDebug() << "create remove failed";}emit downloadFailedSig();return false;
}void HttpDownloadBussiness ::raiseCompleted() {m_isRunning = false;connect(m_manager, SIGNAL(finished(QNetworkReply *)), m_manager,SLOT(deleteLater()));emit downloadCompletedSig();
}#if 0
void HttpDownloadBussiness ::raiseStop() { emit downloadStopSig(); }
#endifReply::Reply(QNetworkReply *reply) {m_reply = reply;qRegisterMetaType("QNetworkReply::NetworkError");connect(m_reply, SIGNAL(finished()), this, SIGNAL(finished()));connect(m_reply, SIGNAL(errorOccurred(QNetworkReply::NetworkError)), this,SIGNAL(errorOccurred(QNetworkReply::NetworkError)));connect(m_reply, SIGNAL(readyRead()), this, SIGNAL(readyRead()));connect(m_reply, SIGNAL(downloadProgress(qint64, qint64)), this,SIGNAL(updateDownloadProgress(qint64, qint64)));
}

相关内容

热门资讯

【MySQL】锁 锁 文章目录锁全局锁表级锁表锁元数据锁(MDL)意向锁AUTO-INC锁...
【内网安全】 隧道搭建穿透上线... 文章目录内网穿透-Ngrok-入门-上线1、服务端配置:2、客户端连接服务端ÿ...
GCN的几种模型复现笔记 引言 本篇笔记紧接上文,主要是上一篇看写了快2w字,再去接入代码感觉有点...
数据分页展示逻辑 import java.util.Arrays;import java.util.List;impo...
Redis为什么选择单线程?R... 目录专栏导读一、Redis版本迭代二、Redis4.0之前为什么一直采用单线程?三、R...
【已解决】ERROR: Cou... 正确指令: pip install pyyaml
关于测试,我发现了哪些新大陆 关于测试 平常也只是听说过一些关于测试的术语,但并没有使用过测试工具。偶然看到编程老师...
Lock 接口解读 前置知识点Synchronized synchronized 是 Java 中的关键字,...
Win7 专业版安装中文包、汉... 参考资料:http://www.metsky.com/archives/350.htm...
3 ROS1通讯编程提高(1) 3 ROS1通讯编程提高3.1 使用VS Code编译ROS13.1.1 VS Code的安装和配置...
大模型未来趋势 大模型是人工智能领域的重要发展趋势之一,未来有着广阔的应用前景和发展空间。以下是大模型未来的趋势和展...
python实战应用讲解-【n... 目录 如何在Python中计算残余的平方和 方法1:使用其Base公式 方法2:使用statsmod...
学习u-boot 需要了解的m... 一、常用函数 1. origin 函数 origin 函数的返回值就是变量来源。使用格式如下...
常用python爬虫库介绍与简... 通用 urllib -网络库(stdlib)。 requests -网络库。 grab – 网络库&...
药品批准文号查询|药融云-中国... 药品批文是国家食品药品监督管理局(NMPA)对药品的审评和批准的证明文件...
【2023-03-22】SRS... 【2023-03-22】SRS推流搭配FFmpeg实现目标检测 说明: 外侧测试使用SRS播放器测...
有限元三角形单元的等效节点力 文章目录前言一、重新复习一下有限元三角形单元的理论1、三角形单元的形函数(Nÿ...
初级算法-哈希表 主要记录算法和数据结构学习笔记,新的一年更上一层楼! 初级算法-哈希表...
进程间通信【Linux】 1. 进程间通信 1.1 什么是进程间通信 在 Linux 系统中,进程间通信...
【Docker】P3 Dock... Docker数据卷、宿主机与挂载数据卷的概念及作用挂载宿主机配置数据卷挂载操作示例一个容器挂载多个目...