#include "tcpserver.h"
#include "ui_tcpserver.h"
#include <QDebug>
TcpServer::TcpServer(QWidget *parent) :
QMainWindow(parent),
ui(new Ui::TcpServer)
{
ui->setupUi(this);
//监听状态栏初始化
LabListen = new QLabel("Listen State: ");
LabListen->setFont(QFont((QString("Times New Roman")),10));
LabListen->setMinimumWidth(150);
ui->statusBar->addWidget(LabListen);
//socket状态栏初始化
LabSocketState = new QLabel("Socket State: ");
LabSocketState->setFont(QFont((QString("Times New Roman")),10));
LabSocketState->setMaximumWidth(200);
ui->statusBar->addWidget(LabSocketState);
//下拉框combobox初始化
QString localIp = getLocalIp();//获取本机IP
ui->comboBox->addItem(localIp);//将本机IP添加到下拉框
//设置窗口题目
this->setWindowTitle("TcpServer-本机IP:"+localIp);
ui->spinBox->setValue(1200);
ui->btnSend->setEnabled(false);
tcpServer =new QTcpServer(this);
connect(tcpServer,SIGNAL(newConnection()),this,SLOT(onNewConnection()));
}
TcpServer::~TcpServer()
{
delete ui;
}
//获取本机IP
QString TcpServer::getLocalIp()
{
//返回主机名
QString hostname = QHostInfo::localHostName();
//返回主机信息
QHostInfo hostInfo = QHostInfo::fromName(hostname);
//返回IP地址列表
QList<QHostAddress> addList = hostInfo.addresses();
QString localIP="";
//判断IP地址列表是否为空
if(!addList.isEmpty())
//遍历IP地址列表,输出主机信息
for(int i=0;i<addList.count();i++)
{
QHostAddress aHost = addList.at(i);
//输出IPV4信息
if(QAbstractSocket::IPv4Protocol==aHost.protocol())
{
localIP= aHost.toString();
break;
}
}
return localIP;
}
//窗口关闭事件,关闭时停止监听
void TcpServer::closeEvent(QCloseEvent *event)
{
//isListening():判断服务器是否处于监听状态
if(tcpServer->isListening())
{
//close():关闭服务器,停止网络监听
tcpServer->close();
}
}
//建立新连接
void TcpServer::onNewConnection()
{
tcpSocket = tcpServer->nextPendingConnection();//获取接入连接的socket
onClientConnected();
connect(tcpSocket,SIGNAL(connected()),this,SLOT(onClientConnected()));
connect(tcpSocket,SIGNAL(disconnected()),this,SLOT(onClientDisconnected()));
connect(tcpSocket,SIGNAL(stateChanged(QAbstractSocket::SocketState)),this,\
SLOT(onStateChange(QAbstractSocket::SocketState)));
onStateChange(tcpSocket->state());
connect(tcpSocket,SIGNAL(readyRead()),this,SLOT(onSocketReadyRead()));
}
//开始连接
void TcpServer::onClientConnected()
{
ui->plainTextEdit->appendPlainText("Client Socket Connected");
ui->btnSend->setEnabled(true);
//peerAddress():在已连接状态下,返回对方socket的地址
ui->plainTextEdit->appendPlainText("Peer Address: "+tcpSocket->peerAddress().toString());
//peerPort():在已连接状态下,返回对方socket的端口
ui->plainTextEdit->appendPlainText("Peer Port: "+QString::number(tcpSocket->peerPort()));
}
//断开连接
void TcpServer::onClientDisconnected()
{
ui->plainTextEdit->appendPlainText("Client Socket Disconnected");
//deleteLater():删除一个对象时,依赖此对象的子对象都会被删除,减少内存泄漏的风险
tcpSocket->deleteLater();
}
//实现缓冲区数据的读取
void TcpServer::onSocketReadyRead()
{
//canReadLine():判断是否有新的一行数据需要读取
while(tcpSocket->canReadLine())
{
//readLine():读取一行数据
ui->plainTextEdit->appendPlainText("[in] "+tcpSocket->readLine());
}
}
//socket状态改变
void TcpServer::onStateChange(QAbstractSocket::SocketState socketState)
{
switch(socketState)
{
case QAbstractSocket::UnconnectedState:
LabSocketState->setText("Socket State: UnconnectedState"); break;
case QAbstractSocket::HostLookupState:
LabSocketState->setText("Socket State: HostLookupState"); break;
case QAbstractSocket::ConnectingState:
LabSocketState->setText("Socket State: ConnectingState"); break;
case QAbstractSocket::ConnectedState:
LabSocketState->setText("Socket State: ConnectedState"); break;
case QAbstractSocket::BoundState:
LabSocketState->setText("Socket State: BoundState"); break;
case QAbstractSocket::ClosingState:
LabSocketState->setText("Socket State: ClosingState"); break;
case QAbstractSocket::ListeningState:
LabSocketState->setText("Socket State: ListeningState"); break;
}
}
//开始监听
void TcpServer::on_actStartListen_triggered()
{
QString IP = ui->comboBox->currentText();
quint16 port = ui->spinBox->value();
QHostAddress addr(IP);
tcpServer->listen(addr,port);
//tcpServer->listen(QHostAddress::LocalHost,port);
ui->plainTextEdit->appendPlainText("Start Listen:");
ui->plainTextEdit->appendPlainText("服务器Address: "+tcpServer->serverAddress().toString());
ui->plainTextEdit->appendPlainText("服务器Port: "+QString::number(tcpServer->serverPort()));
LabListen->setText("Listen State: Start Listen");
}
//停止监听
void TcpServer::on_actStopListen_triggered()
{
//isListening():判断服务器是否处于监听状态
if(tcpServer->isListening())
{
//close():关闭服务器,停止网络监听
tcpServer->close();
LabListen->setText("Listen State: Stop Listen");
}
}
//清空文本
void TcpServer::on_actClear_triggered()
{
ui->plainTextEdit->clear();
}
//发送消息
void TcpServer::on_btnSend_clicked()
{
QString msg = ui->lineEdit->text();
ui->plainTextEdit->appendPlainText("[out]: "+msg);
ui->lineEdit->clear();
ui->lineEdit->setFocus();
QByteArray str = msg.toUtf8();
str.append('\n');
tcpSocket->write(str);
}
Tcp通信服务器端和客户端
需积分: 47 64 浏览量
2020-12-27
13:02:49
上传
评论
收藏 139KB RAR 举报
Vivi的城
- 粉丝: 30
- 资源: 7
评论0