这篇文章主要介绍了Qt怎么用QNetwork实现上传数据的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇Qt怎么用QNetwork实现上传数据文章都会有所收获,下面我们一起来看看吧。
1、利用Qt提供的类实现向服务器发送post和get请求
#include <QCoreApplication>#include <QNetworkAccessManager>#include <QNetworkRequest>#include <QNetworkReply>#include <QJsonArray>#include <QJsonDocument>#include <QJsonObject>#include <QJsonParseError>#include <QJsonValue>#include <QString>#include <QDebug>#include <QFile>#include <QDateTime>#include <QDir>#include <QThread>#pragma execution_character_set("utf-8")void sendPostRequest(){ QNetworkAccessManager *m_pHttpMgr = new QNetworkAccessManager(); //设置url QString url = "http://localhost:80/post"; //设置头信息 QNetworkRequest requestInfo; requestInfo.setUrl(QUrl(url)); requestInfo.setHeader(QNetworkRequest::ContentTypeHeader,QVariant("application/json")); //requestInfo.setRawHeader("Content-Type","application/json");//服务器要求的数据头部 //requestInfo.setRawHeader("Accept","text/json,*, const QString& strExContentDisposition ) { m_pData = nullptr; m_nDataLen = 0; m_sName = strName; m_sValue = strValue; m_sContentType = strContentType; m_sExContentDisposition = strExContentDisposition; } CMultiPartItem::CMultiPartItem(const QString& strName, void* pData, int nLen, const QString& strContentType , const QString& strExContentDisposition ) { m_pData = pData; m_nDataLen = nLen; m_sName = strName; m_sContentType = strContentType; m_sExContentDisposition = strExContentDisposition; } // bool HttpGet( const HttpRequestData& data, QByteArray& respData, int nTimeoutmsec , QString& errMsg, int* pStatuCode ) { // Assemble Url QString strUrl = data.strUrl; if (!data.strServer.isEmpty()) strUrl = data.strServer + ":" + QString::number(data.nPort) + "/" + data.strUrl; const QUrl url = QUrl::fromUserInput(strUrl); // Send Get Requeset QNetworkRequest request(url); for (auto iter = data.mapHeaders.begin(); iter != data.mapHeaders.end(); iter++) { request.setHeader(iter->first, iter->second); } QNetworkAccessManager qNetAccessManager; QNetworkReply* reply = qNetAccessManager.get(request); if (reply == nullptr) return false; // Set time out QTimer timer; timer.setInterval(nTimeoutmsec); // 设置超时时间 30 秒 timer.setSingleShot(true); // 单次触发 // Set Loop Event QEventLoop eventLoop; QObject::connect(&timer, &QTimer::timeout, &eventLoop, &QEventLoop::quit); QObject::connect(reply, &QNetworkReply::finished, &eventLoop, &QEventLoop::quit); timer.start(); int eRes = eventLoop.exec(QEventLoop::ExcludeUserInputEvents); bool bResult = false; if (timer.isActive()) { timer.stop(); QNetworkReply::NetworkError replyError = reply->error(); QVariant variant = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute); int nStatusCode = variant.toInt(); if (nullptr != pStatuCode) { *pStatuCode = nStatusCode; } if (replyError != QNetworkReply::NoError) { errMsg = reply->errorString(); qDebug() << "Error String : " << errMsg << "\n"; } else { if (nStatusCode == 200) { // Accept Response respData = reply->readAll(); bResult = true; } else { bResult = false; } } } else { QObject::disconnect(reply, &QNetworkReply::finished, &eventLoop, &QEventLoop::quit); reply->abort(); qDebug() << strUrl << ":Timeout\n"; } reply->deleteLater(); reply = nullptr; return bResult; } bool HttpPost(const HttpRequestData &data, QByteArray &respData, QString &errMsg, int nTimeoutmsec) { // Assemble Url QString strUrl = data.strUrl; if (!data.strServer.isEmpty()) strUrl = data.strServer + ":" + QString::number(data.nPort) + "/" + data.strUrl; const QUrl url = QUrl::fromUserInput(strUrl); // Send Post Requeset QNetworkRequest request(url); for (auto iter = data.mapHeaders.begin(); iter != data.mapHeaders.end(); iter++) { request.setHeader(iter->first, iter->second); } QNetworkAccessManager qNetAccessManager; QNetworkReply* reply = qNetAccessManager.post(request, data.bytePostData); if (reply == nullptr) return false; // Set time out QTimer timer; timer.setInterval(nTimeoutmsec); // 设置超时时间 30 秒 timer.setSingleShot(true); // 单次触发 // Set Loop Event QEventLoop eventLoop; QObject::connect(&timer, &QTimer::timeout, &eventLoop, &QEventLoop::quit); QObject::connect(reply, &QNetworkReply::finished, &eventLoop, &QEventLoop::quit); timer.start(); eventLoop.exec(QEventLoop::ExcludeUserInputEvents); bool bResult = false; if (timer.isActive()) { timer.stop(); QNetworkReply::NetworkError replyError = reply->error(); if (replyError != QNetworkReply::NoError) { errMsg = reply->errorString(); qDebug() << "Error String : " << reply->errorString() << "\n"; } else { QVariant variant = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute); int nStatusCode = variant.toInt(); if (nStatusCode == 200) { // Accept Response respData = reply->readAll(); bResult = true; } } } else { QObject::disconnect(reply, &QNetworkReply::finished, &eventLoop, &QEventLoop::quit); reply->abort(); errMsg = (strUrl + ":Timeout\n"); qDebug() << strUrl << ":Timeout\n"; } reply->deleteLater(); reply = nullptr; return bResult; } bool UploadMultipartData(const HttpRequestData &data, const CMultiPartDatas &multiPartDatas, QByteArray &respData, QString &errMsg, int nTimeoutmsec) { QString strUrl = data.strUrl; if (!data.strServer.isEmpty()) strUrl = data.strServer + ":" + QString::number(data.nPort) + "/" + data.strUrl; const QUrl url = QUrl::fromUserInput(strUrl); // 创建网络请求 QNetworkRequest request; request.setUrl(url); QHttpMultiPart httpMultiPart(QHttpMultiPart::FormDataType); // 解决Qt自动解析MultiPart得到boundary=带双引号问题 for (auto iter = data.mapHeaders.begin(); iter != data.mapHeaders.end(); iter++) { request.setHeader(iter->first, iter->second); } request.setHeader(QNetworkRequest::ContentTypeHeader, "multipart/form-data;boundary=" + httpMultiPart.boundary()); FOR_EACH(itemPart, multiPartDatas) { QHttpPart httpPart; { QString strContentDisposition = QString("form-data; name=\"%1\"%2").arg(itemPart.m_sName) .arg(itemPart.m_sExContentDisposition.isEmpty() ? "" : "; " + itemPart.m_sExContentDisposition); httpPart.setHeader(QNetworkRequest::ContentDispositionHeader, strContentDisposition.toUtf8()); if (itemPart.m_sContentType.isEmpty() == false) { httpPart.setHeader(QNetworkRequest::ContentTypeHeader, itemPart.m_sContentType.toUtf8()); } if (itemPart.m_pData) { httpPart.setBody(QByteArray((const char*)itemPart.m_pData, itemPart.m_nDataLen)); } else { httpPart.setBody(itemPart.m_sValue.toUtf8()); } } httpMultiPart.append(httpPart); } QNetworkAccessManager qNetAccessManager; QNetworkReply* reply = qNetAccessManager.post(request, &httpMultiPart); if (reply == nullptr) { errMsg = QObject::tr("发送失败"); return false; } QList<QByteArray> headers = reply->rawHeaderList(); // Set time out QTimer timer; timer.setInterval(nTimeoutmsec); // 设置超时时间 30 秒 timer.setSingleShot(true); // 单次触发 // Set Loop Event QEventLoop eventLoop; QObject::connect(&timer, &QTimer::timeout, &eventLoop, &QEventLoop::quit); QObject::connect(reply, &QNetworkReply::finished, &eventLoop, &QEventLoop::quit); timer.start(); eventLoop.exec(QEventLoop::ExcludeUserInputEvents); bool bResult = false; if (timer.isActive()) { timer.stop(); QNetworkReply::NetworkError replyError = reply->error(); if (replyError != QNetworkReply::NoError) { errMsg = reply->errorString(); qDebug() << "Error String : " << reply->errorString() << "\n"; } else { QVariant variant = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute); int nStatusCode = variant.toInt(); if (nStatusCode == 200) { // Accept Response respData = reply->readAll(); bResult = true; } } } else { QObject::disconnect(reply, &QNetworkReply::finished, &eventLoop, &QEventLoop::quit); reply->abort(); qDebug() << data.strUrl << ":Timeout\n"; } reply->deleteLater(); reply = nullptr; return bResult; } bool UploadMultipartData(const QString &strURL, const CMultiPartDatas &multiPartDatas, QByteArray &respData, QString &errMsg, int nTimeoutmsec) { // 创建网络请求 QNetworkRequest request; request.setUrl(QUrl::fromUserInput(strURL)); QHttpMultiPart httpMultiPart(QHttpMultiPart::FormDataType); // 解决Qt自动解析MultiPart得到boundary=带双引号问题 request.setHeader(QNetworkRequest::ContentTypeHeader, "multipart/form-data;boundary=" + httpMultiPart.boundary()); foreach (itemPart, multiPartDatas) { QHttpPart httpPart; { QString strContentDisposition = QString("form-data; name=\"%1\"%2").arg(itemPart.m_sName) .arg(itemPart.m_sExContentDisposition.isEmpty() ? "" : "; " + itemPart.m_sExContentDisposition); httpPart.setHeader(QNetworkRequest::ContentDispositionHeader, strContentDisposition.toUtf8()); if (itemPart.m_sContentType.isEmpty() == false) { httpPart.setHeader(QNetworkRequest::ContentTypeHeader, itemPart.m_sContentType.toUtf8()); } if (itemPart.m_pData) { httpPart.setBody(QByteArray((const char*)itemPart.m_pData, itemPart.m_nDataLen)); } else { httpPart.setBody(itemPart.m_sValue.toUtf8()); } } httpMultiPart.append(httpPart); } QNetworkAccessManager qNetAccessManager; QNetworkReply* reply = qNetAccessManager.post(request, &httpMultiPart); if (reply == nullptr) { errMsg = QObject::tr("发送失败"); return false; } QList<QByteArray> headers = reply->rawHeaderList(); // Set time out QTimer timer; timer.setInterval(nTimeoutmsec); // 设置超时时间 30 秒 timer.setSingleShot(true); // 单次触发 // Set Loop Event QEventLoop eventLoop; QObject::connect(&timer, &QTimer::timeout, &eventLoop, &QEventLoop::quit); QObject::connect(reply, &QNetworkReply::finished, &eventLoop, &QEventLoop::quit); timer.start(); eventLoop.exec(QEventLoop::ExcludeUserInputEvents); bool bResult = false; if (timer.isActive()) { timer.stop(); QNetworkReply::NetworkError replyError = reply->error(); if (replyError != QNetworkReply::NoError) { errMsg = reply->errorString(); qDebug() << "Error String : " << reply->errorString() << "\n"; } else { QVariant variant = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute); int nStatusCode = variant.toInt(); if (nStatusCode == 200) { // Accept Response respData = reply->readAll(); bResult = true; } } } else { QObject::disconnect(reply, &QNetworkReply::finished, &eventLoop, &QEventLoop::quit); reply->abort(); qDebug() << strURL << ":Timeout\n"; } reply->deleteLater(); reply = nullptr; return bResult; }}
关于“Qt怎么用QNetwork实现上传数据”这篇文章的内容就介绍到这里,感谢各位的阅读!相信大家对“Qt怎么用QNetwork实现上传数据”知识都有一定的了解,大家如果还想学习更多知识,欢迎关注编程网行业资讯频道。