学步园

定义

#define TCPSOCKET_MAX 3 

 

 声明private变量

QTcpServer *tcpServer;
QList<QTcpSocket*> tcpSocketList; 

 

声明public slots:

public slots:
    void recv_slot();
    void connect_slot(); 

 

//启动TCP服务
void MainWindow::on_pushButton_3_clicked()
{
    int tcpServerPort = ui->tcpServerPortText->text().toInt();
    //声明TCP服务
    this->tcpServer = new QTcpServer(this);
    //监听
    if(tcpServer->listen(QHostAddress::Any,tcpServerPort))
    {
        ui->pushButton_3->setEnabled(false);
        ui->pushButton_4->setEnabled(true);
    }
    //设置槽
    connect(tcpServer,SIGNAL(newConnection()),this,SLOT(connect_slot()));

}

//TCP服务连接事件
void MainWindow::connect_slot()
{

    if(tcpSocketList.count() <= TCPSOCKET_MAX)
    {
        QTcpSocket *tcpSocket = tcpServer -> nextPendingConnection();
        connect(tcpSocket,SIGNAL(readyRead()),this,SLOT(recv_slot()));
        tcpSocketList.append(tcpSocket);
    }

}

//TCP接收事件
void MainWindow::recv_slot()
{
    for(int i=0 ; i<tcpSocketList.count() ; i++)
    {
        QByteArray byte;
        QTcpSocket *tcpSocket=tcpSocketList.at(i);
        byte = tcpSocket -> readAll();
        QString result = printByteArr(byte);
        if(result.length()>0)
            addLog("tcp rev:" +tcpSocket->peerAddress().toString()+":"+ result);

        tcpSocket->write(strToQByteArray(result.mid(0,16)+ "17 01 03 14 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00"));
    }

}

//关闭TCP服务
void MainWindow::on_pushButton_4_clicked()
{
    tcpServer->close();
    ui->pushButton_3->setEnabled(true);
    ui->pushButton_4->setEnabled(false);
} 

 

转载请注明:kenter原创