在QT中利用多线程并发服务器（C++）

什么是多线程并发服务器？在QT里怎样利用多线程并发服务器呢？
多线程并发服务器是一种网络服务器计划，它可以大概同时处置惩罚多个客户端的哀求。在多线程服务器中，主线程负责监听和接受来自客户端的毗连哀求，每当有一个新的毗连哀求到来时，服务器就会创建一个新的线程来处置惩罚该毗连。这样，每个客户端都有一个专门的线程来为之服务，从而实现并发处置惩罚多个客户端哀求的目的。
下面是怎样在QT里利用多线程并发服务器的流程。
可以先看这个图理解一下。

重写incomingConnection()函数

起首在myserver.h里创建一个Myserver类继承QTcpServer,重写 incomingConnection();
并创建一个自定义信号。
  myserver.h

1. #ifndef MYSERVER_H
2. #define MYSERVER_H
3. #include<QTcpServer>
5. class Myserver:public QTcpServer
6. {
7.     Q_OBJECT
8. public:
9.     Myserver(QObject *parent = 0);
10.     //重写,传递套接字描述（sd标志）
11.     void incomingConnection(qintptr socketDescriptor);
12.     ~Myserver();
13. signals:   //信号函数不需要实现
14.     void sig_sendsd(qintptr sd);
15. };
17. #endif // MYSERVER_H

复制代码

 在myserver.c里实现重写的incomingConnection()函数,当有客户端毗连的时，会发送包含socket套接字描述符的信号sig_sendsd(socketDescriptor)（上面创建的信号）到主线程。（套接字描述符socketDescriptor很告急，在子线程里用来创建socket对象跟客户端进行通信）。

1. #include "myserver.h"
3. Myserver::Myserver(QObject *parent):QTcpServer(parent)
4. {
6. }
7. void Myserver::incomingConnection(qintptr socketDescriptor)
8. {
9.     //发送自定义信号给主线程(sd标志)
10.     emit sig_sendsd(socketDescriptor);
11. }
12. Myserver::~Myserver()
13. {
14. }

复制代码

创建子线程类

在socketthread.h里创建一个叫socketthread的子线程类用于处置惩罚每个客户端发来的信息。

1. #ifndef SOCKETTHREAD_H
2. #define SOCKETTHREAD_H
3. #include<QThread>
4. #include<QTcpSocket>
8. class SocketThread:public QThread
9. {
10.     Q_OBJECT
12. public:
13.     SocketThread(qintptr sd);
14.     void run();  //重写run函数，执行线程
16.    
17.     ~SocketThread();
18. private slots:
19.     void slot_read();
20.     void slot_disconnect();
23. private:
24.     qintptr sd;
25.     QTcpSocket *socket;
26.    
27. };
29. #endif // SOCKETTHREAD_H

复制代码

 在socketthread.c中run()函数中处置惩罚客户端发来的信息，以及发送信息到客户端。

1. #include "socketthread.h"
3. SocketThread::SocketThread(qintptr sd):sd(sd)
4. {
5.    
6. }
8. void SocketThread::run()
9. {
10.     socket=new QTcpSocket;
11.     socket->setSocketDescriptor(sd);
13.     connect(socket,SIGNAL(readyRead()),this,SLOT(slot_read()));
14.     connect(socket,SIGNAL(disconnected()),this,SLOT(slot_disconnect()));  
15. }
17. void SocketThread::slot_read()
18. {
19.     isRead=true;
20.     qDebug()<<"客服端来消息了";
21. }
22. void SocketThread::slot_disconnect()
23. {
24.     qDebug()<<"客户端已断开";
25.     isRun=false;
26. }
27. SocketThread::~SocketThread()
28. {
29.     qDebug()<<"子线程结束";
30. }

复制代码

 主线程（重点）

在主线程里创建myserver类对象，监听客户端，等待客户端毗连。当有客户端毗连时，myserver类对象会发出自定义信号sig_sendsd(qintptr)，通过connect()函数，执行槽函数slot_recv_sd()。在槽函数里创建子线程类对象，在子线程类对象里创建socket套接字（上图），跟客户端通信。

1. MainWindow::MainWindow(QWidget *parent) :
2.     QMainWindow(parent),
3.     ui(new Ui::MainWindow)
4. {
5.     ui->setupUi(this);
6.     initIp();
7.     server=new Myserver(this);
8.     server->listen(QHostAddress::Any,12345); //any所有地址  12345port
9.     //当有新的客户端连接，server对象会发出自定义信号
10.     connect(server,SIGNAL(sig_sendsd(qintptr)),this,SLOT(slot_recv_sd(qintptr)));
11. }
12. MainWindow::~MainWindow()
13. {
14.     delete ui;
15. }
16. void MainWindow::initIp()   //获取本地ip地址
17. {
18.     QString ip;
19.     QString hostName = QHostInfo::localHostName();
20.     QHostInfo info = QHostInfo::fromName(hostName);
21.     QList<QHostAddress> list=info.addresses();
22.     for(int i=0;i<list.size();i++)
23.     {
24.         //获取协议类型
25.         if(list[i].protocol()==QAbstractSocket::IPv4Protocol)
26.         {
27.             ip+="*";
28.             ip+=list[i].toString();
29.         }
30.     }
31.     ui->label_ip->setText(ip);
32. }
33. void MainWindow::slot_recv_sd(qintptr sd)
34. {
35.     //创建子线程
36.     st=new SocketThread(sd);
37.     st->start();
38.    
39. }

复制代码

最后的最后，感谢大家的支持，哀求各路豪杰豪杰多多打赏，多多关注，多多点赞，我是只发布高质量文章的 better-code 。

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