添加 QtNetworkService库

2025-07-18 19:42:21 +08:00 · 2020-11-08 20:41:18 +08:00 · 2020-11-08 20:41:18 +08:00 · 2ae6e80785
commit 2ae6e80785
parent f5788efb47
14 changed files with 1083 additions and 2 deletions
--- a/.gitignore
+++ b/.gitignore
@ -1,3 +1,4 @@
 spark-store.pro.user*
 build/
-.vscode/
+.vscode/
+Lib/
--- a/spark-store.pro
+++ b/spark-store.pro
@ -66,3 +66,7 @@ DISTFILES += \
 TRANSLATIONS = ./trans/spark-store_en.ts \
               ./trans/spark-store_zh_CN.ts
               ./trans/spark-store_fr.ts\
+
+DEFINES += QT_APP_DEBUG
+include(./third-party/QtNetworkService/QtNetworkService.pri)
+
--- a/third-party/QtNetworkService/HttpClient.cpp
+++ b/third-party/QtNetworkService/HttpClient.cpp
@ -0,0 +1,42 @@
+/**********************************************************
+Author: Qt君
+微信公众号: Qt君(文章首发)
+Website: qtbig.com(后续更新)
+Email:  2088201923@qq.com
+QQ交流群: 732271126
+LISCENSE: MIT
+**********************************************************/
+#include "HttpClient.h"
+#include <QJsonObject>
+#include <QJsonDocument>
+#include <QBuffer>
+
+using namespace AeaQt;
+
+HttpClient::HttpClient()
+{
+}
+
+HttpClient::~HttpClient()
+{
+}
+
+HttpRequest HttpClient::get(const QString &url)
+{
+    return HttpRequest(QNetworkAccessManager::GetOperation, this).url(url);
+}
+
+HttpRequest HttpClient::post(const QString &url)
+{
+    return HttpRequest(QNetworkAccessManager::PostOperation, this).url(url);
+}
+
+HttpRequest HttpClient::put(const QString &url)
+{
+    return HttpRequest(QNetworkAccessManager::PutOperation, this).url(url);
+}
+
+HttpRequest HttpClient::send(const QString &url, QNetworkAccessManager::Operation op)
+{
+    return HttpRequest(op, this).url(url);
+}
--- a/third-party/QtNetworkService/HttpClient.h
+++ b/third-party/QtNetworkService/HttpClient.h
@ -0,0 +1,36 @@
+/**********************************************************
+Author: Qt君
+微信公众号: Qt君(文章首发)
+Website: qtbig.com(后续更新)
+Email:  2088201923@qq.com
+QQ交流群: 732271126
+LISCENSE: MIT
+**********************************************************/
+#ifndef HTTP_CLIENT_H
+#define HTTP_CLIENT_H
+
+#include "HttpRequest.h"
+#include "HttpResponse.h"
+#include <QNetworkRequest>
+#include <QNetworkReply>
+
+namespace AeaQt {
+
+class HttpClient : public QNetworkAccessManager
+{
+    Q_OBJECT
+public:
+    friend class HttpRequest;
+
+    HttpClient();
+    ~HttpClient();
+
+    HttpRequest get(const QString &url);
+    HttpRequest post(const QString &url);
+    HttpRequest put(const QString &url);
+
+    HttpRequest send(const QString &url, Operation op = GetOperation);
+};
+
+}
+#endif
--- a/third-party/QtNetworkService/HttpRequest.cpp
+++ b/third-party/QtNetworkService/HttpRequest.cpp
@ -0,0 +1,268 @@
+/**********************************************************
+Author: Qt君
+微信公众号: Qt君(文章首发)
+Website: qtbig.com(后续更新)
+Email:  2088201923@qq.com
+QQ交流群: 732271126
+LISCENSE: MIT
+**********************************************************/
+#include "HttpRequest.h"
+#include "HttpClient.h"
+
+#include <QJsonDocument>
+#include <QUrlQuery>
+#include <QBuffer>
+#include <QMetaEnum>
+
+using namespace AeaQt;
+
+static const char *s_httpOperation[] = {
+    "UnknownOperation",
+    "HeadOperation",
+    "GetOperation",
+    "PutOperation",
+    "PostOperation",
+    "DeleteOperation",
+    "CustomOperation"
+};
+
+HttpRequest::HttpRequest()
+{
+
+}
+
+HttpRequest::~HttpRequest()
+{
+}
+
+HttpRequest::HttpRequest(QNetworkAccessManager::Operation op, HttpClient *jsonHttpClient) :
+    m_body(QByteArray()),
+    m_op(op),
+    m_httpService(jsonHttpClient),
+    m_timeout(-1)
+{
+}
+
+HttpRequest &HttpRequest::url(const QString &url)
+{
+    m_networkRequest.setUrl(QUrl(url));
+    return *this;
+}
+
+HttpRequest &HttpRequest::header(const QString &key, const QVariant &value)
+{
+    m_networkRequest.setRawHeader(QByteArray(key.toStdString().data()), QByteArray(value.toString().toStdString().data()));
+
+    return *this;
+}
+
+HttpRequest &HttpRequest::headers(const QMap<QString, QVariant> &headers)
+{
+   QMapIterator<QString, QVariant> iter(headers);
+   while (iter.hasNext()) {
+       iter.next();
+       header(iter.key(), iter.value());
+   }
+
+   return *this;
+}
+
+HttpRequest &HttpRequest::body(const QVariantMap &content)
+{
+    m_body = QJsonDocument(QJsonObject::fromVariantMap(content)).toJson();
+    return *this;
+}
+
+HttpRequest &HttpRequest::body(const QJsonObject &content)
+{
+    m_body = QJsonDocument(QJsonObject::fromVariantMap(content.toVariantMap())).toJson();
+    return *this;
+}
+
+HttpRequest &HttpRequest::body(const QByteArray &content)
+{
+    m_body = content;
+    return *this;
+}
+
+#if 0
+HttpRequest &HttpRequest::body(const QVariant &body)
+{
+    /// clear m_jsonBody
+    m_jsonBody = QJsonObject();
+
+    if (type == X_Www_Form_Urlencoded) {
+        QUrl url;
+        QUrlQuery urlQuery(url);
+
+        if (body.type() == QVariant::Map
+            || body.typeName() ==  QMetaType::typeName(QMetaType::QJsonObject)) {
+
+            QMapIterator<QString, QVariant> i(body.toMap());
+            while (i.hasNext()) {
+                i.next();
+                urlQuery.addQueryItem(i.key(), i.value().toString());
+            }
+
+            url.setQuery(urlQuery);
+            m_body = url.toString(QUrl::FullyEncoded).toUtf8().remove(0, 1);
+        }
+        else {
+            m_body = body.toByteArray();
+        }
+    }
+    else if (type == Raw_Text_Json) {
+        if (body.type() == QVariant::Map
+            || body.typeName() ==  QMetaType::typeName(QMetaType::QJsonObject)) {
+
+            m_body = QJsonDocument(QJsonObject::fromVariantMap(body.toMap())).toJson();
+        }
+        else {
+            warning << "This is not data in JSON format(QVariantMap or QJsonObject).";
+            m_body = QByteArray();
+            // warning output
+        }
+    }
+    else {
+        m_body = QByteArray();
+        warning << "Disable body.";
+    }
+
+    debugger << "Body Content:" << m_body;
+    return *this;
+}
+#endif
+
+HttpRequest &HttpRequest::onResponse(const QObject *receiver, const char *slot, HttpResponse::SupportMethod type)
+{
+    m_slotsMap.insert(type, {slot, QVariant::fromValue((QObject *)receiver)});
+    return *this;
+}
+
+HttpRequest &HttpRequest::onResponse(std::function<void (QNetworkReply *)> lambda)
+{
+    return onResponse(QVariant::fromValue(lambda));
+}
+
+HttpRequest &HttpRequest::onResponse(std::function<void (QVariantMap)> lambda)
+{
+    return onResponse(QVariant::fromValue(lambda));
+}
+
+HttpRequest &HttpRequest::onResponse(std::function<void (QByteArray)> lambda)
+{
+    return onResponse(QVariant::fromValue(lambda));
+}
+
+HttpRequest &HttpRequest::onResponse(std::function<void (qint64, qint64)> lambda)
+{
+    return onResponse(QVariant::fromValue(lambda));
+}
+
+HttpRequest &HttpRequest::onError(const QObject *receiver, const char *slot)
+{
+    return onResponse(receiver, slot, HttpResponse::AutoInfer);
+}
+
+HttpRequest &HttpRequest::onError(std::function<void (QNetworkReply::NetworkError)> lambda)
+{
+    return onResponse(QVariant::fromValue(lambda));
+}
+
+HttpRequest &HttpRequest::onError(std::function<void (QString)> lambda)
+{
+    return onResponse(QVariant::fromValue(lambda));
+}
+
+HttpRequest &HttpRequest::onError(std::function<void (QNetworkReply::NetworkError, QNetworkReply *)> lambda)
+{
+    return onResponse(QVariant::fromValue(lambda));
+}
+
+HttpRequest &HttpRequest::onError(std::function<void (QString, QNetworkReply *)> lambda)
+{
+    return onResponse(QVariant::fromValue(lambda));
+}
+
+HttpRequest &HttpRequest::timeout(const int &msec)
+{
+    m_timeout = msec;
+    return *this;
+}
+
+HttpRequest &HttpRequest::block()
+{
+    m_isBlock = true;
+    return *this;
+}
+
+HttpRequest &HttpRequest::onResponse(QVariant lambda)
+{
+    m_slotsMap.insert(HttpResponse::AutoInfer, {lambda.typeName(), lambda});
+
+    return *this;
+}
+
+HttpResponse *HttpRequest::exec()
+{
+    QNetworkReply* reply = NULL;
+    QBuffer* sendBuffer = new QBuffer();
+    if (! m_body.isEmpty()) {
+        sendBuffer->setData(m_body);
+    }
+
+    debugger << "Http Client info: ";
+    debugger << "Type: " << s_httpOperation[m_op];
+    debugger << "Url: " << m_networkRequest.url().toString();
+    QString headers;
+    for (int i = 0; i < m_networkRequest.rawHeaderList().count(); i++) {
+        QString each = m_networkRequest.rawHeaderList().at(i);
+        QString header = m_networkRequest.rawHeader(each.toUtf8());
+        headers += QString("%1: %2;").arg(each)
+                                     .arg(header);
+    }
+    debugger << "Header: " << headers;
+    debugger << "Send buffer(Body):\r\n" << m_body;
+
+    reply = m_httpService->createRequest(m_op, m_networkRequest, sendBuffer);
+
+    if (reply == NULL) {
+        sendBuffer->deleteLater();
+        return NULL;
+    }
+    else {
+        sendBuffer->setParent(reply);
+    }
+
+    return new HttpResponse(reply, m_slotsMap, m_timeout, m_isBlock);
+}
+
+HttpRequest &HttpRequest::queryParam(const QString &key, const QVariant &value)
+{
+    QUrl url(m_networkRequest.url());
+    QUrlQuery urlQuery(url);
+
+    urlQuery.addQueryItem(key, value.toString());
+    url.setQuery(urlQuery);
+
+    m_networkRequest.setUrl(url);
+
+    return *this;
+}
+
+HttpRequest &HttpRequest::queryParams(const QMap<QString, QVariant> &params)
+{
+    QMapIterator<QString, QVariant> iter(params);
+    while (iter.hasNext()) {
+        iter.next();
+        queryParam(iter.key(), iter.value());
+    }
+
+    return *this;
+}
+
+HttpRequest &HttpRequest::userAttribute(const QVariant &value)
+{
+    m_networkRequest.setAttribute(QNetworkRequest::User, value);
+    return *this;
+}
--- a/third-party/QtNetworkService/HttpRequest.h
+++ b/third-party/QtNetworkService/HttpRequest.h
@ -0,0 +1,115 @@
+/**********************************************************
+Author: Qt君
+微信公众号: Qt君(文章首发)
+Website: qtbig.com(后续更新)
+Email:  2088201923@qq.com
+QQ交流群: 732271126
+LISCENSE: MIT
+**********************************************************/
+#ifndef HTTP_REQUEST_H
+#define HTTP_REQUEST_H
+
+#include "HttpResponse.h"
+
+#include <QNetworkRequest>
+#include <QNetworkAccessManager>
+#include <QJsonObject>
+#include <QDebug>
+
+namespace AeaQt {
+
+#ifdef QT_APP_DEBUG
+#define debugger qDebug().noquote().nospace() \
+                          << "[AeaQt::Network] Debug: -> " \
+                          << "function: " << __func__ << "; " \
+                          << "line: " << __LINE__ << "; "
+#else
+#define debug QString()
+#endif
+
+#define warning qWarning().noquote().nospace() \
+                           << "[AeaQt::Network] Warning: -> " \
+                           << "function: " << __func__ << "; " \
+                           << "line: " << __LINE__ << "; "
+
+class HttpClient;
+
+class HttpRequest
+{
+public:
+    enum BodyType {
+        None = 0, // This request does not have a body.
+        X_Www_Form_Urlencoded, // x-www-form-urlencoded
+        Raw_Text_Json, // application/json
+    };
+
+    explicit HttpRequest(QNetworkAccessManager::Operation op, HttpClient *jsonHttpClient);
+    virtual ~HttpRequest();
+
+    HttpRequest &url(const QString &url);
+    HttpRequest &header(const QString &key, const QVariant &value);
+    HttpRequest &headers(const QMap<QString, QVariant> &headers);
+
+    HttpRequest &queryParam(const QString &key, const QVariant &value);
+    HttpRequest &queryParams(const QMap<QString, QVariant> &params);
+
+    /* Mainly used for identification */
+    HttpRequest &userAttribute(const QVariant &value);
+
+    HttpRequest &body(const QVariantMap &content);
+    HttpRequest &body(const QJsonObject &content);
+    HttpRequest &body(const QByteArray &content);
+
+    /*
+     * @onRespone slot support type: void function(QVariantMap resultMap) OR
+     *                               void function(QByteArray resultData) OR
+     *                               void function(QNetworkReply* reply)
+     * note: The same type is only triggered once
+     */
+    HttpRequest &onResponse(const QObject *receiver, const char *slot, HttpResponse::SupportMethod type = HttpResponse::AutoInfer);
+    HttpRequest &onResponse(std::function<void (QNetworkReply*)> lambda);
+    HttpRequest &onResponse(std::function<void (QVariantMap)> lambda);
+    HttpRequest &onResponse(std::function<void (QByteArray)> lambda);
+    HttpRequest &onResponse(std::function<void (qint64, qint64)> lambda);
+    /*
+     * @onError slot support type: void function(QNetworkReply::NetworkError error)
+     *                             void function(QString errorString);
+     *                             void function(QNetworkReply::NetworkError error, QNetworkReply* reply);
+     *                             void function(QString errorString, QNetworkReply* reply);
+     * note: The same type is only triggered once
+     */
+    HttpRequest &onError(const QObject *receiver, const char *slot);
+    HttpRequest &onError(std::function<void (QNetworkReply::NetworkError)> lambda);
+    HttpRequest &onError(std::function<void (QString)> lambda);
+    HttpRequest &onError(std::function<void (QNetworkReply::NetworkError, QNetworkReply*)> lambda);
+    HttpRequest &onError(std::function<void (QString, QNetworkReply*)> lambda);
+
+    /**
+     * @brief msec <= 0, disable timeout
+     *        msec >  0, enable timeout
+     */
+    HttpRequest &timeout(const int &msec = -1);
+
+    /**
+     * @brief Block current thread, entering an event loop.
+     */
+    HttpRequest &block();
+
+    HttpResponse *exec();
+
+private:
+    HttpRequest();
+    HttpRequest &onResponse(QVariant lambda);
+
+private:
+    QNetworkRequest                  m_networkRequest;
+    QByteArray                       m_body;
+    QNetworkAccessManager::Operation m_op;
+    HttpClient                      *m_httpService;
+    int                              m_timeout;
+    bool                             m_isBlock;
+    QMultiMap<HttpResponse::SupportMethod, QPair<QString, QVariant>> m_slotsMap;
+};
+
+}
+#endif // HTTP_REQUEST_H
--- a/third-party/QtNetworkService/HttpResponse.cpp
+++ b/third-party/QtNetworkService/HttpResponse.cpp
@ -0,0 +1,331 @@
+/**********************************************************
+Author: Qt君
+微信公众号: Qt君(文章首发)
+Website: qtbig.com(后续更新)
+Email:  2088201923@qq.com
+QQ交流群: 732271126
+LISCENSE: MIT
+**********************************************************/
+#include "HttpResponse.h"
+
+#include <QRegExp>
+#include <QStringList>
+#include <QByteArray>
+#include <QNetworkConfigurationManager>
+#include <QMetaEnum>
+#include <QEventLoop>
+#include <QJsonDocument>
+#include <QJsonObject>
+
+#define T2S(t) (QString(#t).remove(QRegExp("\\s"))) //type to string
+
+#define _exec(target, type, arg) \
+        if (target.canConvert<std::function<void (type)> >()) { \
+            std::function<void (type)> func = target.value<std::function<void (type)> >(); func(arg); \
+        } \
+        else
+
+#define _exec2(target, type1, type2, arg1, arg2) \
+        if (target.canConvert<std::function<void (type1, type2)> >()) { \
+            std::function<void (type1, type2)> func = target.value<std::function<void (type1, type2)> >(); func(arg1, arg2); \
+        } else
+
+using namespace AeaQt;
+
+static const QMap<HttpResponse::SupportMethod, QMap<QString, QVariant>> methodParams =
+{
+    {
+        HttpResponse::onResponse_QNetworkReply_A_Pointer,
+        {
+            {"types", QStringList({T2S(QNetworkReply*)})},
+            {"lambda", T2S(std::function<void (QNetworkReply*)>)},
+            {"signal", SIGNAL(finished(QNetworkReply*))},
+            {"isAutoInfer", true}
+        }
+    },
+    {
+        HttpResponse::onResponse_QByteArray,
+        {
+            {"types", QStringList({T2S(QByteArray)})},
+            {"lambda", T2S(std::function<void (QByteArray)>)},
+            {"signal", SIGNAL(finished(QByteArray))},
+            {"isAutoInfer", true}
+        }
+    },
+    {
+        HttpResponse::onResponse_QVariantMap,
+        {
+            {"types", QStringList({T2S(QVariantMap)})},
+            {"lambda", T2S(std::function<void (QVariantMap)>)},
+            {"signal", SIGNAL(finished(QVariantMap))},
+            {"isAutoInfer", true}
+        }
+    },
+    {
+        HttpResponse::onDownloadProgress_qint64_qint64,
+        {
+            {"types", QStringList({T2S(qint64), T2S(qint64)})},
+            {"lambda", T2S(std::function<void (qint64, qint64)>)},
+            {"signal", SIGNAL(downloadProgress(qint64, qint64))},
+            {"isAutoInfer", true}
+        }
+    },
+    {
+        HttpResponse::onError_QNetworkReply_To_NetworkError,
+        {
+            {"types", QStringList({T2S(QNetworkReply::NetworkError)})},
+            {"lambda", T2S(std::function<void (QNetworkReply::NetworkError)>)},
+            {"signal", SIGNAL(error(QNetworkReply::NetworkError))},
+            {"isAutoInfer", true}
+        }
+    },
+    {
+        HttpResponse::onError_QString,
+        {
+            {"types", QStringList({T2S(QString)})},
+            {"lambda", T2S(std::function<void (QString)>)},
+            {"signal", SIGNAL(error(QString))},
+            {"isAutoInfer", true}
+        }
+    },
+    {
+        HttpResponse::onError_QNetworkReply_To_NetworkError_QNetworkReply_A_Pointer,
+        {
+            {"types", QStringList({T2S(QNetworkReply::NetworkError), T2S(QNetworkReply*)})},
+            {"lambda", T2S(std::function<void (QNetworkReply::NetworkError, QNetworkReply*)>)},
+            {"signal", SIGNAL(error(QNetworkReply::NetworkError, QNetworkReply*))},
+            {"isAutoInfer", true}
+        }
+    },
+    {
+        HttpResponse::onError_QString_QNetworkReply_A_Poniter,
+        {
+            {"types", QStringList({T2S(QString), T2S(QNetworkReply*)})},
+            {"lambda", T2S(std::function<void (QString, QNetworkReply*)>)},
+            {"signal", SIGNAL(error(QString, QNetworkReply*))},
+            {"isAutoInfer", true}
+        }
+    },
+};
+
+static int extractCode(const char *member)
+{
+    /* extract code, ensure QMETHOD_CODE <= code <= QSIGNAL_CODE */
+    return (((int)(*member) - '0') & 0x3);
+}
+
+HttpResponse::HttpResponse(QNetworkReply *networkReply,
+                           const QMultiMap<SupportMethod, QPair<QString, QVariant> > &slotsMap,
+                           const int &timeout,
+                           bool isBlock)
+    : m_networkReply(networkReply),
+      m_slotsMap(slotsMap),
+      QObject(networkReply)
+{
+    slotsMapOperation(m_slotsMap);
+    new HttpResponseTimeout(networkReply, timeout);
+
+    connect(m_networkReply, SIGNAL(finished()), this, SLOT(onFinished()));
+    connect(m_networkReply, SIGNAL(error(QNetworkReply::NetworkError)), this, SLOT(onError(QNetworkReply::NetworkError)));
+    connect(m_networkReply, SIGNAL(downloadProgress(qint64,qint64)), this, SLOT(onDownloadProgress(qint64, qint64)));
+
+    if (isBlock) {
+        QEventLoop loop;
+        QObject::connect(m_networkReply, SIGNAL(finished()), &loop, SLOT(quit()));
+        loop.exec();
+    }
+}
+
+HttpResponse::~HttpResponse()
+{
+}
+
+QNetworkReply *HttpResponse::networkReply()
+{
+    return m_networkReply;
+}
+
+void HttpResponse::onFinished()
+{
+    QNetworkReply *reply = m_networkReply;
+    if (reply->error() != QNetworkReply::NoError)
+        return;
+
+    if (m_slotsMap.contains(onResponse_QNetworkReply_A_Pointer)) {
+        _exec(m_slotsMap.value(onResponse_QNetworkReply_A_Pointer).second, QNetworkReply*, reply) {
+            emit finished(reply);
+        }
+    }
+    else if (m_slotsMap.contains((onResponse_QByteArray))) {
+        QByteArray result = reply->readAll();
+
+        _exec(m_slotsMap.value((onResponse_QByteArray)).second, QByteArray, result) {
+            emit finished(result);
+        }
+
+        reply->deleteLater();
+    }
+    else if (m_slotsMap.contains((onResponse_QVariantMap))) {
+        QByteArray result = reply->readAll();
+        QVariantMap resultMap = QJsonDocument::fromJson(result).object().toVariantMap();
+
+        _exec(m_slotsMap.value((onResponse_QVariantMap)).second, QVariantMap, resultMap){
+            emit finished(resultMap);
+        }
+
+        reply->deleteLater();
+    }
+}
+
+void HttpResponse::onError(QNetworkReply::NetworkError error)
+{
+    QNetworkReply *reply = m_networkReply;
+    const QMetaObject & metaObject = QNetworkReply::staticMetaObject;
+    QMetaEnum metaEnum = metaObject.enumerator(metaObject.indexOfEnumerator("NetworkError"));
+    QString errorString = reply->errorString().isEmpty() ? metaEnum.valueToKey(error) : reply->errorString();
+
+    if (m_slotsMap.contains((onError_QString_QNetworkReply_A_Poniter))) {
+        _exec2(m_slotsMap.value((onError_QString_QNetworkReply_A_Poniter)).second, QString, QNetworkReply*, errorString, reply) {
+            emit this->error(errorString, reply);
+        }
+    }
+    else if (m_slotsMap.contains((onError_QNetworkReply_To_NetworkError_QNetworkReply_A_Pointer))) {
+        _exec2(m_slotsMap.value((onError_QNetworkReply_To_NetworkError_QNetworkReply_A_Pointer)).second,
+              QNetworkReply::NetworkError, QNetworkReply*,
+              error, reply) {
+            emit this->error(error, reply);
+        }
+    }
+    else if (m_slotsMap.contains((onError_QString))) {
+        _exec(m_slotsMap.value((onError_QString)).second, QString, errorString) {
+            emit this->error(errorString);
+        }
+
+        reply->deleteLater();
+    }
+    else if (m_slotsMap.contains((onError_QNetworkReply_To_NetworkError))) {
+        _exec(m_slotsMap.value((onError_QNetworkReply_To_NetworkError)).second, QNetworkReply::NetworkError, error) {
+            emit this->error(error);
+        }
+
+        reply->deleteLater();
+    }
+}
+
+void HttpResponse::onDownloadProgress(qint64 bytesReceived, qint64 bytesTotal)
+{
+    if (m_slotsMap.contains((onDownloadProgress_qint64_qint64))) {
+        _exec2(m_slotsMap.value((onDownloadProgress_qint64_qint64)).second, qint64, qint64, bytesReceived, bytesTotal) {
+            emit downloadProgress(bytesReceived, bytesTotal);
+        }
+    }
+}
+
+static void extractSlot(const QString &respReceiverSlot, QString &extractSlot, QStringList &extractSlotTypes)
+{
+    QString slot(respReceiverSlot);
+    if (extractCode(respReceiverSlot.toStdString().data()) == QSLOT_CODE && !slot.isEmpty()) {
+        slot.remove(0, 1);
+
+        QString unconvertedSlotType = slot;
+        int startIndex = slot.indexOf('(');
+        int endIndex = slot.indexOf(')');
+        Q_ASSERT(startIndex != -1 && endIndex != -1);
+
+        extractSlot = slot.remove(startIndex, endIndex-startIndex+1);
+
+        extractSlotTypes = unconvertedSlotType.mid(startIndex+1, endIndex-startIndex-1)
+                .remove(QRegExp("\\s"))
+                .split(',');
+    }
+}
+
+/* from slotMap get [SupportMethod] */
+static HttpResponse::SupportMethod getSupportMethod(const QPair<QString, QVariant> &slotMap) {
+
+    QMapIterator<HttpResponse::SupportMethod, QMap<QString, QVariant>> iter(methodParams);
+
+    QString receiverSlot = slotMap.first;
+    QString slot;
+    QStringList slotTypes;
+    extractSlot(receiverSlot, slot, slotTypes);
+
+    while (iter.hasNext()) {
+        iter.next();
+        HttpResponse::SupportMethod supportMethod = iter.key();
+        QMap<QString, QVariant> value = iter.value();
+        if (slotTypes == value.value("types").toStringList()) {
+            return supportMethod;
+        }
+        else if (receiverSlot == value.value("lambda").toString()) {
+            return supportMethod;
+        }
+    }
+
+    return HttpResponse::Invalid;
+}
+
+static void autoInfterConvertedSupportMethod(QMultiMap<HttpResponse::SupportMethod, QPair<QString, QVariant> > &unconvertedSlotsMap)
+{
+    QMultiMap<HttpResponse::SupportMethod, QPair<QString, QVariant> > convertedSlotsMap;
+    QMapIterator<HttpResponse::SupportMethod, QPair<QString, QVariant> > iter(unconvertedSlotsMap);
+
+    while (iter.hasNext()) {
+        iter.next();
+        const HttpResponse::SupportMethod supportMethod = iter.key();
+        const QPair<QString, QVariant> slotMap = iter.value();
+
+        if (supportMethod == HttpResponse::AutoInfer) {
+            HttpResponse::SupportMethod supportMethod  = getSupportMethod(slotMap);
+            if (supportMethod == HttpResponse::Invalid) {
+                qDebug()<<"Not find support Method!"<<slotMap.first;
+            }
+            else {
+                if (methodParams[supportMethod].value("isAutoInfer").toBool())
+                    convertedSlotsMap.insert(supportMethod, slotMap);
+                else
+                    qDebug()<<"This type["<<methodParams[supportMethod].value("types").toString()<<"] does not support automatic derivation";
+            }
+        }
+        else {
+            if (methodParams[supportMethod].value("isAutoInfer").toBool())
+                convertedSlotsMap.insert(supportMethod, slotMap);
+            else
+                qDebug()<<"This type["<<methodParams[supportMethod].value("types").toString()<<"] does not support automatic derivation";
+        }
+    }
+
+    unconvertedSlotsMap = convertedSlotsMap;
+
+}
+
+void HttpResponse::slotsMapOperation(QMultiMap<SupportMethod, QPair<QString, QVariant> > &slotsMap)
+{
+    autoInfterConvertedSupportMethod(slotsMap);
+
+    QMapIterator<SupportMethod, QPair<QString, QVariant> > iter(slotsMap);
+    while (iter.hasNext()) {
+        iter.next();
+        SupportMethod supportMethod = iter.key();
+        const QPair<QString, QVariant> &slotMap = iter.value();
+
+        const QString &receiverSlot = slotMap.first;
+        QVariant target = slotMap.second;
+        const QObject *receiver = target.value<QObject*>();
+
+        if (receiver) {
+            if (methodParams.contains(supportMethod)) {
+                connect(this,
+                        methodParams[supportMethod].value("signal").toString().toStdString().data(),
+                        receiver,
+                        receiverSlot.toStdString().data(),
+                        Qt::QueuedConnection);
+            }
+        }
+    }
+}
+
+HttpResponse::HttpResponse()
+{
+
+}
--- a/third-party/QtNetworkService/HttpResponse.h
+++ b/third-party/QtNetworkService/HttpResponse.h
@ -0,0 +1,107 @@
+/**********************************************************
+Author: Qt君
+微信公众号: Qt君(文章首发)
+Website: qtbig.com(后续更新)
+Email:  2088201923@qq.com
+QQ交流群: 732271126
+LISCENSE: MIT
+**********************************************************/
+#ifndef HTTP_RESPONSE_H
+#define HTTP_RESPONSE_H
+
+#include <QNetworkReply>
+#include <QMultiMap>
+#include <functional>
+#include <QTimer>
+
+namespace AeaQt {
+
+class HttpResponseTimeout : public QObject {
+    Q_OBJECT
+public:
+    HttpResponseTimeout(QNetworkReply *parent = NULL, const int timeout = -1) : QObject(parent) {
+        if (timeout > 0)
+            QTimer::singleShot(timeout, this, SLOT(onTimeout()));
+    }
+
+private slots:
+    void onTimeout() {
+        QNetworkReply *reply = static_cast<QNetworkReply*>(parent());
+        if (reply->isRunning()) {
+            reply->abort();
+            reply->deleteLater();
+        }
+    }
+};
+
+class HttpResponse : public QObject
+{
+    Q_OBJECT
+public:
+    /*
+     * Support Reflex Method
+     * default: AutoInfer
+     * AutoInfer: Automatic derivation based on type
+     */
+    enum SupportMethod {
+        Invalid = 0,
+        AutoInfer,
+        onResponse_QNetworkReply_A_Pointer,    /* method: void function(QNetworkReply* reply); Is_AutoInfer: true */
+        onResponse_QByteArray,                 /* method: void function(QByteArray data); Is_AutoInfer: true */
+        onResponse_QVariantMap,                /* method: void function(QVariantMap map); Is_AutoInfer: true */
+        onDownloadProgress_qint64_qint64,      /* method: void function(qint64 bytesReceived, qint64 bytesTotal); Is_AutoInfer: true */
+        onError_QNetworkReply_To_NetworkError, /* method: void function(QNetworkReply::NetworkError error); Is_AutoInfer: true */
+        onError_QString,                       /* method: void function(QString errorString); Is_AutoInfer: true */
+        onError_QNetworkReply_To_NetworkError_QNetworkReply_A_Pointer, /* method: void function(QNetworkReply::NetworkError error, QNetworkReply* reply); Is_AutoInfer: true */
+        onError_QString_QNetworkReply_A_Poniter/* method: void function(QString errorString, QNetworkReply* reply); Is_AutoInfer: true */
+    };
+
+    explicit HttpResponse(QNetworkReply *networkReply,
+                          const QMultiMap<SupportMethod, QPair<QString, QVariant> > &slotsMap,
+                          const int &timeout,
+                          bool isBlock);
+
+    virtual ~HttpResponse();
+
+    QNetworkReply *networkReply();
+
+protected:
+    void slotsMapOperation(QMultiMap<SupportMethod, QPair<QString, QVariant> > &slotsMap);
+
+signals:
+    void finished(QNetworkReply *reply);
+    void finished(QByteArray data);
+    void finished(QVariantMap map);
+    void error(QString errorString);
+    void error(QNetworkReply::NetworkError error);
+    void error(QString errorString, QNetworkReply *reply);
+    void error(QNetworkReply::NetworkError error, QNetworkReply *reply);
+    void downloadProgress(qint64 bytesReceived, qint64 bytesTotal);
+
+private slots:
+    void onFinished();
+    void onError(QNetworkReply::NetworkError error);
+    void onDownloadProgress(qint64 bytesReceived, qint64 bytesTotal);
+
+private:
+    HttpResponse();
+
+private:
+   QMultiMap<SupportMethod, QPair<QString, QVariant> > m_slotsMap;
+   QNetworkReply *m_networkReply;
+};
+
+}
+
+Q_DECLARE_METATYPE(std::function<void (QNetworkReply*)>)
+Q_DECLARE_METATYPE(std::function<void (QByteArray)>)
+Q_DECLARE_METATYPE(std::function<void (QVariantMap)>)
+
+Q_DECLARE_METATYPE(std::function<void (QString)>)
+Q_DECLARE_METATYPE(std::function<void (QNetworkReply::NetworkError)>)
+Q_DECLARE_METATYPE(std::function<void (QNetworkReply::NetworkError, QNetworkReply *)>)
+Q_DECLARE_METATYPE(std::function<void (QString, QNetworkReply *)>)
+
+Q_DECLARE_METATYPE(std::function<void (qint64, qint64)>)
+
+#endif // HTTP_RESPONSE_H
--- a/third-party/QtNetworkService/LICENSE
+++ b/third-party/QtNetworkService/LICENSE
@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2019 Qt君
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
--- a/third-party/QtNetworkService/QtNetworkService.pri
+++ b/third-party/QtNetworkService/QtNetworkService.pri
@ -0,0 +1,15 @@
+#**********************************************************
+#Author: Qt君
+#微信公众号: Qt君(文章首发)
+#Website: qtbig.com(后续更新)
+#Email:  2088201923@qq.com
+#QQ交流群: 732271126
+#LISCENSE: MIT
+#**********************************************************
+INCLUDEPATH += $$PWD/ 
+
+QT += network
+
+!CONFIG(QT_APP_MODE) {
+    LIBS += -L$$OUT_PWD/Lib -lQtNetworkService
+}
--- a/third-party/QtNetworkService/QtNetworkService.pro
+++ b/third-party/QtNetworkService/QtNetworkService.pro
@ -0,0 +1,35 @@
+#**********************************************************
+#Author: Qt君
+#微信公众号: Qt君(文章首发)
+#Website: qtbig.com(后续更新)
+#Email:  2088201923@qq.com
+#QQ交流群: 732271126
+#LISCENSE: MIT
+#**********************************************************
+CONFIG += c++11
+
+#CONFIG += QT_APP_MODE
+DEFINES += QT_APP_DEBUG
+
+CONFIG += staticlib
+TEMPLATE = lib
+unix:TARGET = $$OUT_PWD/Lib/QtNetworkService
+
+win32: {
+DESTDIR = $$OUT_PWD/Lib/
+TARGET = QtNetworkService
+}
+
+message(" ================ QtNetworkService Library ================ ")
+
+SOURCES += \
+    $$PWD/HttpResponse.cpp \
+    $$PWD/HttpRequest.cpp \
+    $$PWD/HttpClient.cpp
+
+HEADERS += \
+    $$PWD/HttpResponse.h \
+    $$PWD/HttpRequest.h \
+    $$PWD/HttpClient.h
+
+include(QtNetworkService.pri)
--- a/third-party/QtNetworkService/README.md
+++ b/third-party/QtNetworkService/README.md
@ -0,0 +1,83 @@
+# 示例
+(1) 简单示例
+* 使用lambda特性
+```cpp
+static HttpClient http;
+http.post("https://example.com")
+    .header("content-type", "application/json")
+    .queryParam("key", "Hello world!")
+    .body(R"({"user": "test"})")
+    .onResponse([](QByteArray result) { /* 接收数据 */
+        qDebug() << "Result: " << result;
+     })
+    .onResponse([](qint64 recv, qint64 total) { /* 接收进度 */
+        qDebug() << "Total: " << total << "; Received: " << recv;
+     })
+    .onError([](QString errorStr) { /* 错误处理 */
+        qDebug()<<"Error: "<<errorStr;
+     })
+    .timeout(30 * 1000) /* 超时操作(30s) */
+    .block() /* 阻塞操作 */
+    .exec();
+```
+
+* 使用Qt信号与槽特性
+```cpp
+http.post("https://example.com")
+    .header("content-type", "application/json")
+    .queryParam("key", "Hello world!")
+    .body(R"({"user": "test"})")
+    .onResponse(this, SLOT(finish(QByteArray)))
+    .onResponse(this, SLOT(downloadProgress(qint64, qint64)))
+    .onError(this, SLOT(error(QString)))
+    .timeout(30 * 1000) /* 超时操作(30s) */
+    .block() /* 阻塞操作 */
+    .exec();
+```
+
+(2) 复杂示例
+```cpp
+/* 获取音乐url功能，请求嵌套请求 */
+static HttpService http;
+http.get("http://mobilecdn.kugou.com/api/v3/search/song")
+    .queryParam("format", "json")
+    .queryParam("keyword", "稻香")
+    .queryParam("page", 1)
+    .queryParam("pagesize", 3)
+    .queryParam("showtype", 1)
+    .onResopnse([](QVariantMap result){
+        QVariantMap data;
+        QList<QVariant> infos;
+        if (!result.isEmpty())
+            data = result.value("data").toMap();
+
+        if (!data.isEmpty())
+            infos = data.value("info").toList();
+
+        static HttpService http;
+        foreach (QVariant each, infos) {
+            http.get("http://m.kugou.com/app/i/getSongInfo.php")
+                .queryParam("cmd", "playInfo")
+                .queryParam("hash", each.toMap()["hash"])
+                .onResopnse([](QVariantMap result){
+                    qDebug()<<"mp3: "<<result["url"].toString();
+                 })
+                .onError([](QString errorStr){ qDebug()<<"Error: "<<errorStr; })
+                .exec();
+        }
+    })
+    .onError([](QString errorStr){ qDebug()<<"Error: "<<errorStr; })
+    .exec();
+```
+## 1.如何使用？
+* 以Qt子工程使用．再在其他子工程包含pri文件即可使用;
+* 通过引用库的方式使用．
+
+## 2.如何启用demo测试？
+* 在QtNetworkService.pro文件中将"#CONFIG += QT_APP_MODE"这一行的#去除即可转为可执行文件形式，在Demo目录的main.cpp为主执行文件，如需要测试接口编辑便可。
+
+## 3.扫码关注，第一时间获取推送
+<p align="center">
+  <img src="http://www.qtbig.com/about/index/my_qrcode.jpg" alt="微信公众号:Qt君">
+  <p align="center"><em>Qt君</em></p>
+</p>
--- a/widget.cpp
+++ b/widget.cpp
@ -29,8 +29,11 @@
 #include <DApplication>
 #include <DGuiApplicationHelper>
 #include <QPushButton>
+#include "HttpClient.h"
+
 DWIDGET_USE_NAMESPACE

+
 Widget::Widget(DBlurEffectWidget *parent) :
    DBlurEffectWidget(parent),
    ui(new Ui::Widget)
@ -42,6 +45,8 @@ Widget::Widget(DBlurEffectWidget *parent) :
    m_loadweb=ui->progressload;
    m_loadweb->show();

+    httpClient = new AeaQt::HttpClient;
+
    connect(ui->menu_main,&QPushButton::clicked,[=](){Widget::chooseLeftMenu(0);});
    connect(ui->menu_network,&QPushButton::clicked,[=](){Widget::chooseLeftMenu(1);});
    connect(ui->menu_chat,&QPushButton::clicked,[=](){Widget::chooseLeftMenu(2);});
@ -710,12 +715,26 @@ void Widget::startRequest(QUrl url)

 void Widget::searchApp(QString text)
 {
+    qDebug() << "测试，我的输出是否被调用了，啊啊啊啊";
    if(text.left(6)=="spk://"){
        openUrl(text);
    }else {
-        sendNotification(tr("Spark store could only process spk:// links for now. The search feature is coming soon!"));
+        // sendNotification(tr("Spark store could only process spk:// links for now. The search feature is coming soon!"));
        // ui->webView->setUrl(QUrl("http://www.baidu.com/s?wd="+text));//这东西对接百度
        // ui->stackedWidget->setCurrentIndex(0);
+        // 关键字搜索处理
+        httpClient->get("http://192.168.0.102:8000/appinfo/search")
+            .header("content-type", "application/json")
+            .queryParam("keyword", text)
+            .onResponse([](QByteArray result) {
+                qDebug() << "请求结果" << result;
+            })
+            .onError([](QString errorStr) {
+                qDebug()  << "请求出错：" << errorStr;
+            })
+            .timeout(10 * 1000)
+            .exec();
+
    }
 }

--- a/widget.h
+++ b/widget.h
@ -36,6 +36,9 @@ class Widget;
 }


+namespace AeaQt {
+    class HttpClient;
+}

 class Widget : public DBlurEffectWidget
 {
@ -145,6 +148,7 @@ private:
    QList<image_show*> label_screen;
    SpkAppInfoLoaderThread appinfoLoadThread;

+    AeaQt::HttpClient *httpClient;
 };

 #endif // WIDGET_H