1. 程式人生 > 實用技巧 >QT socket通訊客戶端與服務端例項

QT socket通訊客戶端與服務端例項

qt通訊很簡單,主要是利用socket通訊,網上有很多案例,案例稍有漏洞,我自己稍加改善,如下

QT += network

client.h

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include <QTcpSocket>

QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
    Q_OBJECT

public:
    Widget(QWidget *parent = nullptr);
    ~Widget();

private slots:
    void on_pushButton_3_clicked();

    void on_pushButton_clicked();

    void on_pushButton_2_clicked();

    void connectToServer();
    void readInformation();



private:
    Ui::Widget *ui;

    QTcpSocket *tcpsocket= NULL;
};
#endif // WIDGET_H  

client.cpp

#include "widget.h"
#include "ui_widget.h"

#include <QHostAddress>
Widget::Widget(QWidget *parent)
    : QWidget(parent)
    , ui(new Ui::Widget)
{
    ui->setupUi(this);

}

Widget::~Widget()
{
    delete ui;
}



//寫socket
void Widget::on_pushButton_clicked()
{
    QString str = ui->textEditWrite->toPlainText();
    tcpsocket->write(str.toUtf8().data());
}

//主動斷開連結
void Widget::on_pushButton_2_clicked()
{
    if(tcpsocket == NULL)return;
    tcpsocket->disconnectFromHost();//主動和客戶端斷開連線
    tcpsocket->close();
    tcpsocket = NULL;
    //if(tcpsocket == NULL) ui->textEditRead->append("已斷開連結");
}

//已經連線到伺服器
void Widget::connectToServer()
{
    ui->textEditRead->setText("成功和伺服器進行連線");
}

//從通道讀取資料
void Widget::readInformation()
{
    QByteArray temp = tcpsocket->readAll();
    ui->textEditRead->append(temp);
}

//建立連結
void Widget::on_pushButton_3_clicked()
{
    QString ip = ui->lineEditIpAddress->text();
    qint16 port = ui->lineEditPort->text().toInt();

    if(tcpsocket != NULL){tcpsocket->deleteLater();tcpsocket=NULL;}
    tcpsocket = new QTcpSocket();
    connect(tcpsocket, &QTcpSocket::connected, this, &Widget::connectToServer);
    connect(tcpsocket, &QTcpSocket::readyRead, this, &Widget::readInformation);
    connect(tcpsocket, &QTcpSocket::disconnected, this, [this](){
        ui->textEditRead->append("已斷開連結");
    });
    //主動和伺服器進行連線
    tcpsocket->connectToHost((QHostAddress)ip, port);


}

  

server.h

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>

#include <QTcpServer>
#include <QTcpSocket>

QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
    Q_OBJECT

public:
    Widget(QWidget *parent = nullptr);
    ~Widget();

private slots:
    void on_pushButton_clicked();

    void on_pushButton_2_clicked();

    void connectToClient();
    void readInformation();

    void on_pushButton_3_clicked();

private:
    Ui::Widget *ui;

    QTcpServer *tcpserver = NULL  ;
    QTcpSocket *tcpsocket = NULL;
};
#endif // WIDGET_H

server.cpp

#include "widget.h"
#include "ui_widget.h"

Widget::Widget(QWidget *parent)
    : QWidget(parent)
    , ui(new Ui::Widget)
{
    ui->setupUi(this);

}

Widget::~Widget()
{
    delete ui;
}


//建立連結
void Widget::connectToClient()
{
    if(tcpsocket != NULL){tcpsocket->deleteLater();tcpsocket=NULL;}
    tcpsocket = tcpserver->nextPendingConnection();
    connect(tcpsocket, &QTcpSocket::readyRead, this, &Widget::readInformation);
    connect(tcpsocket, &QTcpSocket::disconnected, this, [this](){
        ui->textEditRead->append("已斷開連結");
    });
    QString ip = tcpsocket->peerAddress().toString();
    qint16 port = tcpsocket->peerPort();
    ui->textEditRead->setText(QString("[%1:%2]連線成功").arg(ip).arg(port));

}

//從通道讀取資料
void Widget::readInformation()
{
    QByteArray temp = tcpsocket->readAll();
    ui->textEditRead->append(temp);
}

//向通道寫資料
void Widget::on_pushButton_clicked()
{
    QString str = ui->textEditWrite->toPlainText();
    tcpsocket->write(str.toUtf8().data());
}

//客戶端主動斷開連結
void Widget::on_pushButton_2_clicked()
{
    if(tcpsocket == NULL)return;
    tcpsocket->disconnectFromHost();//主動和客戶端斷開連線
    tcpsocket->close();
    tcpsocket->deleteLater();
    tcpsocket = NULL;
    //if(tcpsocket == NULL) ui->textEditRead->append("已斷開連結");
}


//建立監聽
void Widget::on_pushButton_3_clicked()
{
    if(tcpserver!=NULL){on_pushButton_2_clicked();tcpserver->deleteLater();tcpserver = NULL;}
    //if(tcpserver!=NULL){tcpserver->deleteLater();tcpserver = NULL;}
    //if(tcpserver!=NULL){tcpserver = NULL;}
    tcpserver = new QTcpServer(this);
    int port = ui->lineEditListenPort->text().toInt();
    tcpserver->listen(QHostAddress::Any, port);
    connect(tcpserver, &QTcpServer::newConnection, this, &Widget::connectToClient);
}