qt - qt 异步客户端响应 gsoap

Question

我正在使用 gsoap lib 编写客户端服务器应用程序。问题是我的服务器中有一个繁重的进程功能。我想当特殊客户端调用此函数时，服务器会在此客户端答案准备好时为此特殊客户端发送消息“您的答案已准备好”。并且可能多个客户端同时调用此函数。qt中是否有类似asynchronAnswer的工具？如果不是，我该如何使用 qt 或 gsoap 工具来处理它？处理这个问题的真正架构师是什么？在客户端调用中使用多线程并等待其他线程中的响应或通过服务器中的 ip 或更好的方法准确调用客户端？谢谢，

Answer 1

您可以尝试使用 QWebSocket 来完成此任务。您已连接客户端列表，如果客户端发送“重进程功能”请求，您将放入线程池，并在计算完成后向特定客户端发送重播。在代码中它将是这样的：

服务器.h

#ifndef SERVER_H
#define SERVER_H

#include <QObject>
#include <QtWebSockets>

class Server : public QObject
{
    Q_OBJECT
public:
    explicit Server(QObject *parent = 0);
    ~Server();
signals:
    void closed();
public slots:
private slots:
    void onNewConnection();
    void onMessage(QString message);
    void onDisconnected();
private:
    QWebSocketServer* m_pWebSocketServer;
    QList<QWebSocket*> m_clients;
};

#endif // SERVER_H

服务器.cpp

#include <QThreadPool>

#include "server.h"
#include "heavytask.h"

Server::Server(QObject *parent) :
    QObject(parent),
    m_pWebSocketServer(new QWebSocketServer(QStringLiteral("Server"), QWebSocketServer::NonSecureMode, this))
{
    if (m_pWebSocketServer->listen(QHostAddress::Any, 4000)) {
        connect(m_pWebSocketServer, &QWebSocketServer::newConnection, this, &Server::onNewConnection);
        connect(m_pWebSocketServer, &QWebSocketServer::closed, this, &Server::closed);
    }
}

void Server::onNewConnection()
{
    QWebSocket *pSocket = m_pWebSocketServer->nextPendingConnection();
    connect(pSocket, &QWebSocket::textMessageReceived, this, &Server::onMessage);
    connect(pSocket, &QWebSocket::disconnected, this, &Server::onDisconnected);

    m_clients << pSocket;
}

void Server::onMessage(QString message)
{
    QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());

    if (message == "Start heavy process function in your server, please") {
        HeavyTask* ht = new HeavyTask(pClient);
        QThreadPool::globalInstance()->start(ht);
    }
}

void Server::onDisconnected()
{
    QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
    if (pClient) {
        m_clients.removeAll(pClient);
        pClient->deleteLater();
    }
}

Server::~Server()
{
    m_pWebSocketServer->close();
    qDeleteAll(m_clients.begin(), m_clients.end());
}

重任务.h

#ifndef HEAVYTASK_H
#define HEAVYTASK_H

#include <QThreadPool>
#include <QRunnable>
#include <QWebSocket>

class HeavyTask : public QRunnable
{
public:
    explicit HeavyTask(QWebSocket* client);
    void run();
private:
    QWebSocket* m_client;
};

#endif // HEAVYTASK_H

繁重的任务.cpp

#include "heavytask.h"

HeavyTask::HeavyTask(QWebSocket* client) : m_client(client)
{
}

void HeavyTask::run()
{
    /*
    Do your havy task;
    */

    if (m_client != nullptr) {
        if (m_client->isValid()) {
            m_client->sendTextMessage("Your answer is ready!");
        }
    }
}

和 main.cpp

#include <QCoreApplication>
#include "server.h"

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    Server server(&a);
    QObject::connect(&server, &Server::closed, &a, &QCoreApplication::quit);
    return a.exec();
}

希望它会有用。（根本没尝过，但编译）