Qt5 C++ TcpSocket 如何判断是服务主动断开tcp socket连接？

实现思路

1. 监听 disconnected 信号：当连接断开时，QTcpSocket 会发出 disconnected 信号，我们可以在槽函数中处理该信号。
2. 检查连接状态：在 disconnected 信号的槽函数中，检查 QTcpSocket 的状态，判断是否为主动断开。可以结合网络错误码、服务端发送的特定消息等进行判断。
3. 服务端主动断开的特征判断：例如，如果服务端在断开连接前发送了特定的关闭消息，客户端接收到该消息后就可以知道是服务端主动断开；或者通过网络错误码判断是否是服务端正常关闭连接。
   

示例代码

#include <QtNetwork/QTcpSocket>
#include <QDebug>
#include <QCoreApplication>

class MyTcpClient : public QObject
{
    Q_OBJECT
public:
    MyTcpClient(QObject *parent = nullptr) : QObject(parent)
    {
        socket = new QTcpSocket(this);
        connect(socket, &QTcpSocket::disconnected, this, &MyTcpClient::onDisconnected);
        connect(socket, &QTcpSocket::readyRead, this, &MyTcpClient::onReadyRead);

        // 连接到服务端
        socket->connectToHost("127.0.0.1", 12345);
    }

private slots:
    void onDisconnected()
    {
        // 检查是否是服务端主动断开
        if (socket->state() == QAbstractSocket::UnconnectedState) {
            // 可以进一步根据错误码判断
            if (socket->error() == QAbstractSocket::RemoteHostClosedError) {
                qDebug() << "Server主动断开连接";
            } else {
                qDebug() << "连接断开，错误码:" << socket->errorString();
            }
        }
    }

    void onReadyRead()
    {
        QByteArray data = socket->readAll();
        // 假设服务端发送 "CLOSE_CONNECTION" 表示主动断开连接
        if (data == "CLOSE_CONNECTION") {
            qDebug() << "收到服务端断开连接消息，即将断开连接";
            socket->disconnectFromHost();
        }
    }

private:
    QTcpSocket *socket;
};

#include "main.moc"

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

    MyTcpClient client;

    return a.exec();
}

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

class MyServer : public QTcpServer
{
    Q_OBJECT
public:
    explicit MyServer(QObject *parent = nullptr) : QTcpServer(parent) {}

protected:
    void incomingConnection(qintptr socketDescriptor) override
    {
        QTcpSocket *socket = new QTcpSocket(this);
        if (!socket->setSocketDescriptor(socketDescriptor)) {
            qDebug() << "Failed to set socket descriptor.";
            delete socket;
            return;
        }

        connect(socket, &QTcpSocket::readyRead, this, [socket]() {
            QByteArray data = socket->readAll();
            qDebug() << "Received from client:" << data;
            // 将收到的数据原样返回给客户端
            socket->write(data);
        });

        connect(socket, &QTcpSocket::disconnected, socket, &QTcpSocket::deleteLater);
    }
};

#include "server.moc"

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

    MyServer server;
    if (!server.listen(QHostAddress::Any, 12345)) {
        qDebug() << "Server could not start!";
    } else {
        qDebug() << "Server started!";
    }

    return a.exec();
}

#include <QtNetwork/QTcpSocket>
#include <QDebug>
#include <QCoreApplication>

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

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

    if (socket.waitForConnected()) {
        qDebug() << "Connected to server!";
        // 向服务器发送消息
        socket.write("Hello, server!");
        socket.waitForBytesWritten();

        if (socket.waitForReadyRead()) {
            QByteArray data = socket.readAll();
            qDebug() << "Received from server:" << data;
        }
    } else {
        qDebug() << "Connection failed!";
    }

    socket.disconnectFromHost();
    if (socket.state() != QAbstractSocket::UnconnectedState) {
        socket.waitForDisconnected();
    }

    return a.exec();
}

代码解释

1. MyTcpClient 类：继承自 QObject，封装了 QTcpSocket 对象，用于处理与服务端的连接。
2. 构造函数：创建 QTcpSocket 对象，并连接 disconnected 和 readyRead 信号到相应的槽函数。然后尝试连接到服务端。
3. onDisconnected 槽函数：在连接断开时被调用，检查 QTcpSocket 的状态和错误码。如果错误码为 QAbstractSocket::RemoteHostClosedError，则表示服务端主动断开连接。
4. onReadyRead 槽函数：在有数据可读时被调用，检查服务端发送的数据。如果收到特定的关闭消息（如 “CLOSE_CONNECTION”），则认为服务端要主动断开连接，调用 disconnectFromHost() 方法断开连接。

主要功能和用法

• 1 包含必要的头文件
  在使用 QTcpSocket 之前，需要包含相应的头文件，并在 .pro 文件中添加 QT += network 以引入网络模块。

#include <QtNetwork/QTcpSocket>

• 2 创建 QTcpSocket 对象

QTcpSocket *socket = new QTcpSocket(this);

• 3 连接到服务器（客户端）

socket->connectToHost(QHostAddress::LocalHost, 12345);
// 可以使用 waitForConnected 等待连接成功
if (socket->waitForConnected()) {
    qDebug() << "Connected to server!";
} else {
    qDebug() << "Connection failed!";
}

• 4.发送数据

QByteArray data = "Hello, server!";
socket->write(data);
// 可以使用 waitForBytesWritten 等待数据发送完成
if (socket->waitForBytesWritten()) {
    qDebug() << "Data sent successfully!";
}

• 5.接收数据

// 连接 readyRead 信号到槽函数
connect(socket, &QTcpSocket::readyRead, this, [socket]() {
    QByteArray data = socket->readAll();
    qDebug() << "Received data:" << data;
});

• 6.断开连接

socket->disconnectFromHost();
// 可以使用 waitForDisconnected 等待断开连接完成
if (socket->waitForDisconnected()) {
    qDebug() << "Disconnected from server!";
}

• 7.错误处理

connect(socket, QOverload<QAbstractSocket::SocketError>::of(&QTcpSocket::error),
        [](QAbstractSocket::SocketError socketError) {
    qDebug() << "Socket error:" << socketError;
});

// 获取错误信息
qDebug() << "Error message:" << socket->errorString();

注意事项

• 上述示例中的错误码判断和特定消息判断只是一种常见的方式，具体的判断逻辑需要根据实际的业务需求和服务端的实现进行调整。
• 确保服务端和客户端对断开连接的消息和状态处理达成一致，避免出现误解。