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

在 Qt 5.9.9 的 C++ 开发中，利用 QTcpSocket 时，要判断是服务端主动断开 TCP Socket 连接，可以通过处置惩罚 QTcpSocket 的 disconnected 信号，结合 QTcpSocket 的状态以及相干事件信息来综合判断。以下是具体的实现思绪和示例代码：
实现思绪

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

示例代码

1. #include <QtNetwork/QTcpSocket>
2. #include <QDebug>
3. #include <QCoreApplication>
5. class MyTcpClient : public QObject
6. {
7.     Q_OBJECT
8. public:
9.     MyTcpClient(QObject *parent = nullptr) : QObject(parent)
10.     {
11.         socket = new QTcpSocket(this);
12.         connect(socket, &QTcpSocket::disconnected, this, &MyTcpClient::onDisconnected);
13.         connect(socket, &QTcpSocket::readyRead, this, &MyTcpClient::onReadyRead);
15.         // 连接到服务端
16.         socket->connectToHost("127.0.0.1", 12345);
17.     }
19. private slots:
20.     void onDisconnected()
21.     {
22.         // 检查是否是服务端主动断开
23.         if (socket->state() == QAbstractSocket::UnconnectedState) {
24.             // 可以进一步根据错误码判断
25.             if (socket->error() == QAbstractSocket::RemoteHostClosedError) {
26.                 qDebug() << "Server主动断开连接";
27.             } else {
28.                 qDebug() << "连接断开，错误码:" << socket->errorString();
29.             }
30.         }
31.     }
33.     void onReadyRead()
34.     {
35.         QByteArray data = socket->readAll();
36.         // 假设服务端发送 "CLOSE_CONNECTION" 表示主动断开连接
37.         if (data == "CLOSE_CONNECTION") {
38.             qDebug() << "收到服务端断开连接消息，即将断开连接";
39.             socket->disconnectFromHost();
40.         }
41.     }
43. private:
44.     QTcpSocket *socket;
45. };
47. #include "main.moc"
49. int main(int argc, char *argv[])
50. {
51.     QCoreApplication a(argc, argv);
53.     MyTcpClient client;
55.     return a.exec();
56. }

复制代码

1. #include <QtNetwork/QTcpServer>
2. #include <QtNetwork/QTcpSocket>
3. #include <QDebug>
4. #include <QCoreApplication>
6. class MyServer : public QTcpServer
7. {
8.     Q_OBJECT
9. public:
10.     explicit MyServer(QObject *parent = nullptr) : QTcpServer(parent) {}
12. protected:
13.     void incomingConnection(qintptr socketDescriptor) override
14.     {
15.         QTcpSocket *socket = new QTcpSocket(this);
17.         if (!socket->setSocketDescriptor(socketDescriptor)) {
18.             qDebug() << "Failed to set socket descriptor.";
19.             delete socket;
20.             return;
21.         }
23.         connect(socket, &QTcpSocket::readyRead, this, [socket]() {
24.             QByteArray data = socket->readAll();
25.             qDebug() << "Received from client:" << data;
26.             // 将收到的数据原样返回给客户端
27.             socket->write(data);
28.         });
30.         connect(socket, &QTcpSocket::disconnected, socket, &QTcpSocket::deleteLater);
31.     }
32. };
34. #include "server.moc"
36. int main(int argc, char *argv[])
37. {
38.     QCoreApplication a(argc, argv);
40.     MyServer server;
41.     if (!server.listen(QHostAddress::Any, 12345)) {
42.         qDebug() << "Server could not start!";
43.     } else {
44.         qDebug() << "Server started!";
45.     }
47.     return a.exec();
48. }

复制代码

1. #include <QtNetwork/QTcpSocket>
2. #include <QDebug>
3. #include <QCoreApplication>
5. int main(int argc, char *argv[])
6. {
7.     QCoreApplication a(argc, argv);
9.     QTcpSocket socket;
10.     socket.connectToHost(QHostAddress::LocalHost, 12345);
12.     if (socket.waitForConnected()) {
13.         qDebug() << "Connected to server!";
14.         // 向服务器发送消息
15.         socket.write("Hello, server!");
16.         socket.waitForBytesWritten();
18.         if (socket.waitForReadyRead()) {
19.             QByteArray data = socket.readAll();
20.             qDebug() << "Received from server:" << data;
21.         }
22.     } else {
23.         qDebug() << "Connection failed!";
24.     }
26.     socket.disconnectFromHost();
27.     if (socket.state() != QAbstractSocket::UnconnectedState) {
28.         socket.waitForDisconnected();
29.     }
31.     return a.exec();
32. }

复制代码

代码解释

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

重要功能和用法

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

1. #include <QtNetwork/QTcpSocket>

复制代码

• 2 创建 QTcpSocket 对象
  

1. QTcpSocket *socket = new QTcpSocket(this);

复制代码

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

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

复制代码

• 4.发送数据
  

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

复制代码

• 5.吸收数据
  

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

复制代码

• 6.断开连接
  

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

复制代码

• 7.错误处置惩罚
  

1. connect(socket, QOverload<QAbstractSocket::SocketError>::of(&QTcpSocket::error),
2.         [](QAbstractSocket::SocketError socketError) {
3.     qDebug() << "Socket error:" << socketError;
4. });
6. // 获取错误信息
7. qDebug() << "Error message:" << socket->errorString();

复制代码

注意事项

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

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。