当前位置：首页 > article >正文

QT的TCP通讯

article 2025/1/19 10:26:47

一、引言

二、QT 中与 TCP 通讯相关的类

1.QTcpSocket 类

1.1 常用信号

1.2常用函数

2.QTcpServer类

2.1常用函数

三、QT TCP通信的详细代码实现

1.TCP服务器端实现

2.TCP客户端实现

四、总结

一、引言

在网络编程领域，TCP（Transmission Control Protocol，传输控制协议）是一种广泛应用的可靠传输协议。QT 作为一个强大的跨平台 C++ 应用程序开发框架，提供了丰富的类库来支持 TCP 通讯的开发。本文将详细介绍如何使用 QT 进行 TCP 通讯，包括客户端和服务器端的实现，希望能帮助大家快速上手相关开发。

二、QT 中与 TCP 通讯相关的类

QT 提供了丰富的类库来支持 TCP 通信的开发，其中最核心的两个类是 QTcpSocket 和 QTcpServer。

1.QTcpSocket 类

QTcpSocket类用于实现TCP客户端的功能。它提供了一系列的信号和槽函数，方便开发者处理网络连接、数据发送和接收等操作。

1.1 常用信号

connected()：当客户端成功连接到服务器时触发该信号。
readyRead()：当有数据可读时触发该信号，开发者可以在对应的槽函数中读取数据。
disconnected()：当客户端与服务器断开连接时触发该信号。

1.2常用函数

connectToHost(const QString &hostName, quint16 port)：用于连接到指定主机的指定端口。
write(const QByteArray &data)：用于向服务器发送数据。
readAll()：读取所有可用的数据，并以QByteArray的形式返回。

2.QTcpServer类

QTcpServer类用于创建TCP服务器，监听指定的端口，等待客户端的连接请求。

2.1常用函数

isten(const QHostAddress &address = QHostAddress::Any, quint16 port = 0)：开始监听指定地址和端口。如果地址为QHostAddress::Any，则表示监听所有可用的网络接口。
incomingConnection(qintptr socketDescriptor)：当有客户端连接请求时，该函数会被调用。开发者需要在该函数中创建一个QTcpSocket对象，并使用socketDescriptor来初始化它，从而实现与客户端的通信。

三、QT TCP通信的详细代码实现

1.TCP服务器端实现

下面是一个完整的TCP服务器端示例代码，详细展示了如何使用QTcpServer类来创建一个简单的服务器。

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

class MyTcpServer : public QTcpServer
{
    Q_OBJECT

public:
    MyTcpServer(QObject *parent = nullptr) : QTcpServer(parent)
    {
        if (this->listen(QHostAddress::Any, 1234)) {
            qDebug() << "Server started, listening on port 1234...";
        } else {
            qDebug() << "Server could not start!";
        }
    }

protected:
    void incomingConnection(qintptr socketDescriptor) override
    {
        QTcpSocket *socket = new QTcpSocket(this);
        if (socket->setSocketDescriptor(socketDescriptor)) {
            connect(socket, SIGNAL(readyRead()), this, SLOT(handleReadyRead()));
            connect(socket, SIGNAL(disconnected()), this, SLOT(handleDisconnected()));
            qDebug() << "Client connected: " << socket->peerAddress().toString();
        } else {
            delete socket;
        }
    }

private slots:
    void handleReadyRead()
    {
        QTcpSocket *socket = qobject_cast<QTcpSocket*>(sender());
        if (socket) {
            QByteArray data = socket->readAll();
            qDebug() << "Received data: " << data;

            // 这里可以进行数据处理，然后发送响应
            socket->write("Server received your message!");
        }
    }

    void handleDisconnected()
    {
        QTcpSocket *socket = qobject_cast<QTcpSocket*>(sender());
        if (socket) {
            qDebug() << "Client disconnected: " << socket->peerAddress().toString();
            socket->deleteLater();
        }
    }
};

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    MyTcpServer server;
    return a.exec();
}

在上述代码中：

MyTcpServer类：继承自QTcpServer类，在构造函数中调用listen函数开始监听端口1234。
incomingConnection函数：当有客户端连接请求时，该函数被调用。它创建一个新的QTcpSocket对象，并将其与客户端的socketDescriptor关联起来。同时，连接该socket的readyRead和disconnected信号到相应的槽函数。
handleReadyRead槽函数：当客户端有数据发送过来时，该函数被触发。它读取客户端发送的数据，并向客户端发送一个简单的响应。
handleDisconnected槽函数：当客户端断开连接时，该函数被调用，用于清理资源。

2.TCP客户端实现

下面是一个完整的TCP客户端示例代码，展示了如何使用QTcpSocket类来连接到服务器并进行数据通信。

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

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

    QTcpSocket *socket = new QTcpSocket();
    socket->connectToHost("127.0.0.1", 1234);

    if (socket->waitForConnected(3000)) {
        qDebug() << "Connected to server!";
        socket->write("Hello, server!");

        if (socket->waitForReadyRead(3000)) {
            QByteArray data = socket->readAll();
            qDebug() << "Received response from server: " << data;
        } else {
            qDebug() << "Timeout waiting for response!";
        }

        socket->disconnectFromHost();
        if (socket->waitForDisconnected(3000)) {
            qDebug() << "Disconnected from server.";
        } else {
            qDebug() << "Failed to disconnect from server.";
        }
    } else {
        qDebug() << "Could not connect to server!";
    }

    delete socket;
    return a.exec();
}

在上述代码中：