Qt5之TCP多线程收发

#include "Tcp.h" #include "ui_Tcp.h" Tcp::Tcp(QWidget *parent) : QWidget(parent), ui(new Ui::Tcp) { ui->setupUi(this); server = nullptr; serverThread = nullptr; socket = nullptr; socketThread = nullptr; } Tcp::~Tcp() { delete ui; if(socketThread) { socketThread->quit(); socketThread->wait(); delete socketThread; } socketThread = nullptr; if(serverThread) { serverThread->quit(); serverThread->wait(); delete serverThread; } serverThread = nullptr; if(socket) { if(socket->isOpen()) socket->close(); delete socket; } socket = nullptr; if(server) delete server; server = nullptr; } void Tcp::on_ServerListen_clicked() { if(!server) { server = new Server; serverThread = new QThread; server->moveToThread(serverThread); serverThread->start(); connect(this,&Tcp::serverMsg,server,&Server::send); connect(server,&Server::msg,this,[&](const QString &str){ui->ServerReceive->append(str);}); ui->ServerListen->setEnabled(false); } } void Tcp::on_ServerSend_clicked() { QString str = ui->ServerSendContent->text(); if(!str.isEmpty()) emit serverMsg(str); } void Tcp::on_SocketLink_clicked() { if(!socket) { socket = new Socket; socketThread = new QThread; socket->moveToThread(socketThread); socketThread->start(); connect(this,&Tcp::socketMsg,socket,&Socket::send); connect(socket,&Socket::msg,this,[&](const QString &str){ui->SocketReceive->append(str);}); ui->SocketLink->setEnabled(false); } } void Tcp::on_SocketSend_clicked() { QString str = ui->SocketSendContent->text(); if(!str.isEmpty()) emit socketMsg(str); }