QT的TCP一个服务端连接多个客户端

#include "MyTcpServer.h" #include <QHostAddress> #include <QDebug> Server::Server(QObject *parent, int port):QTcpServer(parent) { qDebug()<<">>>>start to listen..."; listen(QHostAddress::Any, port); //监听 } void Server::incomingConnection(int socketDescriptor) { qDebug()<<">>>>a new client connect"; TcpSocket *tcpclientsocket = new TcpSocket(this);//只要有新的连接就生成一个新的通信套接字 //将新创建的通信套接字描述符指定为参数socketdescriptor tcpclientsocket->setSocketDescriptor(socketDescriptor); //将这个套接字加入客户端套接字列表中 tcpclientsocketlist.append(tcpclientsocket); //接收到tcpclientsocket发送过来的更新界面的信号 connect(tcpclientsocket, SIGNAL(updateserver(QString,int)), this, SLOT(slotupdateserver(QString,int))); connect(tcpclientsocket, SIGNAL(clientdisconnected(int)), this, SLOT(slotclientdisconnect(int))); } void Server::slotupdateserver(QString msg, int length) { //将这个信号发送给界面 emit updateserver(msg, length); //将收到的信息发送给每个客户端,从套接字列表中找到需要接收的套接字 for(int i = 0; i < tcpclientsocketlist.count(); i++) { QTcpSocket *item = tcpclientsocketlist.at(i); // if(item->write((char*)msg.toUtf8().data(), length) != length) // { // continue; // } item->write(msg.toUtf8().data()); } } void Server::slotclientdisconnect(int descriptor) { qDebug()<<">>>>client disconnect!!!"; for(int i = 0; i < tcpclientsocketlist.count(); i++) { QTcpSocket *item = tcpclientsocketlist.at(i); if(item->socketDescriptor() == descriptor) { tcpclientsocketlist.removeAt(i);//如果有客户端断开连接， 就将列表中的套接字删除 qDebug()<<">>>>client delet"; return; } } return; } int Server::SendData(QByteArray &arr) { qDebug() << ">>>>>SendSerialData:"<< arr.toHex(); int ret; for(int i = 0; i < tcpclientsocketlist.count(); i++) { QTcpSocket *item = tcpclientsocketlist.at(i); ret =item->socketDescriptor(); QHostAddress s=item->localAddress(); QString Ipadd = s.toString(); qDebug()<<">>>>ip address:"<<Ipadd; item->write((arr)); item->flush(); } qDebug() << ">>>>>ret:"<<ret; if(ret < 0) { qDebug() << ">>>>>SendData failed:"; return -1; } return ret; }