4、TCP客户端实现：创建TCP客户端、连接服务器、发送数据、接收数据、断开连接

好，咱们今天来聊聊TCP客户端的实现。说实话，这部分内容在Qt网络编程里，算是基本功中的基本功。我当年刚接触Qt网络模块时，第一个实战项目就是写一个TCP客户端。那时候踩了不少坑，今天我把这些经验都揉碎了讲给你听。

4.1 创建TCP客户端——从QTcpSocket说起

在Qt里，TCP客户端的核心就是QTcpSocket这个类。它封装了底层的socket操作，你不需要关心三次握手、数据包重组这些细节。说白了，它就是一根管子，你往里面倒数据，它帮你送到服务器那边。

创建客户端很简单，几行代码的事：

QTcpSocket *tcpSocket = new QTcpSocket(this);
// 或者用栈对象
// QTcpSocket tcpSocket;

我个人习惯用堆对象，配合父对象管理内存。这样当窗口关闭时，socket会自动销毁，省心。

小提示： 记得在头文件里包含 #include <QTcpSocket>，并在.pro文件里加上 QT += network。我见过有人忘了加network模块，编译报错后一脸懵。

4.2 连接服务器——信号与槽的经典配合

创建好socket后，下一步就是连接服务器。你需要知道服务器的IP地址和端口号。比如：

tcpSocket->connectToHost("192.168.1.100", 8080);

这里有个关键点：connectToHost()是异步的。它不会阻塞你的UI线程，连接结果通过信号通知你。我曾经在项目里犯过傻，以为调用完就连接上了，结果直接发数据，当然失败了。

正确的做法是监听信号：

connect(tcpSocket, &QTcpSocket::connected, this, [=]() {
    qDebug() << "连接成功！";
    // 可以开始发送数据了
});

connect(tcpSocket, &QTcpSocket::errorOccurred, this, [=](QAbstractSocket::SocketError error) {
    qDebug() << "连接失败：" << tcpSocket->errorString();
});

你想想看，如果连接失败，比如服务器没启动，或者IP写错了，errorOccurred信号就会触发。这时候你可以给用户弹个提示框，而不是让程序默默崩溃。

注意： 连接超时默认是30秒。如果你觉得太久，可以用 tcpSocket->setSocketOption(QAbstractSocket::LowDelayOption, 1); 来优化。不过这个选项在不同平台上表现不太一样，我建议你测试一下。

4.3 发送数据——写就完了？没那么简单

连接成功后，发送数据就简单了。Qt提供了几种方式：

// 方式一：直接写QByteArray
QByteArray data = "Hello, Server!";
tcpSocket->write(data);

// 方式二：写字符串
tcpSocket->write("Hello, Server!");

// 方式三：用QDataStream包装（适合复杂数据）
QByteArray buffer;
QDataStream stream(&buffer, QIODevice::WriteOnly);
stream << QString("Hello") << 12345;
tcpSocket->write(buffer);

嗯，这里要注意：write()返回的是实际写入的字节数，但不代表数据已经发送到网络上了。它只是写入了发送缓冲区。真正的网络传输由Qt底层处理。

我遇到过一个问题：连续快速发送多条数据时，底层可能会把它们合并成一个TCP包。这在某些协议里会导致解析错误。解决办法是自定义协议，比如在每个数据包前面加上长度字段。这个咱们后面会细讲。

4.4 接收数据——readyRead信号的正确用法

接收数据是客户端的核心功能。Qt通过readyRead信号通知你有数据到达：

connect(tcpSocket, &QTcpSocket::readyRead, this, [=]() {
    QByteArray data = tcpSocket->readAll();
    qDebug() << "收到数据：" << data;
});

这里有个坑：readyRead信号可能触发多次，每次只带来一部分数据。比如服务器发送了1000字节，你可能收到两次信号，第一次600字节，第二次400字节。如果你用readAll()，每次只能读到当前缓冲区里的数据。

那怎么办？我建议用缓冲区自己拼接：

QByteArray m_buffer; // 成员变量

connect(tcpSocket, &QTcpSocket::readyRead, this, [=]() {
    m_buffer.append(tcpSocket->readAll());
    
    // 假设协议是：前4字节是数据长度
    while (m_buffer.size() >= 4) {
        int len = *reinterpret_cast<int*>(m_buffer.data());
        if (m_buffer.size() < 4 + len) break; // 数据还没收完
        
        QByteArray msg = m_buffer.mid(4, len);
        m_buffer.remove(0, 4 + len);
        
        // 处理完整的一条消息
        processMessage(msg);
    }
});

说白了，就是自己维护一个接收缓冲区，按照协议格式解析。这个模式我在好几个项目里都用过，很稳。

核心要点： TCP是流式协议，没有消息边界。你必须自己定义协议来区分消息。常见做法有：固定长度、特殊分隔符、长度前缀。

4.5 断开连接——优雅地结束

断开连接有两种方式：主动断开和被动断开。

主动断开：

tcpSocket->disconnectFromHost();
// 或者直接关闭
// tcpSocket->abort(); // 立即关闭，不等待

disconnectFromHost()会等待数据发送完毕再断开，比较优雅。abort()则立即关闭，适合紧急情况。

被动断开： 服务器断开连接时，会触发disconnected信号：

connect(tcpSocket, &QTcpSocket::disconnected, this, [=]() {
    qDebug() << "连接已断开";
    // 清理资源，更新UI
});

我曾经在项目里遇到一个问题：客户端断网了，但disconnected信号没有立即触发。这是因为TCP有保活机制，默认要等很久才能检测到连接断开。解决方案是启用保活探测：

tcpSocket->setSocketOption(QAbstractSocket::KeepAliveOption, 1);

不过这个选项在不同系统上行为不一样，Windows和Linux的默认保活间隔也不同。如果你需要更精细的控制，可以用平台相关的API。

4.6 完整示例：一个简单的TCP客户端

说了这么多，咱们来个完整的例子。假设你要写一个聊天客户端：

// 头文件
#include <QTcpSocket>
#include <QLineEdit>
#include <QTextEdit>
#include <QPushButton>

class TcpClient : public QWidget {
    Q_OBJECT
public:
    TcpClient(QWidget *parent = nullptr) : QWidget(parent) {
        // 创建UI
        m_ipEdit = new QLineEdit("127.0.0.1", this);
        m_portEdit = new QLineEdit("8080", this);
        m_connectBtn = new QPushButton("连接", this);
        m_sendBtn = new QPushButton("发送", this);
        m_msgEdit = new QTextEdit(this);
        m_inputEdit = new QLineEdit(this);
        
        // 创建socket
        m_socket = new QTcpSocket(this);
        
        // 连接信号
        connect(m_connectBtn, &QPushButton::clicked, this, &TcpClient::onConnect);
        connect(m_sendBtn, &QPushButton::clicked, this, &TcpClient::onSend);
        connect(m_socket, &QTcpSocket::connected, this, [=]() {
            m_msgEdit->append("已连接到服务器");
        });
        connect(m_socket, &QTcpSocket::readyRead, this, [=]() {
            QString msg = QString::fromUtf8(m_socket->readAll());
            m_msgEdit->append("收到: " + msg);
        });
        connect(m_socket, &QTcpSocket::disconnected, this, [=]() {
            m_msgEdit->append("连接已断开");
        });
    }
    
private slots:
    void onConnect() {
        if (m_socket->state() == QAbstractSocket::UnconnectedState) {
            m_socket->connectToHost(m_ipEdit->text(), m_portEdit->text().toInt());
        } else {
            m_socket->disconnectFromHost();
        }
    }
    
    void onSend() {
        if (m_socket->state() == QAbstractSocket::ConnectedState) {
            m_socket->write(m_inputEdit->text().toUtf8());
            m_msgEdit->append("发送: " + m_inputEdit->text());
            m_inputEdit->clear();
        }
    }
    
private:
    QLineEdit *m_ipEdit, *m_portEdit, *m_inputEdit;
    QPushButton *m_connectBtn, *m_sendBtn;
    QTextEdit *m_msgEdit;
    QTcpSocket *m_socket;
};

这个例子虽然简单，但涵盖了TCP客户端的核心流程。你可以在它的基础上扩展，比如添加心跳包、重连机制、协议解析等。

4.7 知识体系总览

为了让你更直观地理解TCP客户端的整体结构，我画了一张流程图：

TCP客户端核心流程 创建 QTcpSocket connectToHost() 连接成功? errorOccurred 信号 connected 信号 发送/接收数据 write() / readyRead disconnectFromHost()

这张图把整个流程串起来了。从创建socket开始，到连接、数据交互、断开，每一步都有对应的信号和槽函数。你写代码时，可以对照这张图，确保每个环节都处理到了。

好了，TCP客户端的基础实现就讲到这里。记住几个关键点：异步连接、信号槽驱动、自定义协议解析、优雅断开。把这些吃透了，你就能写出稳定可靠的网络客户端了。

总结： TCP客户端开发的核心就是围绕QTcpSocket的四个信号（connected、readyRead、errorOccurred、disconnected）来组织代码。每个信号对应一个生命周期阶段，处理好它们，你的客户端就稳了。

可可精品资料库

← 上一章 📖 返回目录 下一章 →