QT打造高效线程池异步QWebSocket 客户端

Posted qianbo_insist

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了QT打造高效线程池异步QWebSocket 客户端相关的知识,希望对你有一定的参考价值。

目的

我们可以使用QWebSocket得异步通信来高效传输数据,当时我们使用QWebSocket来和服务端取得视频信息流,而渲染也使用同样得界面线程,大量得包流通并且要渲染多个画面,这使得通信包来不及接收,这样,QWebSocket要使用不同得线程来接收数据包,和渲染分开,所以可以使用多个线程来将QWebSocket得异步通信放入到某个线程中,这里比较核心的是,将几个QWebSocke 放到同一个线程执行,这其实就是线程池技术。我们的示例是将两个QWebSocket放到一个线程中,学会了处理,自己稍加修改就可以做出像样的线程池了。

qt 多线程websocket

Qt有两种多线程的方法,其中一种是继承QThread的run函数,
另外一种是把一个继承于QObject的类用moveToThread函数转移到一个Thread里。
Qt4.8之前都是使用继承QThread的run这种方法,Qt4.8之后,Qt官方建议使用第二种方法。

具体的使用步骤如下:

1.从QObject派生一个类,将耗时的工作写在该类的槽函数中。

2.将派生类对象移动到一个QThread中,该线程需要start。(这一步使用moveToThread)

3.通过信号连接派生类的槽函数,并通过信号触发槽函数。(槽函数在子线程中执行)

#ifndef WORKER_H
#define WORKER_H


#include <QDebug>
#include <QThread>
#include <QString>
#include <QObject>

class Worker:public QObject

    Q_OBJECT
public:
    explicit Worker(QObject *parent=0);
    ~Worker();

signals:
    void sig_finish();

public slots:
    void slot_dowork();

;
#endif // WORKER_H
#include "worker.h"

Worker::Worker(QObject *parent):QObject(parent)

    qDebug()<<"worker()";

Worker::~Worker()

    qDebug()<<"~worker()";

void Worker::slot_dowork()

    qDebug()<< "do work,thread id = " << QThread::currentThreadId();
    int i =0;
    while(i++<10)
    
        qDebug()<<"this is time for:"<<i;
        QThread::msleep(20);
    
    emit sig_finish();

其中我们的slot_dowork函数其实就是我们的线程工作函数,是通过发送信号来接收信息的,线面我们来看mainwindow

mainwindow

#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QMainWindow>
#include <worker.h>
QT_BEGIN_NAMESPACE
namespace Ui  class MainWindow; 
QT_END_NAMESPACE

class MainWindow : public QMainWindow

    Q_OBJECT

public:
    MainWindow(QWidget *parent = nullptr);
    ~MainWindow();
    void dowork();
private:
    Ui::MainWindow *ui;
    Worker *m_pworker;
    QThread *m_pthread;
signals:
    void sig_dowork();

public slots:
    void slot_finish();
;
#endif // MAINWINDOW_H

mainwindow.cpp 文件

实现

#include "mainwindow.h"
#include "ui_mainwindow.h"

MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
    , ui(new Ui::MainWindow)

    ui->setupUi(this);
    m_pworker = new Worker();
      m_pthread = new QThread();
      m_pworker->moveToThread(m_pthread);
      qDebug()<< "start,thread id = " << QThread::currentThreadId();

      connect(m_pthread, &QThread::finished, m_pworker, &QObject::deleteLater);
      connect(this,SIGNAL(sig_dowork()),m_pworker,SLOT(slot_dowork()));
      connect(m_pworker,SIGNAL(sig_finish()),this,SLOT(slot_finish()));


MainWindow::~MainWindow()

    delete ui;
    m_pthread->quit();
    m_pthread->wait();


void MainWindow::dowork()

    m_pthread->start();
    emit sig_dowork();


void MainWindow::slot_finish()

     qDebug()<< "finish,thread id = " << QThread::currentThreadId();

在主函数里面启动线程得方法:
调用mainwindow的dowork,事先这些资源都已经new出来了,可以开始工作

#include "mainwindow.h"

#include <QApplication>

int main(int argc, char *argv[])

    QApplication a(argc, argv);
    MainWindow w;
    w.show();
    w.dowork();
    return a.exec();

运行结果如下图所示

多个websocket 使用同一个线程

如果多个QWebSocket 使用不同得线程,创建多个以上得thread就行,问题是要分配好线程,不宜过多,不宜过少,如何做到呢,下面我们来修改一下:
我们创建一个wsclientmanager类,使得多个websocket在一个线程里运行,只要能这样做,就可以创建一个线程池,每个线程分配相应得QWebSocket。

#ifndef WSCLIENTMANAGER_H
#define WSCLIENTMANAGER_H

#include "worker.h"
#include <QMap>

class wsClient:public QObject

    Q_OBJECT
private:
    QString m_name;
    //QThread *m_pthread = NULL;
public:
   // void send_message(QString str, char* content);
    void send(QString str)
    
        emit sig_send(str);
    
    void start()
    
        emit sig_start();
    
public:
signals:
    void sig_start();
    void sig_send(QString str);
public slots:
    void slot_finish()
    
         qDebug()<< "finish,thread id = " << QThread::currentThreadId();
    
;

class wsClientManager:public QObject

    Q_OBJECT
   QMap<QString,wsClient*> map_ptr_Client;
   QMap<QString,Worker*> map_ptr_work;
   QThread* m_pthread = NULL;
public:
   wsClientManager();
   ~wsClientManager();
   int add_client(QString str);
   int dec_client(QString str);

    void start();
    void send_message(QString str, QString content);
;

#endif // WSCLIENTMANAGER_H

实现文件如下:

#include "wsclientmanager.h"



wsClientManager::wsClientManager()

    m_pthread = new QThread();

wsClientManager::~wsClientManager()

    m_pthread->quit();
    m_pthread->wait();


void wsClientManager::start()


    //emit sig_dowork();


int wsClientManager::add_client(QString str)

    if(!m_pthread->isRunning())
        m_pthread->start();
    qDebug()<<m_pthread->isRunning();
    if(map_ptr_Client.find(str)== map_ptr_Client.end())
    
        wsClient* client = new wsClient();
        Worker* work = new Worker(str);
        work->moveToThread(m_pthread);
        connect(client,SIGNAL(sig_start()),work,SLOT(slot_start()));
        connect(client,SIGNAL(sig_send(QString)),work,SLOT(send(QString)));
        connect(work,SIGNAL(sig_finish()),client,SLOT(slot_finish()));
        map_ptr_work.insert(str,work);
        map_ptr_Client.insert(str,client);
        client->start();
        return 1;
    
    return 0;

void wsClientManager::send_message(QString str, QString content)

    auto iter = map_ptr_Client.find(str);
    if(iter!=map_ptr_Client.end())
    
        iter.value()->send(content);
        //iter->second->send(content);
    
    else
        qDebug()<<"not find the name of "<<str;


界面如下:

在启动时先创建用户1和用户2,分别对应一个wsClient, 创建相应得Worker,并且关联,代码见addClient函数,我们点击用户1时, 发送得是用户1要发送得内容,同理用户2
事先创建用户1 qianbo1 用户2 qianbo2

void MainWindow::dowork()

    m_manager.add_client("qianbo1");
    m_manager.add_client("qianbo2");
    //m_pthread->start();
    //emit sig_dowork();

发送时,根据选择得用户来发送内容


void MainWindow::on_pushButton_clicked()

    QString str ;
    if(ui->radioButton->isChecked())
    
        str = "qianbo1";
    
    else
    
        str = "qianbo2";
    

    m_manager.send_message(str,ui->lineEdit->text());


根据qDebug 输出如下, 返回内容可以看出是不同得用户接收得

那么服务端在哪里呢?我们使用nodejs来写一个非常简单得代码,一下子就有了,我们使用ws来做服务端测试


var WebSocketServer = require('ws').Server,
wss = new WebSocketServer( port: 8777 );
wss.on('connection', function (ws) 
    console.log('client connected');
    ws.on('message', function (message) 
        console.log(message);
        ws.send("this is a test");
	
    );
);

启动如下所示:

无论谁发送过来都给一个this is a test,读者可以根据需求来做返回,也可以返回json等等,根据需求来做吧。

代码下载:下载

以上是关于QT打造高效线程池异步QWebSocket 客户端的主要内容,如果未能解决你的问题,请参考以下文章

Qt QWebsocket::open 阻塞用户界面

如何在 Qt 中修改 QWebsocket 定时器

无法使用任何 QWebSocket 客户端基本示例

python异步爬虫:引入+线程池实战

高效线程池(threadpool)的实现

一种基于Qt的可伸缩的全异步C/S架构服务器实现 综述