#include "widget.h"
#include "ui_widget.h"
Widget::Widget(QWidget *parent) :
QWidget(parent),
ui(new Ui::Widget)
{
ui->setupUi(this);
tcpServer = new QTcpServer(this);
connect(tcpServer,SIGNAL(newConnection()),this,SLOT(newConnection_Slot()));
}
Widget::~Widget()
{
delete ui;
}
void Widget::newConnection_Slot()
{
ui->recvEdit->append("Have a clinet connection");
QTcpSocket *temptcpSocket = tcpServer->nextPendingConnection();
connect(temptcpSocket,SIGNAL(readyRead()),this,SLOT(readyRead_Slot()));
connect(temptcpSocket,SIGNAL(stateChanged(QAbstractSocket::SocketState)),this,SLOT(stateChanged_Slot(QAbstractSocket::SocketState)));
// 客户端的ip地址
QString ipaddr = temptcpSocket->peerAddress().toString();
quint16 port = temptcpSocket->peerPort();
// 打印客户端连接的端口信息
ui->recvEdit->append("服务端：客户端的ip地址：" + ipaddr);
ui->recvEdit->append("服务端：客户端的端口：" + QString::number(port));
}
void Widget::readyRead_Slot()
{
//sender()返回触发该函数的信号所属者的指针
QTcpSocket *tcpSocket = (QTcpSocket *)sender();
QString buf;
buf = tcpSocket->readAll();
ui->recvEdit->append(buf);
}
void Widget::stateChanged_Slot(QAbstractSocket::SocketState socketState)
{
QTcpSocket *tcpSocket = (QTcpSocket *)sender();
switch(socketState){
case QAbstractSocket::UnconnectedState:
ui->recvEdit->append("connection end");
tcpSocket->deleteLater();
break;
default:
break;
}
}
void Widget::on_openBt_clicked()
{
if(ui->portEdit->text().isEmpty()){
ui->recvEdit->append("port is empty!!");
return;
}
tcpServer->listen(QHostAddress::Any, ui->portEdit->text().toUInt());
ui->recvEdit->append("open successful");
ui->openBt->setEnabled(false);
ui->colseBt->setEnabled(true);
}
void Widget::on_colseBt_clicked()
{
tcpServer->close();
ui->recvEdit->append("close successful");
ui->openBt->setEnabled(true);
ui->colseBt->setEnabled(false);
}
void Widget::on_sendBt_clicked()
{
//返回server端与客户端建立连接的所有socket
QList <QTcpSocket *> socketList = tcpServer->findChildren<QTcpSocket *>();
qDebug() << "tcpSocket 数量：" << socketList.count() << endl;
if (socketList.count() == 0) {
ui->recvEdit->append("当前没有客户端连接，请先与客户端连接！");
return;
}
foreach (QTcpSocket *tmpTcpSocket, socketList) {
// 服务端向每个客户端发送消息
tmpTcpSocket->write(ui->sendEdit->text().toUtf8());
}
ui->recvEdit->append("服务端：" + ui->sendEdit->text());
}
