QNetworkAccessManager、QNetworkRequest和QNetworkReply与http通讯
admin
2024-04-18 22:16:17
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)));
}

相关内容

热门资讯

民调显示内塔尼亚胡支持率大跌 新华社北京6月22日电 一项于21日公布的民意调查显示,以总理内塔尼亚胡的支持率大幅下滑,已从3月初...
伊朗将为霍尔木兹海峡船只提供服... 5月7日消息,伊朗媒体报道说,伊朗港口与海事组织已向位于霍尔木兹海峡及邻近水域的所有船只发布正式通知...
美国检方就企业并购内幕交易起诉... 5月7日消息,美国联邦检方6日宣布,已起诉30人涉嫌参与企业并购内幕交易。他们利用华尔街律师事务所掌...
挪威央行意外上调基准利率25个... 5月7日消息,挪威央行上调基准利率25个基点至4.25%,市场预期为4.00%。(广角观察)
惠而浦美股盘前跌超16% 5月7日消息,惠而浦美股盘前跌超16%,公司一季度销售额不及预期,并宣布暂停派发股息。(科股宝播报)
巴基斯坦外交部:期待美伊尽快达... 5月7日消息,巴基斯坦外交部发言人塔希尔·安德拉比7日说,期待美伊尽快达成协议。安德拉比当天在例行记...
日元涨势在155关口遇到强劲阻... 5月7日消息,在日本多次疑似干预后,日元兑美元汇率仍未能突破155关口,这引发了市场对日元近期涨势能...
信托业协会:抵制“内卷式”竞争 5月7日消息,中国信托业协会日前制定了《中国信托业协会关于优化信托服务,促进信托业健康可持续发展的倡...
上期所:将于5月11日至5月2... 5月7日消息,上海期货交易所发布通知,将于2026年5月11日(周一)至2026年5月22日(周五)...
千问PC端上线AI语音输入功能 5月7日消息,从阿里方面获悉,今日千问在PC端上线AI语音输入功能,用户通过快捷键可在各类桌面应用中...