Qt實現(xiàn)TCP同步與異步讀寫消息的示例代碼

更新時間：2024年04月24日 09:46:22 作者：鍵盤會跳舞

這篇文章主要為大家詳細介紹了如何在?Qt?中實現(xiàn)?TCP?客戶端和服務器的同步和異步讀寫消息,有需要的小伙伴可以跟隨小編一起學習一下

一、異步讀寫

在 Qt 中實現(xiàn) TCP 客戶端和服務器的同步和異步讀寫消息涉及使用 QTcpSocket 和 QTcpServer 類。這兩個類提供了用于建立 TCP 連接、發(fā)送和接收數(shù)據的功能。下面是一個簡單的示例，演示了如何在 Qt 中實現(xiàn) TCP 客戶端和服務器的同步和異步讀寫消息：

TCP 服務器端示例（異步）

#include <QCoreApplication>
#include <QTcpServer>
#include <QTcpSocket>
#include <QDebug>

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

    QTcpServer server;
    server.listen(QHostAddress::Any, 1234); // 監(jiān)聽端口 1234

    QObject::connect(&server, &QTcpServer::newConnection, [&](){
        QTcpSocket* clientSocket = server.nextPendingConnection();
        QObject::connect(clientSocket, &QTcpSocket::readyRead, [&](){
            QByteArray requestData = clientSocket->readAll();
            qDebug() << "Received request from client:" << requestData;

            // Echo back the received data
            clientSocket->write(requestData);
        });
    });

    qDebug() << "TCP server started. Listening on port 1234...";

    return a.exec();
}

TCP 客戶端端示例（異步）

#include <QCoreApplication>
#include <QTcpSocket>
#include <QDebug>

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

    QTcpSocket client;
    client.connectToHost("127.0.0.1", 1234); // 連接到服務器的 IP 地址和端口

    QObject::connect(&client, &QTcpSocket::connected, [&](){
        qDebug() << "Connected to server.";

        // Send a message to the server
        client.write("Hello, Server!");
    });

    QObject::connect(&client, &QTcpSocket::readyRead, [&](){
        QByteArray responseData = client.readAll();
        qDebug() << "Received response from server:" << responseData;
    });

    return a.exec();
}

示例簡單演示了如何在 Qt 中實現(xiàn) TCP 客戶端和服務器的異步讀寫消息。在異步通信中，使用信號和槽機制來處理數(shù)據的接收和發(fā)送。

二、同步讀寫

以下是一個簡單的示例，演示了如何在 Qt 中實現(xiàn) TCP 客戶端和服務器的同步讀寫消息：

TCP 服務器端示例（同步）

#include <QCoreApplication>
#include <QTcpServer>
#include <QTcpSocket>
#include <QDebug>

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

    QTcpServer server;
    server.listen(QHostAddress::Any, 1234); // 監(jiān)聽端口 1234

    if (!server.isListening()) {
        qDebug() << "Failed to start TCP server.";
        return 1;
    }

    QTcpSocket* clientSocket = nullptr;

    while (true) {
        if (server.hasPendingConnections()) {
            clientSocket = server.nextPendingConnection();
            break;
        }
    }

    if (clientSocket) {
        qDebug() << "Client connected.";

        // Read data from client
        QByteArray requestData = clientSocket->readAll();
        qDebug() << "Received request from client:" << requestData;

        // Echo back the received data
        clientSocket->write(requestData);
    }

    return a.exec();
}

TCP 客戶端端示例（同步）

#include <QCoreApplication>
#include <QTcpSocket>
#include <QDebug>

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

    QTcpSocket client;
    client.connectToHost("127.0.0.1", 1234); // 連接到服務器的 IP 地址和端口

    if (!client.waitForConnected()) {
        qDebug() << "Failed to connect to server.";
        return 1;
    }

    qDebug() << "Connected to server.";

    // Send a message to the server
    client.write("Hello, Server!");

    if (!client.waitForBytesWritten()) {
        qDebug() << "Failed to write data to server.";
        return 1;
    }

    if (!client.waitForReadyRead()) {
        qDebug() << "Failed to read response from server.";
        return 1;
    }

    // Read response from server
    QByteArray responseData = client.readAll();
    qDebug() << "Received response from server:" << responseData;

    return a.exec();
}

示例簡單演示了如何在 Qt 中實現(xiàn) TCP 客戶端和服務器的同步讀寫消息。在同步通信中，使用 waitForConnected、waitForBytesWritten 和 waitForReadyRead 等方法來等待連接建立、數(shù)據寫入和數(shù)據讀取完成。這種方式適用于需要確保數(shù)據傳輸完整性和順序性的場景。

到此這篇關于Qt實現(xiàn)TCP同步與異步讀寫消息的示例代碼的文章就介紹到這了,更多相關Qt TCP同步與異步讀寫消息內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: