#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget), server(new QTcpServer(this)) // 实例化服务器对象
{ui->setupUi(this);
}Widget::~Widget()
{delete ui;
}void Widget::on_startButton_clicked()
{// 获取界面输入的端口号quint16 port = ui->PortLineEdit->text().toUInt();// 设置服务器为监听状态: 监听任意客户端（主机）int ret = server->listen(QHostAddress::Any, port);if(ret == true){QMessageBox::information(this, "", "启动服务器成功");}else{QMessageBox::information(this, "", "启动服务器失败");return;}// 新客户端连接信号 连接 槽函数connect(server, &QTcpServer::newConnection, this, &Widget::connectSlot);
}void Widget::connectSlot()
{// 获取新连接客户端的socketQTcpSocket *clientSocket = server->nextPendingConnection();// 将客户端socket对象存入链表中socketList.push_back(clientSocket);// 客户端发送数据信号 连接 窗口connect(clientSocket, &QTcpSocket::readyRead, this, &Widget::readySlot);
}void Widget::readySlot()
{int ret;// 遍历客户端链表，移除无效客户端for(int i = 0; i < socketList.count(); ++i){ret = socketList.at(i)->state();if(ret == QTcpSocket::UnconnectedState){socketList.removeAt(i);}}// 遍历客户端链表，判断哪个客户端发送了消息for(int i = 0; i < socketList.count(); ++i){// 会阻塞等待ret = socketList.at(i)->bytesAvailable();if(ret > 0){// 读取数据QByteArray msg = socketList.at(i)->readAll();// 将读取到的数据发送到窗口ui->listWidget->addItem(QString::fromLocal8Bit(msg));// 将数据广播给所有客户端（除了发送此消息的客户端）for(int j = 0; j < socketList.count(); ++j){if(i == j)continue;socketList.at(j)->write(msg);}}}
}
