当前位置: 首页 > article >正文

Qt实现多线程

Qt服务器多线程

  • 1、新建线程类
  • 2、修改线程头文件
  • 3、包含头文件,启动线程
  • 4、重写run()函数
    • 4.1把socket传过去
    • 4.2重写run()函数
  • 5、创建处理接收到来自客户端数据的槽函数
  • 6、自定义一个信号用来把数据发送出去
  • 7、Widget接收信号
  • 8、创建处理sendToServer信号的槽函数
  • 9、.h文件和.cpp文件
    • 9.1 mythread.h
    • 9.2 mythread.cpp
    • 9.3 Widget.h
    • 9.4Widget.cpp
  • 10、总结

1、新建线程类

在这里插入图片描述
在这里插入图片描述

2、修改线程头文件

#include <QObject>
#include <QThread>
#include <QTcpSocket>

// 定义 myThread 类,继承自 QThread 类,用于创建处理客户端连接的独立线程
class myThread : public QThread

3、包含头文件,启动线程

#include <QWidget>
#include <QTcpServer>
#include <QTcpSocket>
#include <mythread.h>
//启动线程
myThread *t = new myThread(socket);     //创建线程对象
t->start();                     //开始线程

4、重写run()函数

4.1把socket传过去

myThread *t = new myThread(socket);     //创建线程对象
private:
    QTcpSocket *socket;      //创建网络通信对象,用来接受参数传递
public:
    // 显式构造函数,接受一个 QTcpSocket 指针参数 s,用于初始化 socket 成员变量
    explicit myThread(QTcpSocket *s);   
myThread::myThread(QTcpSocket *s)
{
    socket = s;
}

4.2重写run()函数

public:
    // 显式构造函数,接受一个 QTcpSocket 指针参数 s,用于初始化 socket 成员变量
    explicit myThread(QTcpSocket *s);   

    void run() override;        //线程处理函数
void myThread::run()
{
    //当有数据可读时,readyRead 信号被触发
    connect(socket, &QTcpSocket::readyRead, this, &myThread::clientHandle);
}

5、创建处理接收到来自客户端数据的槽函数

private slots:
    void clientHandle();     //处理来自客户端信息
//处理来自客户端的信息
void myThread::clientHandle()
{
   
    QByteArray data = socket->readAll();     // 使用 socket 成员变量读取所有可用的数据
    emit sendToServer(data);      // 发射 sendToServer 信号,并传递从 socket 读取到的数据
}

6、自定义一个信号用来把数据发送出去

signals:
    // 自定义信号 sendToServer,向服务器发送QByteArray 类型的数据
    void sendToServer(QByteArray data);
//处理来自客户端的信息
void myThread::clientHandle()
{
    QByteArray data = socket->readAll();     // 使用 socket 成员变量读取所有可用的数据
    emit sendToServer(data);      // 发射 sendToServer 信号,并传递从 socket 读取到的数据给服务器
}

7、Widget接收信号

//处理sendToServer信号
connect(t,&myThread::sendToServer, this, &Widget::threadHandle);

8、创建处理sendToServer信号的槽函数

void threadHandle(QByteArray data);     //处理sendToWidget信号的槽函数
//处理sendToServer信号
void Widget::threadHandle(QByteArray data)
{
    ui->serverRevtextEdit->setText(QString(data));     //显示接收到的数据
}

9、.h文件和.cpp文件

9.1 mythread.h

mythread.h

#ifndef MYTHREAD_H
#define MYTHREAD_H

#include <QObject>
#include <QThread>
#include <QTcpSocket>

// 定义 myThread 类,继承自 QThread 类,用于创建处理客户端连接的独立线程
class myThread : public QThread
{
    Q_OBJECT
public:
    // 显式构造函数,接受一个 QTcpSocket 指针参数 s,用于初始化 socket 成员变量
    explicit myThread(QTcpSocket *s);

    void run() override;        //线程处理函数

signals:
    // 自定义信号 sendToServer,向服务器发送QByteArray 类型的数据
    void sendToServer(QByteArray data);

private slots:
    void clientHandle();     //处理来自客户端信息

private:
    QTcpSocket *socket;      //创建网络通信对象,用来接受参数传递


};

#endif // MYTHREAD_H

9.2 mythread.cpp

mythread.cpp

#include "mythread.h"

myThread::myThread(QTcpSocket *s)
{
    socket = s;
}

void myThread::run()
{
    //当有数据可读时,readyRead 信号被触发
    connect(socket, &QTcpSocket::readyRead, this, &myThread::clientHandle);
}

//处理来自客户端的信息
void myThread::clientHandle()
{
    QByteArray data = socket->readAll();     // 使用 socket 成员变量读取所有可用的数据
    emit sendToServer(data);      // 发射 sendToServer 信号,并传递从 socket 读取到的数据给服务器
}

9.3 Widget.h

Widget.h

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include <QTcpServer>
#include <QTcpSocket>
#include <mythread.h>

#define PORT 8000

QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
    Q_OBJECT

public:
    Widget(QWidget *parent = nullptr);
    ~Widget();

private slots:
    void newClientHandler();        //服务器处理

    //void serverRevMessage();        //服务器读取

    void threadHandle(QByteArray data);     //处理sendToWidget信号的槽函数

private:
    Ui::Widget *ui;

    QTcpServer *server;         //定义服务器对象
};
#endif // WIDGET_H

9.4Widget.cpp

Widget.cpp

#include "widget.h"
#include "ui_widget.h"

Widget::Widget(QWidget *parent)
    : QWidget(parent)
    , ui(new Ui::Widget)
{
    ui->setupUi(this);

    server = new QTcpServer(this);

    server->listen(QHostAddress::AnyIPv4,PORT);

    //有新的客户端连接,会发出信号
    connect(server,&QTcpServer::newConnection,this, &Widget::newClientHandler);

}

Widget::~Widget()
{
    delete ui;
}

void Widget::newClientHandler()
{
    QTcpSocket *socket = server->nextPendingConnection();

    socket->peerAddress();
    socket->peerPort();

    ui->serveripLineEdit->setText((socket->peerAddress()).toString());
    ui->serverportLineEdit->setText(QString::number(socket->peerPort()));

    //服务器收到客户端发送的信息,sockket发出readyread信号
//    connect(socket,&QTcpSocket::readyRead, this, &Widget::serverRevMessage);

    //启动线程
    myThread *t = new myThread(socket);     //创建线程对象
    t->start();                     //开始线程

    //处理sendToServer信号
    connect(t,&myThread::sendToServer, this, &Widget::threadHandle);

}

//处理sendToServer信号
void Widget::threadHandle(QByteArray data)
{
    ui->serverRevtextEdit->setText(QString(data));     //显示接收到的数据
}

//服务器读取
/*
void Widget::serverRevMessage()
{
    QTcpSocket *clientsocket = (QTcpSocket *)sender();
    ui->serverRevtextEdit->setText(clientsocket->readAll());
}
*/

10、总结

以上就是Qt实现多线程的整个过程了,浏览过程中,如若发现错误,欢迎大家指正,有

问题的可以评论区留言或者私信。 最后,如果大家觉得有所帮助的话,可以点个赞,谢

谢大家!永远相信美好的事情即将发生!
Qt实现多线程完成!

http://www.kler.cn/a/587014.html

相关文章:

  • vscode python相对路径的问题
  • 3.6、数字签名
  • Ollama+OpenWebUI本地部署大模型
  • nvm安装node失败的处理方法
  • @RequestParam、@RequestBody、@PathVariable
  • DeepSeek技术解析:MoE架构实现与代码实战
  • 十种处理权重矩阵的方法及数学公式
  • Java注解对象克隆
  • 元音辅音字符串计数leetcode3305,3306
  • 自然语言秒转SQL—— 免费体验 OB Cloud Text2SQL 数据查询
  • 软件行业的“3.15问题”有哪些?如何防止?
  • C++ unordered_map unordered_set 模拟实现
  • Certbot实现SSL免费证书自动续签(CentOS 7版 + Docker部署的nginx)
  • 测试工程师指南:基于需求文档构建本地安全知识库的完整实战
  • HarmonyOS第24天:鸿蒙应用安全秘籍:如何为用户数据筑牢防线?
  • 使用Python实现经典贪吃蛇游戏教程
  • python相关语法的学习文档1
  • 4.3 计算属性与watch的类型守卫实现
  • 软考高级《系统架构设计师》知识点(十三)
  • Day2 导论 之 「存储器,IO,微机工作原理」