C++ Qt 网络编程实战：UDP、TCP 与 HTTP 应用

// widget.cpp
#include "widget.h"
#include "ui_widget.h"

Widget::Widget(QWidget *parent)
    : QWidget(parent), ui(new Ui::Widget)
{
    ui->setupUi(this);
    socket = new QUdpSocket(parent);
    ui->listWidget->setObjectName(QString("UDP 服务器"));
    
    connect(socket, &QUdpSocket::readyRead, this, &Widget::process);
    
    bool isconnect = socket->bind(QHostAddress::Any, 8081);
    if (!isconnect) {
        QMessageBox::critical(this, "错误", "服务器启动错误\n" + socket->errorString());
        return;
    }
    setWindowTitle("Udp 服务端");
}

Widget::~Widget()
{
    delete ui;
}

QString Widget::process2(const QString& request)
{
    return request;
}

void Widget::process()
{
    QNetworkDatagram requestPacket = socket->receiveDatagram();
    QString request = requestPacket.data();
    QString response = process2(request);
    
    QNetworkDatagram responsePacket(response.toUtf8(), requestPacket.senderAddress(), requestPacket.senderPort());
    socket->writeDatagram(responsePacket);
    
    qint64 msTimestamp = QDateTime::currentMSecsSinceEpoch();
    QDateTime dateTime = QDateTime::fromMSecsSinceEpoch(msTimestamp);
    QString formatted = dateTime.toString("yyyy-MM-dd hh:mm:ss.zzz");
    QString log = "[" + formatted + " : " + requestPacket.senderAddress().toString() + ":" + QString::number(requestPacket.senderPort()) + "] req: " + request + ", resp: " + response;
    ui->listWidget->addItem(log);
}

实战：UDP 客户端

客户端同样需要 QUdpSocket，但不需要绑定端口（系统自动分配），只需指定目标 IP 和端口发送。

1. 定义全局变量 SERVER_IP (127.0.0.1) 和 SERVER_PORT (8081)。
2. 按钮点击槽函数中：
   • 获取输入框文本，转 UTF-8。
   • 构造 QNetworkDatagram 对象。
   • 调用 writeDatagram 发送。
   • 清空输入框。
3. 监听 readyRead 信号处理服务器回包。

// widget.cpp
QString SERVER_IP = "127.0.0.1";
quint16 SERVER_PORT = 8081;

Widget::Widget(QWidget *parent)
    : QWidget(parent), ui(new Ui::Widget)
{
    ui->setupUi(this);
    socket = new QUdpSocket(parent);
    setWindowTitle("Udp 客户端");
    connect(socket, &QUdpSocket::readyRead, this, &Widget::processResponse);
}

void Widget::on_pushButton_clicked()
{
    QString context = ui->lineEdit->text();
    QNetworkDatagram request(context.toUtf8(), QHostAddress(SERVER_IP), SERVER_PORT);
    socket->writeDatagram(request);
    ui->listWidget->addItem("客户端说：" + context);
    ui->lineEdit->clear();
}

void Widget::processResponse()
{
    const QNetworkDatagram& packet = socket->receiveDatagram();
    QString s = QString::fromUtf8(packet.data());
    ui->listWidget->addItem("服务器说" + s);
}

注意：Qt 程序通常依赖图形化界面，因此不建议将此类 GUI 服务器部署到纯 Linux 后台环境，但 Qt 客户端连接 Linux 原生 UDP 服务是完全可行的。

TCP 编程：QTcpServer & QTcpSocket

TCP 是面向字节流的协议，相比 UDP 更可靠，但也面临粘包问题。Qt 使用 QTcpServer 监听端口，QTcpSocket 处理具体连接。

关键 API

QTcpServer

• listen: 绑定地址端口并开始监听。
• nextPendingConnection: 获取已建立的连接（返回 QTcpSocket*）。
• newConnection: 有新客户端连接时触发。

QTcpSocket

• readAll: 读取缓冲区所有数据。
• write: 写入数据。
• peerAddress / peerPort: 获取对端信息。
• deleteLater: 安全销毁对象。

实战：TCP 回显服务器

1. 创建 QTcpServer 成员变量。
2. 构造函数中连接 newConnection 信号到处理函数。
3. 监听端口前确保信号槽已绑定。
4. 在 processConnection 中：
   • 调用 nextPendingConnection 获取客户端 Socket。
   • 记录上线日志（IP + 端口）。
   • 为当前客户端 Socket 连接 readyRead 信号（建议使用 Lambda 表达式捕获上下文）。
   • 读取数据，处理业务，写回响应。
   • 连接 disconnected 信号，下线时释放资源（使用 deleteLater 而非直接 delete，防止线程安全问题）。

// widget.cpp
Widget::Widget(QWidget *parent)
    : QWidget(parent), ui(new Ui::Widget)
{
    ui->setupUi(this);
    setWindowTitle("服务器");
    server = new QTcpServer(parent);
    connect(server, &QTcpServer::newConnection, this, &Widget::processConnection);
    
    bool ret = server->listen(QHostAddress::Any, 8080);
    if (!ret) {
        QMessageBox::critical(this, "服务器启动失败", server->errorString());
        return;
    }
}

QString Widget::process(QString& request)
{
    return request;
}

void Widget::processConnection()
{
    QTcpSocket *clientSocket = server->nextPendingConnection();
    QHostAddress add = clientSocket->peerAddress();
    quint16 port = clientSocket->peerPort();
    
    ui->listWidget->addItem("[" + add.toString() + ":" + QString::number(port) + "]: 客户端已上线");
    
    // 处理接收数据
    connect(clientSocket, &QTcpSocket::readyRead, this, [=]() {
        QString request = clientSocket->readAll();
        const QString& response = process(request);
        clientSocket->write(response.toUtf8());
        QString log = "[" + add.toString() + ":" + QString::number(port) + "] req:" + request + ",res:" + response;
        ui->listWidget->addItem(log);
    });
    
    // 处理断开连接
    connect(clientSocket, &QTcpSocket::disconnected, this, [=]() {
        QString log = "[" + add.toString() + ":" + QString::number(port) + "] 已下线";
        qDebug() << log;
        ui->listWidget->addItem(log);
        clientSocket->deleteLater();
    });
}

关于粘包：TCP 是流式协议，一个完整请求可能分多次传输。严谨做法需约定应用层协议格式（如长度头或分隔符）解析缓冲区。本示例仅做回显演示。

实战：TCP 客户端

1. 创建 QTcpSocket 对象。
2. 调用 connectToHost("127.0.0.1", 8080) 发起连接。
3. 使用 waitForConnected 阻塞等待连接结果，失败则弹窗退出。
4. 连接 readyRead 信号处理服务器响应。
5. 按钮点击时发送数据并清空输入框。

// widget.cpp
Widget::Widget(QWidget *parent)
    : QWidget(parent), ui(new Ui::Widget)
{
    ui->setupUi(this);
    socket = new QTcpSocket(parent);
    socket->connectToHost("127.0.0.1", 8080);
    
    connect(socket, &QTcpSocket::readyRead, this, [=]() {
        QString response = socket->readAll();
        ui->listWidget->addItem("服务端说：" + response);
    });
    
    if (!socket->waitForConnected()) {
        QMessageBox::critical(this, "client 连接服务器失败", socket->errorString());
        exit(0);
    }
}

void Widget::on_pushButton_clicked()
{
    QString request = ui->lineEdit->text();
    socket->write(request.toUtf8());
    ui->listWidget->addItem("客户端说：" + request);
    ui->lineEdit->clear();
}

HTTP 客户端：QNetworkAccessManager

HTTP 基于 TCP 封装，Qt 提供了高层抽象类简化操作。

核心 API

• QNetworkAccessManager: 管理网络请求的核心类。
• QNetworkRequest: 表示请求（URL、Header）。
• QNetworkReply: 表示响应（继承自 QIODevice）。

实战：HTTP 请求

1. 实例化 QNetworkAccessManager。
2. 构建 QNetworkRequest 对象，传入 URL。
3. 调用 get() 或 post() 方法，返回 QNetworkReply 指针。
4. 关键点：请求是非阻塞的。需连接 finished 信号处理响应。
5. 在槽函数中检查 error() 状态，若无错则 readAll() 读取数据。
6. 记得调用 deleteLater() 释放响应对象。

// widget.cpp
Widget::Widget(QWidget *parent)
    : QWidget(parent), ui(new Ui::Widget)
{
    ui->setupUi(this);
    client = new QNetworkAccessManager(parent);
}

void Widget::on_pushButton_clicked()
{
    QUrl url = ui->lineEdit->text();
    QNetworkRequest request(url);
    QNetworkReply *response = client->get(request);
    
    connect(response, &QNetworkReply::finished, this, [=]() {
        if (response->error() == QNetworkReply::NoError) {
            QString req = response->readAll();
            ui->plainTextEdit->setPlainText(req);
        } else {
            ui->plainTextEdit->setPlainText(response->errorString());
        }
        response->deleteLater();
    });
}

总结

1. UDP: 使用 QUdpSocket 配合 QNetworkDatagram，无连接，速度快但不可靠。注意先连信号槽再绑定端口。
2. TCP: 使用 QTcpServer 监听，QTcpSocket 通信。注意粘包处理和资源释放（优先用 deleteLater）。
3. HTTP: 使用 QNetworkAccessManager 封装，非阻塞机制，通过 finished 信号获取结果。
4. 模块依赖: 别忘了在 .pro 中添加 QT += network。

掌握这些基础组件，就能搭建起跨平台的网络应用了。