若该文为原创文章，转载请注明原文出处
本文章博客地址：https://blog.csdn.net/qq21497936/article/details/79955907
各位读者，知识无穷而人力有穷，要么改需求，要么找专业人士，要么自己研究
红胖子(红模仿)的博文大全：开发技术集合（包含Qt实用技术、树莓派、三维、OpenCV、OpenGL、ffmpeg、OSG、单片机、软硬结合等等）持续更新中…（点击传送门）
Qt开发专栏：项目实战（点击传送门）
需求
预言项目需要写个qt服务器，终端与qt服务器完成socket通讯，因存在多个设备，单个传输文件大小比较大，所以做多线程并发。
补充（2021年04月05日）
本文章的初衷，是记录服务器的QTcpServer遇到新的连接之后可以把QTcpSocket分发到不同的线程去处理，使用常规的方式，新QTcpSocket是在QTcpServer的线程里处理的。
实现原理
客户端：固定client的线程数量，单个线程按照设置的间隔不断发送数据给服务器，并接收服务器的线程指针地址。
服务端：主线程为TcpServer，当有一个新连接的时候，会new一个线程处理该新连接socket，接收数据后发送处理该socket的线程地址。
相关博客
《实用技巧：阿里云服务器建立公网物联网服务器（解决阿里云服务器端口，公网连接不上的问题）》
《Qt开发技术：QWebSocket客户端、服务端介绍与开发》
《Qt开发技术：mqtt介绍、QtMqtt编译和开发环境搭建》
《项目实战：Qt并发服务器通讯，受同一时刻最大线程数限制（笔者本本同一时刻600多）》
《Qt实用技巧：80显示超大显示拼接（十台服务器，每台八路摄像头）方案和Demo》
Demo测试工具
CSDN免积分下载地址：https://download.csdn.net/download/qq21497936/10351463
QQ群：1047134658（点击“文件”搜索“tcpClientAndServerTools”，群内与博文同步更新所有可开源的源码模板）
受限说明
1.同一时刻该应用最大限度的线程数，如果超过则仍然会new，然后打印失败，但是仍然会跑new线程的构造函数；
2.下载源码可以将客户端的时间间隔改下，同时运行线程数增大，IDE的qDebug可以看到停止后，index没有归零，仔细翻阅调试信息，可以找到“错误”，此条，以便读者自己可以使用源码尝试该问题。
3.写服务器时，应对最大线程数做限制，此Demo只是项目过程中关键功能的记录，未做处理。
实现截图
关键代码
客户端
单个线程socket请求代码 TcpClientThread.h
#ifndef TCPCLIENTTHREAD_H #define TCPCLIENTTHREAD_H #include <QThread> #include <QTcpSocket> #include <QByteArray> #include <QHostAddress> /************************************************************\ * 类名：TcpClientThread * 描述：线程循环使用QTcpClient连接服务器发送数据、接收数据、断开 * 信号： * recvMsg() - 收到客户端的的数据 * 函数： * TcpClientThread() - 传入ip，port，间隔时间（ms） * start() - 开启线程 * stop() - 停止 * 作者：红模仿 QQ：21497936 * 日期 版本号 描述 * 2018年04月13日 v1.0.0 指定间隔向指定ip和port发送数据、接收数据 \************************************************************/ class TcpClientThread : public QThread { Q_OBJECT public: explicit TcpClientThread(QString ip, quint16 port, int ms=1000, QObject *parent = nullptr); signals: void recvData(QByteArray data); public slots: void stop(); protected: void run(); private: QTcpSocket *_pTcpSocket; QString _ip; quint16 _port; bool _running; int _ms; }; #endif // TCPCLIENTTHREAD_H
服务器端
newConnection线程处理代码Thread.h
#ifndef THREAD_H #define THREAD_H #include <QObject> #include <QThread> #include <QTcpSocket> #include <QDebug> #include <QMutexLocker> /************************************************************\ * 类名：Thread * 描述：服务器端，线程处理新连接的socket * 信号： * Thread() - 传入socket描述符，注意类型是qintptr,不是int * error() - 错误信息 * recvMsg() - 收到客户端的的数据 * 函数： * TcpClientThread() - 传入ip，port，间隔时间（ms） * start() - 开启线程 * stop() - 停止 * 作者：红模仿 QQ：21497936 * 日期 版本号 描述 * 2018年04月13日 v1.0.0 处理收到的信息 \************************************************************/ #define DEBUG qDebug()<<__FILE__<<__LINE__<<__FUNCTION__<<"current thread:"<<QThread::currentThread() class Thread : public QThread { Q_OBJECT public: explicit Thread(qintptr socketDescriptor, QThread *parent = nullptr); ~Thread(); signals: void error(QString errorString); void recvMsg(QString msg); protected slots: void readyRead(); protected: void run(); private: qintptr _socketDescriptor; QTcpSocket *_pTcpSoscket; static int _count; static QMutex _mutex; int _index; }; #endif // THREAD_Hsa
若该文为原创文章，转载请注明原文出处
本文章博客地址：https://blog.csdn.net/qq21497936/article/details/79955907
