Hello developers, I have tried something with QNetworkAccessManager & QThreads.
I had some problem with Qthreads my QThread::finished function have not been called even after i got my response.
Implementation here:
RESTClientController -> Assign jobs to Threads
#include "RESTClientController.h"
#include <QThread>
RESTClientController::RESTClientController(QObject *parent) : QObject(parent)
{
}
void RESTClientController::executeRESTRequests(RESTClient *client)
{
QThread *thread = new QThread();
client->moveToThread(thread);
connect(thread, &QThread::finished, this, &RESTClientController::onThreadFinished);
connect(thread, &QThread::started, client, &RESTClient::startSync);
connect(thread, &QThread::finished, thread, &QThread::deleteLater);
thread->start();
}
void RESTClientController::onThreadFinished()
{
qDebug() << "THread done its job !!!!!";
}
Class RESTClient -> Used to make Network request through Common AccessManager
#include "RESTClient.h"
#include <QEventLoop>
RESTClient::RESTClient(NetworkRequest *reqRes, QObject *parent) :
QObject(parent),
m_request(reqRes)
{
m_networkManager = new QNetworkAccessManager();
connect(m_networkManager, &QNetworkAccessManager::finished, m_request, &NetworkRequest::onFinished);
}
void RESTClient::startSync()
{
m_networkManager->get(m_request->constructRequest());
}
Class NetworkRequest -> Container having QNetworkRequest & QNetworkReply
#include "NetworkRequest.h"
#include <QDebug>
#include <QJsonDocument>
NetworkRequest::NetworkRequest(QObject *parent) : QObject(parent)
{
initMembers();
}
void NetworkRequest::initMembers()
{
m_request.setHeader(QNetworkRequest::ContentTypeHeader,
"application/x-www-form-urlencoded");
}
void NetworkRequest::setUrl(const QString hostName)
{
m_url = hostName;
m_request.setUrl(QUrl(m_url));
}
void NetworkRequest::setHeader(QNetworkRequest::KnownHeaders header, const QVariant &value)
{
m_request.setHeader(header, value);
}
void NetworkRequest::onFinished(QNetworkReply *reply)
{
int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
QByteArray data = reply->readAll();
handleReply(status, data);
}
void NetworkRequest::handleReply(int status, QByteArray data)
{
QJsonDocument jsonDocument;
QJsonParseError parsingResult;
if (status >= 200 && status < 300) {
// success
jsonDocument = QJsonDocument::fromJson(data, &parsingResult);
qDebug() << QString("Status: %1 !!! success").arg(QString::number(status));
} else if (status >= 300 && status < 400) {
qDebug() << QString("Status: %1 !!! Redirected").arg(QString::number(status));
} else if (status >= 400 && status < 500) {
qDebug() << QString("Status: %1 !!! Client error").arg(QString::number(status));
} else if (status >= 500 && status < 600) {
qDebug() << QString("Status: %1 !!! Server error").arg(QString::number(status));
} else {
qDebug() << QString("Status: %1 !!! Unknown error").arg(QString::number(status));
}
}
Main or Some Backend class -> Trigger requests
RESTClientController *m_restController;
NetworkRequest *request = new NetworkRequest();
RESTClient *restClient = new RESTClient(request);
m_restController->executeRESTRequests(restClient);
Above is my implementation as of now im jus creating QTHread instances. In future i had an idea to go with QThreadPool. But now I can't able to catch my finished signal from QThread. So that i can able to clear my instances.
Thanks in advance
