[网络协议] QT实现TCP与UDP的消息收发

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 网络协议 -> QT实现TCP与UDP的消息收发 -> 正文阅读

[网络协议]QT实现TCP与UDP的消息收发

QT的TCP与UDP通信

1.TCP
TCP通信是基于握手实现的，数据传输相对较为可靠，但实时性较UDP差一些。
2.UDP
UDP通信是基于不可靠实现的，数据传输没有TCP那么靠谱，尽最大能力交付，实时性较好。
两者各有优点和不足，废话不多说，上代码

下面是重点
工程的结构如下。
在这里插入图片描述
工程中的UI文件如下

1.在QT的工程文件[.pro]里面加入network，如下所示。整个工程文件就改变这一处，其它代码为自动生成，此处不贴出占据版面

QT       += core gui network

2.widget.h

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include <QTcpSocket>
#include <QUdpSocket>
#include <QHostAddress>
#include <QDebug>
#include <QTimer>
#include <QString>

QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
    Q_OBJECT

public:
    Widget(QWidget *parent = nullptr);
    ~Widget();
    // UDP通信
    QUdpSocket *USocket;
    // TCP通信
    QTcpSocket *TSocket;
    QTimer *myTimer;
    // 处理接收到的UDP数据
    void dealUdpData(QByteArray array);

public slots:
    // 读取TCP数据
    void readTcpData();
    // 读取UDP数据
    void readUdpData();


private slots:
    void on_sendData_clicked();
    void timerSend();
    void on_sendData_2_clicked();

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

2.widget.cpp

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

Widget::Widget(QWidget *parent)
    : QWidget(parent)
    , ui(new Ui::Widget)
{
    ui->setupUi(this);
    myTimer = new QTimer(this);
    // TCP,监听本地IP的3081端口
    TSocket = new QTcpSocket(this);
    TSocket->connectToHost("127.0.0.1", 3081);
    // UDP,监听所有IP的3080端口
    USocket = new QUdpSocket(this);
    USocket->bind(QHostAddress::AnyIPv4, 3080);
    // 接收TCP
    connect(TSocket, &QTcpSocket::readyRead, this, &Widget::readTcpData);
    // 接收UDP数据
    connect(USocket, &QUdpSocket::readyRead, this, &Widget::readUdpData);
    // 定时发送数据
    connect(myTimer, &QTimer::timeout, this, &Widget::timerSend);
    myTimer->start(1000);
}

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

void Widget::dealUdpData(QByteArray array)
{
    if(array[0]==0xFD && array[1]==0x2A)
    {
        qDebug()<<"接收正确";
    }
    else
    {
        qDebug()<<"接收错误";
    }
}

// 读取TCP的数据
void Widget::readTcpData()
{
    QByteArray tcpData = TSocket->readAll();
    if(tcpData.at(0)==0x01 && tcpData.at(1)==0x02)
    {
        qDebug()<<"报文1段";
        if(tcpData.at(2)==0x03)
        {
            qDebug()<<"接收";
        }
        else if(tcpData.at(2)==0x04)
        {
            qDebug()<<"发送";
        }
    }
    else if(tcpData.at(0)==0x01 && tcpData.at(1)==0x03)
    {
        qDebug()<<"报文2段";
    }
}

// 读取UDP数据
void Widget::readUdpData()
{
    QByteArray array;
    while(USocket->hasPendingDatagrams())
    {
        array.resize(USocket->pendingDatagramSize());
        USocket->readDatagram(array.data(), array.size());
        if(array.size()>0)dealUdpData(array);
    }
}

// 向TCP发送消息
void Widget::on_sendData_clicked()
{
    QString msg = "ABC-123";
    QByteArray array1;
    array1.resize(4);
    // 电源控制
    array1[0]=0xFD;array1[1]=0x2C;array1[2]=0x02;array1[3]=0x02;
    QByteArray bytes = msg.toUtf8();
    if(TSocket->waitForConnected()) {
        TSocket->write(array1);

    }
}

// 定时器，定时向TCP不间断发送数据
void Widget::timerSend()
{
    QByteArray array;
    array.resize(4);
    for(int i=0;i<array.size();i++)
        array[i]=0;
    // 同步
    array[0]=0xFD;array[1]=0x2C;array[2]=0x01;array[3]=0x01;
    if(TSocket->waitForConnected()) {
        TSocket->write(array);
    }
}
// 发送UDP消息
void Widget::on_sendData_2_clicked()
{
    QByteArray array;
    array.resize(5);
    for(int i=0;i<array.size();i++)
        array[i]=0x09+i;
    USocket->writeDatagram(array, QHostAddress("127.0.0.1"), 3082);
}

3.main.cpp

#include "widget.h"
#include <QApplication>

int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    Widget w;
    w.show();
    return a.exec();
}