Qt 网络编程实战：QUdpSocket、QTcpSocket 与 HTTP 客户端

Qt 网络编程实战：QUdpSocket、QTcpSocket 与 HTTP 客户端 | 极客日志

名称	类型	说明	对标原生 API
bind(const QHostAddress&, quint16)	方法	绑定指定的端口号	bind
receiveDatagram()	方法	返回 QNetworkDatagram 读取一个 UDP 数据报	recvfrom
writeDatagram(const QNetworkDatagram&)	方法	发送一个 UDP 数据报	sendto
readyRead	信号	在收到数据并准备就绪后触发	无 (类似于 IO 多路复用的通知机制)

名称	类型	说明	对标原生 API
QNetworkDatagram(const QByteArray&, const QHostAddress& , quint16 )	构造函数	通过 QByteArray , 目标 IP 地址，目标端口号构造一个 UDP 数据报	无
data()	方法	获取数据报内部持有的数据	无
senderAddress()	方法	获取数据报中包含的对端的 IP 地址	无
senderPort()	方法	获取数据报中包含的对端的端口号	无

//widget.h
#ifndef WIDGET_H
#define WIDGET_H
#include <QWidget>
#include <QUdpSocket>
#include <QHostAddress>
#include <QMessageBox>
#include <QNetworkDatagram>
#include <QDateTime>

QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
    Q_OBJECT
public:
    explicit Widget(QWidget *parent = nullptr);
    ~Widget();

private:
    Ui::Widget *ui;
    QUdpSocket* socket;
    QString process2(const QString& s);

private slots:
    void process();
};
#endif // WIDGET_H

//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, "错误", "服务器启动错误");
        return;
    }
    setWindowTitle("Udp 服务端");
}

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

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

void Widget::process()
{
    // 1. 读取请求并解析
    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);
}

//widget.h
#ifndef WIDGET_H
#define WIDGET_H
#include <QWidget>
#include <QUdpSocket>
#include <QNetworkDatagram>
#include <QHostAddress>

QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
    Q_OBJECT
public:
    explicit Widget(QWidget *parent = nullptr);
    ~Widget();

private slots:
    void on_pushButton_clicked();
    void processResponse();

private:
    Ui::Widget *ui;
    QUdpSocket *socket;
};
#endif // WIDGET_H

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

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);
}

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

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);
}

名称	类型	说明	对标原生 API
listen(const QHostAddress&, quint16 port)	方法	绑定指定的地址和端口号，并开始监听	bind 和 listen
nextPendingConnection()	方法	从系统中获取到一个已经建立好的 tcp 连接	accept
newConnection	信号	有新的客户端建立连接好之后触发	无

名称	类型	说明	对标原生 API
readAll()	方法	读取当前接收缓冲区中的所有数据	read
write(const QByteArray& )	方法	把数据写入 socket 中	write
deleteLater	方法	暂时把 socket 对象标记为无效	无
peerAddress	方法	获取对端客户端的 ip	无
peerPort	方法	获取对端客户端 port	无
readyRead	信号	有数据到达并准备就绪时触发	无
disconnected	信号	连接断开时触发	无

#include "widget.h"
#include "ui_widget.h"

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;
    }
}

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

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();
    });
}

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

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);
    }
}

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

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

方法	说明
get(const QNetworkRequest& )	发起一个 HTTP GET 请求
post(const QNetworkRequest& , const QByteArray& )	发起一个 HTTP POST 请求

方法	说明
QNetworkRequest(const QUrl& )	通过 URL 构造一个 HTTP 请求
setHeader(QNetworkRequest::KnownHeaders header, const QVariant &value)	设置请求头

取值	说明
ContentTypeHeader	描述 body 的类型
ContentLengthHeader	描述 body 的长度
CookieHeader	设置 cookie
UserAgentHeader	设置 User-Agent

方法	说明
error()	获取出错状态
errorString()	获取出错原因的文本
readAll()	读取响应 body
header(QNetworkRequest::KnownHeaders header)	读取响应指定 header 的值

#include "widget.h"
#include "ui_widget.h"

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

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

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();
    });
}

Qt 网络编程实战：QUdpSocket、QTcpSocket 与 HTTP 客户端

Qt 网络编程

关于 Qt 网络编程的要点

1. QUdpSocket

核心 API 概览

实操 Demo

UDP 回显服务器

UDP 回显客户端

Qt UDP 总结

2. TcpSocket

实操 Demo

Tcp 回显服务器

Tcp 客户端的实现

Qt Tcp 总结

3. HTTP Client

核心 API

实操 Demo Http 客户端

Qt Http 总结

更多推荐文章

相关免费在线工具

Qt 网络编程实战：QUdpSocket、QTcpSocket 与 HTTP 客户端

Qt 网络编程

关于 Qt 网络编程的要点

1. QUdpSocket

核心 API 概览

实操 Demo

UDP 回显服务器

UDP 回显客户端

Qt UDP 总结

2. TcpSocket

实操 Demo

Tcp 回显服务器

Tcp 客户端的实现

Qt Tcp 总结

3. HTTP Client

核心 API

实操 Demo Http 客户端

Qt Http 总结

微信扫一扫，关注极客日志

更多推荐文章

相关免费在线工具