Qt实现简易的多线程TCP服务器（附源码）

风雨同行  金牌会员 | 2024-6-8 09:32:52 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 511|帖子 511|积分 1533

目录
一.UI界面的设计
二.服务器的启动
三.实现自界说的TcpServer类
1.在widget中声明自界说TcpServer类的成员变量
2.在TcpServer的构造函数中对于我们声明的m_widget进行初始化，m_widget我们用于后续的显示消息等，说白了就是主界面的更新显示等
四.实现自界说的TcpSocket类
1.TcpSocket.h   先忽略掉信号与槽函数，关注构造函数与qintptr类型的 m_sockDesc
五.实现自界说线程类
1.主要关注run函数，其中run函数是继承QThread中的虚函数，必要我们进行重写
2.实现某个客户端断开连接时通过信号与槽让主界面改变
3.实现有新的客户端连接时主界面更新
六.服务器收到多客户端消息进行显示的流程实现
七.服务器发送消息给某个客户端流程
八.服务器发送信息后，要在主页面信息消息更新显示的流程
注意：
效果演示：
源码下载地址：

在初学Qt 中Tcp服务器与客户端的时候，发现每次服务器只能和最后一个连接的客户端进行通信，由于没有用到多线程以及TcpServer中虚函数incomingConnection（），当新的客户端连接的时候，会主动调用incomingConnection函数，在里面产生新的线程来处理通信。
以下来讲讲这个简易的多线程Tcp服务器的实现
一.UI界面的设计


其中包括2个Label，一个LineEdit，两个pushbutton，上面是一个TextBrowser用于服务器显示通信记录，下面一个TextEdit用于发送信息。如许一个简朴的界面就搭建完成了~~~

二.服务器的启动

首先我们肯定必要实现点击启动服务器按钮来启动服务器

1.在界面中右击启动按钮 ----> 转到槽

2.实现逻辑，这里直接放代码，其中serverisworking 是我在widget.h 中声明的一个bool类型，用于判断服务器是否启动，同时更改按钮的文本显示内容，以及弹出对话框提示。
  1. //点击开始启动服务器
  2. void Widget::on_pushButton_StartServer_clicked()
  3. {
  4.     //如果服务器没有启动
  5.      if (!this->serverisworking) {
  6.         if(this->m_tcpserver->listen(QHostAddress::Any,ui->lineEdit_Port->text().toUShort())){
  7.             QMessageBox::information(this,"成功！","启动成功！");
  8.             ui->pushButton_StartServer->setText("关闭服务器");
  9.             this->serverisworking = true;
  10.         }
  11.         else {
  12.             QMessageBox::critical(this,"失败!","服务器启动失败请检查设置!");
  13.         }
  14.     }
  15.     //如果服务器正在启动
  16.      else if(this->serverisworking) {
  17.          m_tcpserver->close();
  18.          if(!m_tcpserver->isListening()){
  19.              ui->pushButton_StartServer->setText("启动服务器");
  20.              this->serverisworking = false;
  21.              QMessageBox::information(this,"提示","关闭成功!");
  22.          }
  23.          else {
  24.              QMessageBox::critical(this,"错误","关闭失败,请重试！");
  25.              return;
  26.          }
  28.      }
  29. }
复制代码
三.实现自界说的TcpServer类

1.首先我们搞清晰，这个类是负责干嘛的？这个类我们要继承QTcpServer，重写虚函数incomingConnetion
2.这是头文件，如果有报错，注意看利用#pragma once没有，由于大概涉及到头文件重复包罗
  1. //tcpserver.h
  2. #pragma once
  3. #ifndef TCPSERVER_H
  4. #define TCPSERVER_H
  6. #include <QObject>
  7. #include<QTcpServer>
  9. #include <widget.h>
  10. #include"serverthread.h"
  12. class TcpServer : public QTcpServer
  13. {
  14.     Q_OBJECT
  15. public:
  16.     explicit TcpServer(QObject *parent = nullptr);
  18. private:
  20.     //重写虚函数
  21.     void incomingConnection(qintptr sockDesc);
  23. private:
  24.    
  25.     //用来保存连接进来的套接字，存到ComboBox中
  26.     QList<qintptr> m_socketList;
  27.    
  28.     //再包含一个widget对象
  29.     Widget *m_widget;
  31. };
  33. #endif // TCPSERVER_H
复制代码
1.在widget中声明自界说TcpServer类的成员变量

  1. //widget.h
  2. #pragma once
  3. #ifndef WIDGET_H
  4. #define WIDGET_H
  6. #include <QWidget>
  7. #include<QMessageBox>
  8. #include"tcpserver.h"
  10. namespace Ui {
  11. class Widget;
  12. }
  14. class TcpServer;
  16. class Widget : public QWidget
  17. {
  18.     Q_OBJECT
  20. public:
  21.     explicit Widget(QWidget *parent = nullptr);
  22.     ~Widget();
  24. public:
  25.     //当有新连接的时候在页面上显示
  26.     void showNewConnection(qintptr sockDesc);
  28.     //断开时显示
  29.     void showDisconnection(qintptr sockDesc);
  31.     //当服务器发送消息后，通知窗口更新消息
  32.     void UpdateServerMsg(qintptr Desc,const QByteArray &msg);
  35. private slots:
  37.     //按钮被触发
  38.     void on_pushButton_StartServer_clicked();
  40.     void on_pushButton_Trans_clicked();
  43. public slots:
  45.     //当服务器收到客户端发送的消息后，更新消息
  46.     void RecvMsg(QString Desc,const QByteArray &msg);
  49. signals :
  50.    void  sendData(qintptr Desc ,const QByteArray &msg);
  52. private:
  53.     Ui::Widget *ui;
  55.     TcpServer *m_tcpserver;
  57.     bool serverisworking;
  58. };
  60. #endif // WIDGET_H
复制代码
其他的我们先不去讨论，这里我们就声明一个TcpServer类型的m_tcpserver 以及一个bool类型的serverisworking用来判断服务器是否在工作
2.在TcpServer的构造函数中对于我们声明的m_widget进行初始化，m_widget我们用于后续的显示消息等，说白了就是主界面的更新显示等

  1. TcpServer::TcpServer(QObject *parent) : QTcpServer(parent)
  2. {
  3.      m_widget = dynamic_cast<Widget *>(parent);
  5. }
复制代码

那么，问题来了，我们要重写TcpServer的incomingConnection函数，里面要涉及到线程，那么我们必要去写一个自界说的线程类
  1. //当有新的连接进来的时候会自动调用这个函数，不需要你去绑定信号槽
  2. void TcpServer::incomingConnection(qintptr sockDesc)
  3. {
  4.     //将标识符保存进list
  5.     m_socketList.append(sockDesc);
  7.     //产生线程用于通信
  8.     ServerThread *thread = new ServerThread(sockDesc);
  10.     //窗口中显示有新的连接
  11.     m_widget->showNewConnection(sockDesc);
  13.     //线程中发出断开tcp连接，触发widget中显示断开
  14.     connect(thread, &ServerThread::disconnectTCP, this,[=]{
  15.          m_widget->showDisconnection(sockDesc);
  16.     });
  20.     //当socket 底层有readyread信号的时候  -> 发送socket_getmsg信号  -> 发送socket_getmsg_thread
  21.     //将socket_getmsg_thread 与 widget中 RecvMsg 绑定，RecvMsg 用于处理将收到的消息进行显示
  22.     connect(thread,&ServerThread::socket_getmsg_thread,this->m_widget,&Widget::RecvMsg);
  24.     //当点击发送的时候-> 产生一个SendData 信号  -> 调用线程中SendDataSlot函数用于发送sendData信号来使socket来发送消息
  25.     connect(this->m_widget,&Widget::sendData,thread,&ServerThread::sendDataSlot);
  27.     //当服务器给客户端发送下消息后，会产生一个writeover信号-> 触发线程发送writeover信号给 Tcpserver -> Tcpserver中widget更新消息
  28.     connect(thread,&ServerThread::writeover,[=](qintptr Desc,const QByteArray &msg){
  29.            m_widget->UpdateServerMsg(Desc,msg);
  30.     });
  33.     thread->start();
  34. }
复制代码

我们要实现线程类，线程的工作是必要每个线程里面都有一个不同的Tcpsocket类实例，但是我们要在不同的线程里面 工作不同的socket，那么我们可以在一个线程中 去利用套接字标识符（socketDesc）去区分不同的套接字，然后服务器也可以通过不同的套接字标识符去进行与不同的套接字进行通信，以是我们必要先去实现一个自界说的TcpSocket类
四.实现自界说的TcpSocket类

1.TcpSocket.h   先忽略掉信号与槽函数，关注构造函数与qintptr类型的 m_sockDesc

为什么是qintptr类型呢，我们查看官方文档，利用qintpt类型作为参数更方便，

  1. #pragma once
  2. #ifndef SERVERSOCKET_H
  3. #define SERVERSOCKET_H
  5. #include <QObject>
  6. #include<QTcpSocket>
  10. class ServerSocket : public QTcpSocket
  11. {
  12.     Q_OBJECT
  13. public:
  14.     explicit ServerSocket(qintptr socketDesc,QObject *parent = nullptr);
  16. signals:
  17.     void socket_getmsg(QString Desc, const QByteArray &msg);
  19.      void writeover(qintptr Desc,const QByteArray &msg);
  21. public slots:
  22.     void sendData(qintptr Desc, const QByteArray &data);
  24. private:
  25.         qintptr m_sockDesc;
  26. };
  28. #endif // SERVERSOCKET_H
复制代码
五.实现自界说线程类

1.主要关注run函数，其中run函数是继承QThread中的虚函数，必要我们进行重写

  1. //serverthread.h
  2. #pragma once
  3. #ifndef SERVERTHREAD_H
  4. #define SERVERTHREAD_H
  6. #include <QObject>
  8. #include <QThread>
  9. #include<serversocket.h>
  11. class ServerThread : public QThread
  12. {
  13.     Q_OBJECT
  14. public:
  16.     //构造函数初始化套接字标识符
  17.     explicit ServerThread(qintptr sockDesc,QObject *parent = nullptr);
  19.     void run() override;
  21.     ~ServerThread();
  23. signals:
  24.     void disconnectTCP(qintptr m_sockDesc);
  26.     void sendData(qintptr Desc, const QByteArray& msg);
  28.     void socket_getmsg_thread(QString Desc,const QByteArray &msg);
  30.     void  writeover(qintptr Desc,const QByteArray &msg);
  32. public  slots:
  33.     void sendDataSlot(qintptr Desc, const QByteArray& msg);
  37. private:
  38.     qintptr m_socketDesc;
  40.     ServerSocket *m_socket;
  42. };
  46. #endif // SERVERTHREAD_H
复制代码
2.实现某个客户端断开连接时通过信号与槽让主界面改变

1）我们在run函数中，实在就是对某个对应的用来通信套接字运行一个线程，以是我们在run中，先对m_socket进行初始化，将自身的m_socketDesc 作为参数传给m_socket的有参构造。而且利用TcpSocket的setSocketDescriptor方法对m_socket进行绑定标识符，如许我们每个线程内工作的套接字都是不同的
  1.   m_socket = new ServerSocket(this->m_socketDesc);
  3.     //绑定套接字标识符绑定给自定义套接字对象
  4.     if (!m_socket->setSocketDescriptor(this->m_socketDesc)) {
  5.         return ;
  6.     }
复制代码
2）在线程中，当该线程中的套接字断开时，底层会发射出disconnected信号，我们线程可以此信号与一个用来发射信号的槽函数绑定起来，实现当套接字发送disconnect信号的时候，线程发射出一个disconnectTcp如许一个自界说信号关照服务器套接字断开，server在调用widget成员的方法实现在主界面中显示断开连接

  1. //run()中：
  2.     //当套接字断开时，发送底层的disconnected信号
  3.     connect(m_socket, &ServerSocket::disconnected, this, [=]{
  5.         //此信号可以出发server的槽函数然后再调用widget中combobox清除该socketDesc
  6.         emit disconnectTCP(this->m_socketDesc);
  8.         //让该线程中的套接字断开连接
  9.         m_socket->disconnectFromHost();//断开连接
  11.         //线程退出
  12.         this->quit();
  13.    
复制代码

  1. //incommingConnection中
  2.   //线程中发出断开tcp连接，触发widget中显示断开
  3.     connect(thread, &ServerThread::disconnectTCP, this,[=]{
  4.          m_widget->showDisconnection(sockDesc);
  5.     });
复制代码
  1. //widget.cpp中
  2. //用以显示连接断开
  3. void Widget::showDisconnection(qintptr sockDesc)
  4. {
  5.     ui->textBrowser_ServerMess->append(QString::number(sockDesc)+"断开了连接");
  6.    
  7.     //通过信号传递的标识符，将其删除
  8.     int index = ui->comboBox_CilentID->findData(sockDesc);
  10.     ui->comboBox_CilentID->removeItem(index);
  11. }
复制代码
3.实现有新的客户端连接时主界面更新

当有新的客户端连接的时候，会主动调用server中的incommingConnect函数，直接在此函数中调用widget->showNewconnection函数
  1. //incomingConnection函数中:
  2.     //窗口中显示有新的连接
  3.     m_widget->showNewConnection(sockDesc);
复制代码
  1. //widget.cpp
  2. void Widget::showNewConnection(qintptr sockDesc)
  3. {
  4.     ui->textBrowser_ServerMess->append("有新的连接！，新接入"+QString::number(sockDesc));
  5.     ui->comboBox_CilentID->addItem(QString("%1").arg(sockDesc), sockDesc);
  6. }
复制代码
 通过这两个连接就可以直接实现有新的客户端连接时主界面更新。

六.服务器收到多客户端消息进行显示的流程实现


  1. //serversocket.cpp
  2. ServerSocket::ServerSocket(qintptr socketDesc,QObject *parent) : QTcpSocket(parent)
  3. {
  4.     this->m_sockDesc = socketDesc;
  7.     connect(this,&ServerSocket::readyRead,this,[=]{
  9.         QString name = QString::number(m_sockDesc);
  11.         QByteArray msg = readAll();
  13.         emit socket_getmsg(name,msg);
  15.     });
  16. }
复制代码
  1. //serverthread::run()中
  2.     //套接字发出有消息的信号，然后触发线程中发出有消息的信号
  3.     connect(m_socket, &ServerSocket::socket_getmsg, this,[=](QString Desc,const QByteArray &msg){
  6.                 emit socket_getmsg_thread(Desc,msg);
  8.     });
复制代码
  1. //server.cpp
  2.    //当socket 底层有readyread信号的时候  -> 发送socket_getmsg信号  -> 发送socket_getmsg_thread
  3.     //将socket_getmsg_thread 与 widget中 RecvMsg 绑定，RecvMsg 用于处理将收到的消息进行显示
  4.     connect(thread,&ServerThread::socket_getmsg_thread,this->m_widget,&Widget::RecvMsg);
复制代码
  1. //widget.cpp
  2. //当客户端发送消息，服务器收到后，显示消息
  3. void Widget::RecvMsg(QString Desc,const QByteArray &msg)
  4. {
  5.     ui->textBrowser_ServerMess->append(Desc+":"+msg);
  6. }
复制代码
实现收到客户端消息进行显示

七.服务器发送消息给某个客户端流程


  1. void Widget::on_pushButton_Trans_clicked()
  2. {
  3.     if(serverisworking){
  5.         //如果连接个数大于0，发送发送消息的信号
  6.         if(ui->comboBox_CilentID->count() >0)
  7.         {
  8.             //发射 发送信号
  9.             emit sendData( ui->comboBox_CilentID->currentText().toInt(), ui->textEdit_SendMess->toPlainText().toUtf8());
  10.             qDebug()<<"发送了sendData信号"<<endl;
  11.             ui->textEdit_SendMess->clear();
  12.         }
  14.     }
  15.     else {
  16.         QMessageBox::critical(this,"错误","请检查连接");
  17.         return;
  18.     }
  20. }
复制代码
  1. //Tcpserver.cpp  incomingConnection中
  2.     //当点击发送的时候-> 产生一个SendData 信号  -> 调用线程中SendDataSlot函数用于发送sendData信号来使socket来发送消息
  3.     connect(this->m_widget,&Widget::sendData,thread,&ServerThread::sendDataSlot);
复制代码
  1. void ServerThread::sendDataSlot(qintptr Desc, const QByteArray &msg)
  2. {
  4.      emit sendData(Desc, msg);
  5. }
复制代码
  1. //run（）中
  2.    connect(this,&ServerThread::sendData,m_socket,&ServerSocket::sendData);
复制代码
  1. void ServerSocket::sendData(qintptr Desc, const QByteArray &msg)
  2. {
  3.     if (Desc == m_sockDesc && !msg.isEmpty()) {
  4.         this->write(msg);
  6.         //发送完毕，发出信号，通知主页面更新聊天框
  7.         emit writeover(Desc,msg);
  8.     }
  9. }
复制代码


八.服务器发送信息后，要在主页面信息消息更新显示的流程


  1. void ServerSocket::sendData(qintptr Desc, const QByteArray &msg)
  2. {
  3.     if (Desc == m_sockDesc && !msg.isEmpty()) {
  4.         this->write(msg);
  6.         //发送完毕，发出信号，通知主页面更新聊天框
  7.         emit writeover(Desc,msg);
  8.     }
  9. }
复制代码
  1. //serverthread.cpp
  2.     //socket 发送 writeorver 通知线程发送writeover 用来提醒server中的widget更新消息
  3.     connect(m_socket,&ServerSocket::writeover,this,[=](qintptr Desc, const QByteArray& msg){
  4.             emit writeover(Desc,msg);
  5.     });
复制代码
  1. //server.cpp
  2.     //当服务器给客户端发送下消息后，会产生一个writeover信号-> 触发线程发送writeover信号给 Tcpserver -> Tcpserver中widget更新消息
  3.     connect(thread,&ServerThread::writeover,[=](qintptr Desc,const QByteArray &msg){
  4.            m_widget->UpdateServerMsg(Desc,msg);
  5.     });
复制代码
  1. //widget.cpp
  2. //当服务器发送消息后，通知主窗口更新信号
  3. void Widget::UpdateServerMsg(qintptr Desc, const QByteArray &msg)
  4. {
  5.     ui->textBrowser_ServerMess->append("服务器："+msg+" to "+QString::number(Desc));
  6. }
复制代码
注意：

注册自界说信号参数，否则信号槽机制利用时会出现生存
  1. #include "widget.h"
  2. #include <QApplication>
  4. int main(int argc, char *argv[])
  5. {
  6.     qRegisterMetaType<qintptr>("qintptr");
  7.     QApplication a(argc, argv);
  8.     Widget w;
  9.     w.show();
  11.     return a.exec();
  12. }
复制代码
效果演示：


源码下载地址：

yuanzhaoyi/My_project at master (github.com)
https://github.com/yuanzhaoyi/My_project/tree/master

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

风雨同行

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表