int main(int argc, char *argv[]){ QApplication a(argc, argv); Widget w; w.show(); return a.exec();}主线程Widget.h文件#ifndef WIDGET_H#define WIDGET_H#include
devbox
我家自动化
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Qt搭建多线程服务器_qwebserver多线程

作者：我家自动化 | 2024-03-04 11:11:43

赞

踩

qwebserver多线程

main.cpp 文件

  1. #include "Widget.h"
  2.  
  3. #include <QApplication>
  4.  
  5. int main(int argc, char *argv[])
  6. {
  7.     QApplication a(argc, argv);
  8.     Widget w;
  9.     w.show();
  10.     return a.exec();
  11. }

主线程

Widget.h文件

  1. #ifndef WIDGET_H
  2. #define WIDGET_H
  3.  
  4. #include <QWidget>
  5. #include <QListWidget>
  6. #include <QPushButton>
  7. #include <QLabel>
  8. #include <QThread>
  9. #include "Work.h"
  10.  
  11. class Widget : public QWidget
  12. {
  13.     Q_OBJECT
  14.  
  15. public:
  16.     Widget(QWidget *parent = nullptr);
  17.  
  18.     ~Widget();
  19.  
  20. private:
  21.     void init();
  22.     void rcvListenData(QString strData, QString strBtnData);
  23.     void rcvConnectData(QString strData, QString strBtnData);
  24.     void rcvMsg(QString strData, QString strBtnData);
  25. private:
  26.     QListWidget* m_pList;
  27.     QLabel* m_pLbListen;
  28.     QPushButton* m_pBtn;
  29.  
  30.     Work* m_pWork;
  31.     QThread* m_pThread;
  32.  
  33. signals:
  34.     void operate(bool bClose = false);
  35. public slots:
  36.     void onRcvData(Work::MsgTag tag, QString strData, QString strBtnData = "close listen");
  37.  
  38.  
  39. };
  40. #endif // WIDGET_H

Widget.cpp文件

  1. #include "Widget.h"
  2. #include <QPluginLoader>
  3. #include <QDebug>
  4. #include <QVBoxLayout>
  5. #include <QHBoxLayout>
  6. #include <QDesktopWidget>
  7.  
  8. Widget::Widget(QWidget *parent)
  9.     : QWidget(parent)
  10. {
  11.     init();
  12.     m_pThread = new QThread(this);
  13.     m_pWork = new Work();
  14.     m_pThread->start();
  15.     connect(m_pThread, &QThread::finished, m_pWork, &Work::deleteLater);
  16.     connect(this, &Widget::operate, m_pWork, &Work::OnWork);
  17.     connect(m_pWork, &Work::sigToMainThread, this, &Widget::onRcvData);
  18.     m_pWork->moveToThread(m_pThread);
  19.     this->setWindowTitle(tr("server"));  
  20. }
  21.  
  22. Widget::~Widget()
  23. {
  24.     m_pThread->quit();
  25.     m_pThread->wait();
  26. }
  27.  
  28. void Widget::init()
  29. {
  30.     QDesktopWidget destWidget;
  31.     int nHight = destWidget.geometry().height();
  32.     int nWidth = destWidget.geometry().width();
  33.     this->resize(nWidth/2, nHight/2);
  34.     m_pList = new QListWidget;
  35.     m_pBtn = new QPushButton(tr("start listen"));
  36.     m_pLbListen = new QLabel(tr(""));
  37.     connect(m_pBtn, &QPushButton::clicked, [&]{
  38.         if(m_pBtn->text() == tr("start listen"))
  39.             emit operate(false);
  40.         else
  41.             emit operate(true);
  42.     });
  43.     QHBoxLayout* pHBtnLayout = new QHBoxLayout;
  44.     pHBtnLayout->addWidget(m_pLbListen);
  45.     pHBtnLayout->addWidget(m_pBtn);
  46.  
  47.     QHBoxLayout* pHListLayout = new QHBoxLayout;
  48.     pHListLayout->addWidget(m_pList);
  49.  
  50.     QVBoxLayout* pVMainLayout = new QVBoxLayout;
  51.     pVMainLayout->addLayout(pHListLayout);
  52.     pVMainLayout->addLayout(pHBtnLayout);
  53.     this->setLayout(pVMainLayout);
  54. }
  55.  
  56. void Widget::rcvListenData(QString strData, QString strBtnData)
  57. {
  58.     m_pBtn->setText(strBtnData);
  59.     m_pLbListen->setText(strData);
  60. }
  61.  
  62. void Widget::rcvConnectData(QString strData, QString strBtnData)
  63. {
  64.     m_pBtn->setText(strBtnData);
  65.     QListWidgetItem* pItem = new QListWidgetItem(strData);
  66.     m_pList->addItem(pItem);
  67. }
  68.  
  69. void Widget::rcvMsg(QString strData, QString strBtnData)
  70. {
  71.     m_pBtn->setText(strBtnData);
  72.     QListWidgetItem* pItem = new QListWidgetItem(strData);
  73.     m_pList->addItem(pItem);
  74. }
  75.  
  76.  
  77.  
  78. void Widget::onRcvData(Work::MsgTag tag, QString strData, QString strBtnData)
  79. {
  80.     qDebug() << strBtnData;
  81.     switch(tag)
  82.     {
  83.     case Work::ID_Listen:
  84.         rcvListenData(strData,strBtnData);
  85.         break;
  86.     case Work::ID_Conect:
  87.         rcvConnectData(strData, strBtnData);
  88.         break;
  89.     case Work::ID_Msg:
  90.         rcvMsg(strData, strBtnData);
  91.         break;
  92.     default:
  93.         break;
  94.     }
  95. }
  96.

工作线程

Work.h文件

  1. #ifndef WORK_H
  2. #define WORK_H
  3.  
  4. #include <QObject>
  5. #include <QWidget>
  6. //监听套接字
  7. #include <QTcpServer>
  8.  
  9.  
  10. class Work : public QObject
  11. {
  12.     Q_OBJECT
  13. public:
  14.     enum MsgTag
  15.     {
  16.         ID_Listen,  //监听
  17.         ID_Conect,  //连接
  18.         ID_Msg      //信息
  19.     };
  20.     Q_ENUM(MsgTag)
  21.  
  22.     explicit Work(QObject *parent = nullptr);
  23. private:
  24.     void serverConnect();
  25.     void serverDisconnect();
  26. private:
  27.     QTcpServer* m_pTcpServer;
  28.     QSet<QTcpSocket*> m_SetSock;
  29.  
  30.  
  31. signals:
  32.     void sigToMainThread(Work::MsgTag tag, QString strData, QString strBtn = "close Listen");
  33. public slots:
  34.     void OnWork(bool bClose);
  35.     void onRecvData(QTcpSocket* pSocket);
  36.     void onDisconnect(QTcpSocket *pSocket);
  37. };
  38.  
  39. #endif // WORK_H

Work.cpp

  1. #include "Work.h"
  2. #include <QTextCodec>
  3. #include <QDebug>
  4. #include <QTcpSocket>
  5.  
  6. Work::Work(QObject *parent) : QObject(parent)
  7. {
  8.     qRegisterMetaType<MsgTag>();
  9.     m_pTcpServer = new QTcpServer(this);
  10.     connect(m_pTcpServer, &QTcpServer::newConnection, [=]{
  11.         QTcpSocket* pSocket = m_pTcpServer->nextPendingConnection();
  12.         //获取客户端的Ip和端口
  13.         qint32 ip = pSocket->peerAddress().toIPv4Address();
  14.         QString strIP = QHostAddress(ip).toString();
  15.         QString strPort = QString::number(pSocket->peerPort());
  16.         m_SetSock.insert(pSocket);
  17.         qDebug() << m_SetSock.count();
  18.         QString connectText = "IP:" + strIP + "," + "Port:" + strPort + "connect server !";
  19.         emit sigToMainThread(ID_Conect, connectText);
  20.         connect(pSocket, &QTcpSocket::readyRead, [=]{
  21.             QByteArray byteArry;
  22.             byteArry =  pSocket->readAll();
  23.             qint32 ip = pSocket->peerAddress().toIPv4Address();
  24.             QString strIP = QHostAddress(ip).toString();
  25.             uint port = pSocket->peerPort();
  26.             //防止中文乱码
  27.             QTextCodec *tc = QTextCodec::codecForName("GBK");
  28.             QString strTotalData = strIP + QString::number(port) + ":" + tc->toUnicode(byteArry);
  29.             emit sigToMainThread(ID_Msg,  strTotalData);
  30.         });
  31.         connect(pSocket, &QTcpSocket::disconnected, this, [=]{
  32.             qint32 ip = pSocket->peerAddress().toIPv4Address();
  33.             QString strIP = QHostAddress(ip).toString();
  34.             QString strTotal = strIP + ":" + "disconnect !";
  35.             emit sigToMainThread(ID_Msg, strTotal);
  36.         });
  37.     });
  38. }
  39.  
  40. void Work::OnWork(bool bClose)
  41. {
  42.     if(!bClose)
  43.         serverConnect();
  44.     else
  45.         serverDisconnect();
  46. }
  47.  
  48. void Work::onRecvData(QTcpSocket *pSocket)
  49. {
  50.     QByteArray byteArry;
  51.     byteArry =  pSocket->readAll();
  52.     qint32 ip = pSocket->peerAddress().toIPv4Address();
  53.     QString strIP = QHostAddress(ip).toString();
  54.     uint port = pSocket->peerPort();
  55.     //防止中文乱码
  56.     QTextCodec *tc = QTextCodec::codecForName("GBK");
  57.     QString strTotalData = strIP + QString::number(port) + ":" + tc->toUnicode(byteArry);
  58.     emit sigToMainThread(ID_Msg,  strTotalData);
  59. }
  60.  
  61. void Work::onDisconnect(QTcpSocket *pSocket)
  62. {
  63.     qint32 ip = pSocket->peerAddress().toIPv4Address();
  64.     QString strIP = QHostAddress(ip).toString();
  65.     QString strTotal = strIP + ":" + "disconnect !";
  66.     emit sigToMainThread(ID_Msg, strTotal);
  67. }
  68. void Work::serverConnect()
  69. {
  70.     if(! m_pTcpServer->listen(QHostAddress::Any, 666))
  71.         emit sigToMainThread(ID_Listen, "listen failed", "start Listen");
  72.     else
  73.         emit sigToMainThread(ID_Listen, "listening...");
  74. }
  75.  
  76. void Work::serverDisconnect()
  77. {
  78.     m_pTcpServer->close();
  79.     if(! m_pTcpServer->isListening())
  80.         emit sigToMainThread(ID_Listen, "server disconnect !", "start listen");
  81.     else
  82.         emit sigToMainThread(ID_Listen, "server disconnect fauiled!");
  83. }

下面补上客户端代码：

main.cpp文件

  1. #include "Widget.h"
  2.  
  3. #include <QApplication>
  4.  
  5. int main(int argc, char *argv[])
  6. {
  7.     QApplication a(argc, argv);    
  8.     Widget w;
  9.     w.show();
  10.     return a.exec();
  11. }

Widget.h文件

  1. #ifndef WIDGET_H
  2. #define WIDGET_H
  3.  
  4. #include <QWidget>
  5. #include <QTcpSocket>
  6. #include <QLabel>
  7. #include <QPushButton>
  8. #include <QLineEdit>
  9.  
  10. class Widget : public QWidget
  11. {
  12.     Q_OBJECT
  13.  
  14. public:
  15.     Widget(QWidget *parent = nullptr);
  16.     ~Widget();
  17. private:
  18.     void init();
  19. private:
  20.     QTcpSocket* m_pTcpSocket;
  21.     QPushButton* m_pBtnConnect;
  22.     QLabel* m_pLbIP;
  23.     QLabel* m_pLbPort;
  24.     QLineEdit* m_pLineIP;
  25.     QLineEdit* m_pLinePort;
  26.  
  27.     bool m_bOnLine;
  28.  
  29. public slots:
  30.     void onReadData();
  31.     void onSocketError(QAbstractSocket:: SocketError nError);
  32.     void onConnectClicked();
  33.     void onConnected();
  34.     void onDisConnected();
  35. };
  36. #endif // WIDGET_H
  37.

widget.cpp

  1. #include "Widget.h"
  2. #include <QHBoxLayout>
  3. #include <QVBoxLayout>
  4. #include <QDesktopWidget>
  5. #include <QTextCodec>
  6.  
  7. Widget::Widget(QWidget *parent)
  8.     : QWidget(parent)
  9. {
  10.     QDesktopWidget* pWidget = new QDesktopWidget;
  11.     int nWidth = pWidget->geometry().width();
  12.     int nHight = pWidget->geometry().height();
  13.     this->resize(nWidth/2, nHight/2);
  14.     setWindowTitle("client");
  15.     m_pTcpSocket = new QTcpSocket(this);
  16.     m_bOnLine = false;
  17.     init();
  18.     connect(m_pTcpSocket, &QTcpSocket::connected, this, &Widget::onConnected);
  19.     connect(m_pTcpSocket, &QTcpSocket::readyRead, this, &Widget::onReadData);
  20.     connect(m_pTcpSocket, &QTcpSocket::disconnected, this, &Widget::onDisConnected);
  21.     connect(m_pTcpSocket, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(onSocketError(QAbstractSocket::SocketError)));
  22. }
  23.  
  24. Widget::~Widget()
  25. {
  26. }
  27.  
  28. void Widget::init()
  29. {
  30.     m_pLbIP = new QLabel(tr("IP:"));
  31.     m_pLbPort = new QLabel(tr("Port:"));
  32.     m_pLineIP = new QLineEdit;
  33.     m_pLinePort = new QLineEdit;
  34.     m_pBtnConnect = new QPushButton(tr("连接"));
  35.     connect(m_pBtnConnect, &QPushButton::clicked, this, &Widget::onConnectClicked);
  36.     QHBoxLayout* pHIpLayout = new QHBoxLayout;
  37.     pHIpLayout->addWidget(m_pLbIP);
  38.     pHIpLayout->addWidget(m_pLineIP);
  39.     QHBoxLayout* pHPortLayout = new QHBoxLayout;
  40.     pHPortLayout->addWidget(m_pLbPort);
  41.     pHPortLayout->addWidget(m_pLinePort);
  42.     QHBoxLayout* pHBtnLayout = new QHBoxLayout;
  43.     pHBtnLayout->addStretch();
  44.     pHBtnLayout->addWidget(m_pBtnConnect);
  45.     QVBoxLayout* pVMainLayout = new QVBoxLayout;
  46.     pVMainLayout->addLayout(pHIpLayout);
  47.     pVMainLayout->addLayout(pHPortLayout);
  48.     pVMainLayout->addLayout(pHBtnLayout);
  49.     this->setLayout(pVMainLayout);
  50. }
  51.  
  52. void Widget::onReadData()
  53. {
  54.     if(m_pTcpSocket->bytesAvailable())
  55.     {
  56.         QByteArray buf = m_pTcpSocket->readAll();
  57.         QTextCodec *tc = QTextCodec::codecForName("GBK");
  58.         QString strTotalData =tc->toUnicode(buf);
  59.         qDebug() << strTotalData;
  60.     }
  61. }
  62.  
  63. void Widget::onSocketError(QAbstractSocket::SocketError nError)
  64. {
  65.     qDebug() << "Error ID:" + QString::number(nError);
  66. }
  67.  
  68. void Widget::onConnectClicked()
  69. {
  70.     if(! m_bOnLine)
  71.     {
  72.         QString strIp = m_pLineIP->text();
  73.         QString strPort = m_pLinePort->text();
  74.         m_pTcpSocket->connectToHost(strIp,strPort.toShort());
  75.     }
  76.     else
  77.     {
  78.         m_bOnLine = false;
  79.         m_pTcpSocket->disconnectFromHost();
  80.         m_pBtnConnect->setText("连接");
  81.     }
  82. }
  83.  
  84. void Widget::onConnected()
  85. {
  86.     qDebug() << "连接服务器成功！";
  87.     m_bOnLine = true;
  88.     m_pBtnConnect->setText(tr("断开连接"));
  89. }
  90.  
  91. void Widget::onDisConnected()
  92. {
  93.     qDebug() << "已断开与服务器的连接！";
  94.     m_bOnLine = false;
  95.     m_pBtnConnect->setText(tr("连接"));
  96. }

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家自动化/article/detail/187358
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。