前言

Qt 是一個(gè)跨平臺(tái)C++圖形界面開(kāi)發(fā)庫(kù)，利用Qt可以快速開(kāi)發(fā)跨平臺(tái)窗體應(yīng)用程序，在Qt中我們可以通過(guò)拖拽的方式將不同組件放到指定的位置，實(shí)現(xiàn)圖形化開(kāi)發(fā)極大的方便了開(kāi)發(fā)效率，本章將重點(diǎn)介紹如何運(yùn)用QTcpSocket組件實(shí)現(xiàn)基于TCP的網(wǎng)絡(luò)通信功能。

QTcpSocket和QTcpServer是Qt中用于實(shí)現(xiàn)基于TCP（Transmission Control Protocol）通信的兩個(gè)關(guān)鍵類(lèi)。TCP是一種面向連接的協(xié)議，它提供可靠的、雙向的、面向字節(jié)流的通信。這兩個(gè)類(lèi)允許Qt應(yīng)用程序在網(wǎng)絡(luò)上建立客戶(hù)端和服務(wù)器之間的連接。

以下是QTcpSocket類(lèi)的一些常用函數(shù)：

以下是QTcpServer類(lèi)的一些常用函數(shù)及其簡(jiǎn)要解釋?zhuān)?/p>

如上這些只是常用函數(shù)的簡(jiǎn)要描述，詳細(xì)的函數(shù)說(shuō)明和用法可以參考Qt官方文檔或相關(guān)文檔。

1.通信的流程

1.1服務(wù)端流程

在使用TCP通信時(shí)同樣需要導(dǎo)入Qt+=network模塊，并在頭文件中引入QTcpServer和QTcpSocket兩個(gè)模塊，當(dāng)有了模塊的支持，接著就是偵聽(tīng)套接字，此處可通過(guò)調(diào)用server.listen來(lái)實(shí)現(xiàn)偵聽(tīng)，此函數(shù)原型如下；

bool QTcpServer::listen(
    const QHostAddress &address = QHostAddress::Any, 
    quint16 port = 0
);

這個(gè)函數(shù)用于開(kāi)始在指定的地址和端口上監(jiān)聽(tīng)連接。它的參數(shù)包括：

• address：一個(gè)QHostAddress對(duì)象，指定要監(jiān)聽(tīng)的主機(jī)地址。默認(rèn)為QHostAddress::Any，表示監(jiān)聽(tīng)所有可用的網(wǎng)絡(luò)接口。
• port：一個(gè)quint16類(lèi)型的端口號(hào)，指定要監(jiān)聽(tīng)的端口。如果設(shè)置為0，系統(tǒng)將選擇一個(gè)可用的未使用端口。

函數(shù)返回一個(gè)bool值，表示是否成功開(kāi)始監(jiān)聽(tīng)。如果成功返回true，否則返回false，并且可以通過(guò)調(diào)用errorString()獲取錯(cuò)誤消息。

緊隨套接字偵聽(tīng)其后，通過(guò)使用一個(gè)waitForNewConnection等待新的連接到達(dá)。它的原型如下：

bool QTcpServer::waitForNewConnection(
    int msec = 0, 
    bool *timedOut = nullptr
);

該函數(shù)在服務(wù)器接受新連接之前會(huì)一直阻塞。參數(shù)包括：

• msec：等待連接的超時(shí)時(shí)間（以毫秒為單位）。如果設(shè)置為0（默認(rèn)值），則表示無(wú)限期等待，直到有新連接到達(dá)。
• timedOut：一個(gè)可選的布爾指針，用于指示等待是否超時(shí)。如果傳遞了此參數(shù)，并且等待時(shí)間達(dá)到了指定的超時(shí)時(shí)間，*timedOut將被設(shè)置為true，否則為false。如果不關(guān)心超時(shí)，可以將此參數(shù)設(shè)置為nullptr。

函數(shù)返回一個(gè)布爾值，表示是否成功等待新連接。如果在超時(shí)時(shí)間內(nèi)有新連接到達(dá)，返回true，否則返回false。如果等待超時(shí)，可以通過(guò)檢查timedOut參數(shù)來(lái)確定。如果函數(shù)返回false，可以通過(guò)調(diào)用errorString()獲取錯(cuò)誤消息。

套接字的接收會(huì)使用nextPendingConnection()函數(shù)來(lái)實(shí)現(xiàn)，nextPendingConnection 是 QTcpServer 類(lèi)的成員函數(shù)，用于獲取下一個(gè)已接受的連接的套接字（QTcpSocket）。它的原型如下：

QTcpSocket *QTcpServer::nextPendingConnection();

函數(shù)返回一個(gè)指向新連接套接字的指針。如果沒(méi)有已接受的連接，則返回 nullptr。

使用這個(gè)函數(shù)，你可以在服務(wù)器接受連接之后獲取相應(yīng)的套接字，以便進(jìn)行數(shù)據(jù)傳輸和通信。一般來(lái)說(shuō)，在收到 newConnection 信號(hào)后，你可以調(diào)用這個(gè)函數(shù)來(lái)獲取新連接的套接字。

當(dāng)有了套接字以后，就可以通過(guò)QTcpServer指針判斷對(duì)應(yīng)的套接字狀態(tài)，一般套接字的狀態(tài)被定義在QAbstractSocket類(lèi)內(nèi)。以下是QAbstractSocket類(lèi)中定義的一些狀態(tài)及其對(duì)應(yīng)的標(biāo)志：

這些狀態(tài)反映了套接字在不同階段的連接和通信狀態(tài)。在實(shí)際使用中，可以通過(guò)調(diào)用state()函數(shù)獲取當(dāng)前套接字的狀態(tài)，并根據(jù)需要處理相應(yīng)的狀態(tài)。例如，可以使用信號(hào)和槽機(jī)制來(lái)捕獲狀態(tài)變化，以便在連接建立或斷開(kāi)時(shí)執(zhí)行相應(yīng)的操作。

當(dāng)套接字被連接后則可以通過(guò)socket->write()方法向上線(xiàn)客戶(hù)端發(fā)送一個(gè)字符串，此處我們以發(fā)送lyshark為例，發(fā)送時(shí)需要向write()中傳入兩個(gè)參數(shù)。其原型如下：

qint64 QTcpSocket::write(const char *data, qint64 maxSize);

該函數(shù)接受兩個(gè)參數(shù)：

• data：指向要寫(xiě)入套接字的數(shù)據(jù)的指針。
• maxSize：要寫(xiě)入的數(shù)據(jù)的最大字節(jié)數(shù)。

函數(shù)返回實(shí)際寫(xiě)入的字節(jié)數(shù)，如果發(fā)生錯(cuò)誤，則返回 -1。在寫(xiě)入數(shù)據(jù)之后，可以使用 bytesWritten 信號(hào)來(lái)獲取寫(xiě)入的字節(jié)數(shù)。此外，你也可以使用 waitForBytesWritten 函數(shù)來(lái)阻塞等待直到所有數(shù)據(jù)都被寫(xiě)入。

至此服務(wù)端代碼可總結(jié)為如下案例；

#include <QCoreApplication>
#include <QTcpServer>
#include <QTcpSocket>
#include <iostream>

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    QTcpServer server;

    server.listen(QHostAddress::Any,9000);
    server.waitForNewConnection(100000);

    QTcpSocket *socket;

    socket = server.nextPendingConnection();
    if(socket->state() && QAbstractSocket::ConnectedState)
    {
        QByteArray bytes = QString("lyshark").toUtf8();
        socket->write(bytes.data(),bytes.length());
    }

    socket->close();
    server.close();
    return a.exec();
}

1.2客戶(hù)端流程

客戶(hù)端的流程與服務(wù)端基本保持一致，唯一的區(qū)別在于將server.listen更換為socket.connectToHost連接到對(duì)應(yīng)的主機(jī)，QTcpSocket 的 connectToHost 函數(shù)的原型如下：

void QTcpSocket::connectToHost(
const QString &hostName, 
quint16 port, 
OpenMode openMode = ReadWrite
);

• hostName：遠(yuǎn)程主機(jī)的主機(jī)名或IP地址。
• port：要連接的端口號(hào)。
• openMode：套接字的打開(kāi)模式，默認(rèn)為 ReadWrite。

函數(shù)用于初始化與指定遠(yuǎn)程主機(jī)和端口的連接。在實(shí)際使用中，你可以通過(guò)調(diào)用這個(gè)函數(shù)來(lái)發(fā)起與目標(biāo)主機(jī)的連接嘗試。

讀取數(shù)據(jù)時(shí)可以使用readAll函數(shù)來(lái)實(shí)現(xiàn)，socket.readAll() 是 QTcpSocket 類(lèi)的成員函數(shù)，用于讀取所有可用的數(shù)據(jù)并返回一個(gè) QByteArray 對(duì)象。其函數(shù)函數(shù)原型如下：

QByteArray QTcpSocket::readAll();

該函數(shù)返回一個(gè)包含從套接字中讀取的所有數(shù)據(jù)的 QByteArray 對(duì)象。通常，你可以通過(guò)這個(gè)函數(shù)來(lái)獲取已經(jīng)到達(dá)的所有數(shù)據(jù)，然后對(duì)這些數(shù)據(jù)進(jìn)行進(jìn)一步的處理。其客戶(hù)端功能如下所示；

#include <QCoreApplication>
#include <QTcpServer>
#include <QTcpSocket>
#include <iostream>

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    QTcpSocket socket;
    socket.connectToHost(QHostAddress::LocalHost,9000);

    if(socket.state() && QAbstractSocket::ConnectedState)
    {
        socket.waitForReadyRead(10000);

        QByteArray ref = socket.readAll();

        QString ref_string;

        ref_string.prepend(ref);

        std::cout << ref_string.toStdString() << std::endl;
    }

    socket.close();
    return a.exec();
}

2.圖形化應(yīng)用

2.1 服務(wù)端流程

與命令行版本的網(wǎng)絡(luò)通信不同，圖形化部分需要使用信號(hào)與槽函數(shù)進(jìn)行綁定，所有的通信流程都是基于信號(hào)的，對(duì)于服務(wù)端而言我們需要導(dǎo)入QTcpServer、QtNetwork、QTcpSocket模塊，并新增四個(gè)槽函數(shù)分別對(duì)應(yīng)四個(gè)信號(hào)；

在程序入口處我們通過(guò)new QTcpServer(this)新建TCP套接字類(lèi)，并通過(guò)connect()連接到初始化槽函數(shù)上，當(dāng)程序運(yùn)行后會(huì)首先觸發(fā)newConnection信號(hào)，執(zhí)行onNewConnection槽函數(shù)。

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

    // 新建TCP套接字類(lèi)
    tcpServer=new QTcpServer(this);

    // 連接信號(hào)初始化其他信號(hào)
    connect(tcpServer,SIGNAL(newConnection()),this,SLOT(onNewConnection()));
}

而在槽函數(shù)onNewConnection中，通過(guò)nextPendingConnection新建一個(gè)套接字，并綁定其他四個(gè)槽函數(shù)，這里的槽函數(shù)功能各不相同，將其對(duì)應(yīng)的信號(hào)綁定到對(duì)應(yīng)槽函數(shù)上即可；

// 初始化信號(hào)槽函數(shù)
void MainWindow::onNewConnection()
{
    // 創(chuàng)建新套接字
    tcpSocket = tcpServer->nextPendingConnection();

    // 連接觸發(fā)信號(hào)
    connect(tcpSocket, SIGNAL(connected()),this, SLOT(onClientConnected()));
    onClientConnected();

    // 關(guān)閉觸發(fā)信號(hào)
    connect(tcpSocket, SIGNAL(disconnected()),this, SLOT(onClientDisconnected()));

    // 狀態(tài)改變觸發(fā)信號(hào)
    connect(tcpSocket,SIGNAL(stateChanged(QAbstractSocket::SocketState)),this,SLOT(onSocketStateChange(QAbstractSocket::SocketState)));
    onSocketStateChange(tcpSocket->state());

    // 讀入數(shù)據(jù)觸發(fā)信號(hào)
    connect(tcpSocket,SIGNAL(readyRead()),this,SLOT(onSocketReadyRead()));
}

當(dāng)讀者點(diǎn)擊偵聽(tīng)時(shí)則直接調(diào)用tcpServer->listen實(shí)現(xiàn)對(duì)本地IP的8888端口的偵聽(tīng)功能，停止偵聽(tīng)則是調(diào)用tcpServer->close函數(shù)實(shí)現(xiàn)，如下所示；

// 開(kāi)始偵聽(tīng)
void MainWindow::on_pushButton_2_clicked()
{
    // 此處指定綁定本機(jī)的8888端口
    tcpServer->listen(QHostAddress::LocalHost,8888);
    ui->plainTextEdit->appendPlainText("[+] 開(kāi)始監(jiān)聽(tīng)");
    ui->plainTextEdit->appendPlainText(" 服務(wù)器地址：" + tcpServer->serverAddress().toString() +
                                       " 服務(wù)器端口："+QString::number(tcpServer->serverPort())
                                       );
}

// 停止偵聽(tīng)
void MainWindow::on_pushButton_3_clicked()
{
    if (tcpServer->isListening())
    {
        tcpServer->close();
    }
}

對(duì)于讀取數(shù)據(jù)可以通過(guò)canReadLine()函數(shù)判斷行，并通過(guò)tcpClient->readLine()逐行讀入數(shù)據(jù)，相對(duì)應(yīng)的發(fā)送數(shù)據(jù)可通過(guò)調(diào)用tcpSocket->write函數(shù)實(shí)現(xiàn)，在發(fā)送之前需要將其轉(zhuǎn)換為QByteArray類(lèi)型的字符串格式，如下所示；

// 讀取數(shù)據(jù)
void MainWindow::onSocketReadyRead()
{
    while(tcpSocket->canReadLine())
        ui->plainTextEdit->appendPlainText("[接收] | " + tcpSocket->readLine());
}

// 發(fā)送數(shù)據(jù)
void MainWindow::on_pushButton_clicked()
{
    QString  msg=ui->lineEdit->text();
    ui->plainTextEdit->appendPlainText("[發(fā)送] | " + msg);

    QByteArray str=msg.toUtf8();
    str.append('\n');
    tcpSocket->write(str);
}

運(yùn)行服務(wù)端程序，并點(diǎn)擊偵聽(tīng)按鈕此時(shí)將會(huì)在本地的8888端口上啟用偵聽(tīng)，如下圖所示；

2.2客戶(hù)端流程

對(duì)于客戶(hù)端而言同樣需要綁定四個(gè)信號(hào)并對(duì)應(yīng)到特定的槽函數(shù)上，其初始化部分與服務(wù)端保持一致，唯一不同的是客戶(hù)端使用connectToHost函數(shù)鏈接到服務(wù)端上，斷開(kāi)連接時(shí)使用的是disconnectFromHost函數(shù)，如下所示；

// 連接服務(wù)器時(shí)觸發(fā)
void MainWindow::on_pushButton_2_clicked()
{
    // 連接到8888端口
    tcpClient->connectToHost(QHostAddress::LocalHost,8888);
}

// 斷開(kāi)時(shí)觸發(fā)
void MainWindow::on_pushButton_3_clicked()
{
    if (tcpClient->state()==QAbstractSocket::ConnectedState)
        tcpClient->disconnectFromHost();
}

此處的讀取數(shù)據(jù)與服務(wù)端保持一致，發(fā)送數(shù)據(jù)時(shí)則是通過(guò)tcpClient->write(str)函數(shù)直接傳遞給客戶(hù)端，代碼如下所示；

// 讀取數(shù)據(jù)時(shí)觸發(fā)
void MainWindow::onSocketReadyRead()
{
    while(tcpClient->canReadLine())
    {
        ui->plainTextEdit->appendPlainText("[接收] | " + tcpClient->readLine());
    }
}

// 發(fā)送消息時(shí)觸發(fā)
void MainWindow::on_pushButton_clicked()
{
    QString msg=ui->lineEdit->text();
    ui->plainTextEdit->appendPlainText("[發(fā)送] | " + msg);
    QByteArray str=msg.toUtf8();
    str.append('\n');
    tcpClient->write(str);
}

運(yùn)行后，服務(wù)端啟用偵聽(tīng)等待客戶(hù)端連接，客戶(hù)端連接后，雙方則可以實(shí)現(xiàn)數(shù)據(jù)的收發(fā)功能，由于采用了信號(hào)機(jī)制，兩者的收發(fā)并不會(huì)阻斷可同時(shí)進(jìn)行，如下圖所示；

到此這篇關(guān)于C++ Qt開(kāi)發(fā)之使用QTcpSocket實(shí)現(xiàn)TCP網(wǎng)絡(luò)通信的文章就介紹到這了,更多相關(guān)Qt QTcpSocket TCP網(wǎng)絡(luò)通信內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論