当前位置： 首页 > article >正文

QT实现TCP/UDP通信

article 2024/9/22 19:37:52

服务器端：

客户端：

服务器：

widget.h

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include <QTcpServer>
#include <QTcpSocket>
#include <QList>
#include <QMessageBox>
#include <QDebug>


QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
    Q_OBJECT

public:
    Widget(QWidget *parent = nullptr);
    ~Widget();

private slots:

    //自定义处理信号与槽函数
    void on_startButton_clicked();
    void newConnection_slot();
    void readyRead_slot();

private:
    Ui::Widget *ui;
    QTcpServer *server;//定义服务器指针
    QList<QTcpSocket*> socketList;//定义存放客户端信息的容器

};
#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);
    //实例化一个服务器对象
    server = new QTcpServer(this);//在堆区申请一个服务器


}

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

//启动服务器按钮对应的槽函数
void Widget::on_startButton_clicked()
{
    if(ui->startButton->text()== "启动服务器")
    {
        //执行启动服务器动作

        //获取ui界面的端口号  ???
        quint16 port = ui->portEdit->text().toUInt();

        //启动监听
        //函数原型 bool listen(const QHostAddress &address = QHostAddress::any,quint16 port = 0);
        //1->要监听的ip地址 写any 表示监听该主机上所有的网络接口
        //2->要监听的端口号 不指定 系统默认随机绑定一个端口号

        if(!server->listen(QHostAddress::Any,port))
        {
            QMessageBox::critical(this,"错误","服务器启动失败");
            return;
        }

        //程序启动至此表示服务器启动成功
        QMessageBox::information(this,"成功","服务器启动成功");

        //将行编辑器设置为不可用
        ui->portEdit->setEnabled(false);
        //将按钮文本内容设置为关闭服务器
        ui->startButton->setText("关闭服务器");

        //此时 如果有客户端发来请求 那么该服务器会自动发射一个newConnection信号
        //将该信号连接到自定槽函数中处理后续操作
        connect(server,&QTcpServer::newConnection,this,&Widget::newConnection_slot);
    }
    else
    {
        //执行关闭服务器操作
        server->close();
        //将行编辑器设置成为可用状态
        ui->portEdit->setEnabled(true);
        //将按钮文本内容设置为启动服务器
        ui->startButton->setText("启动服务器");
    }
}

void Widget::newConnection_slot()
{
    qDebug()<<"有新的客户端发来连接请求";

    //可以通过nextPendingConnection函数获取最新连接的客户端套接字的地址
    //函数原型 QTcpSocket *nextPendingConnection();
    //无参函数
    //返回值 最新的连接的套接字地址

    QTcpSocket *s = server->nextPendingConnection();
    //将套接字地址放入链表中

    socketList.push_back(s);
    //一个服务器对应多个客户端 已经建立连接
    //如果有客户端发来消息 自动发射readyRead信号
    connect(s,&QTcpSocket::readyRead,this,&Widget::readyRead_slot);
}
void Widget::readyRead_slot()
{
    //遍历链表中的所有客户端 如果客户端状态未连接 则直接移除出链表
    for (int i=0 ;i<socketList.size();i++)
    {
        //判断当前套接字 socketList[i] 是否失效
        //函数原型 SocketState state() const;
        //返回值 返回当前调节子状态
        //返回结果为0 表示未连接
        if(socketList[i]->state()==0)
        {
            socketList.removeAt(i);
        }
    }

    //遍历所有客户端 判断客户端中是否有数据刻度 如果有数据可读 则表示该客户端发来的消息
    for (int i =0;i<socketList.count();i++)
    {
        //判断当前 客户端中是否有数据可读
        //函数原型 qint64 byteAvailable() const overrde
        //参数无
        //返回值为当前客户端套接字中的待读数据 如果没有数据 则返回0
        if(socketList[i]->bytesAvailable()  !=0)
        {
            //读取当前套接字的内容
            QByteArray msg = socketList[i]->readAll();

            //将接受的消息展示到ui界面上
            ui->msgListWidget->addItem(QString::fromLocal8Bit(msg));

            //将收到的消息 全部发给其他客户端
            for (int j=0;j<socketList.length();j++)
            {
                if (i!=j)
                {
                    socketList[j]->write(msg);
                }
            }
        }
    }
}

客户端

widget.h

#ifndef WIDGET_H
#define WIDGET_H


#include <QWidget>
#include<QTcpSocket>         //客户端套接字类
#include<QMessageBox>        //消息对话框类


QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE


class Widget : public QWidget
{
    Q_OBJECT


public:
    Widget(QWidget *parent = nullptr);
    ~Widget();


private slots:
    void on_connectBtn_clicked();
    void connected_slot();           //自定义处理connected信号的槽函数
    void readyRead_slot();           //自定义处理readyRead信号的槽函数
    void disconnected_slot();        //自定义处理disconnected信号的槽函数
    void on_sendBtn_clicked();
    void on_disConnectBtn_clicked();


private:
    Ui::Widget *ui;
    //定义通信用的变量
    QTcpSocket *client;         //定义套接字指针
    QString userName;           //用户名


};
#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);
    //实例化客户端对象
    client = new QTcpSocket(this);

    //当客户端与服务器建立联系后，如果客户端接受到服务器发来的消息
    //客户端自身就会自动发射一个 readyRead的信号，我们可以将该信号连接到自定义的槽函数中执行相关逻辑
    connect(client, &QTcpSocket::readyRead, this, &Widget::readyRead_slot);

    //如果当前客户端成功连接的服务器，那么该客户端就会自动发射一个connected的信号
    //我们可以将该信号连接到自定义的槽函数中处理相关逻辑
    connect(client, &QTcpSocket::connected, this, &Widget::connected_slot);

    //当客户端断开了与服务器的连接后，该客户端就会自动发射一个disconnected的信号
    //我们可以将该信号连接到自定义的槽函数中处理相关逻辑
    connect(client, &QTcpSocket::disconnected, this, &Widget::disconnected_slot);
}


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


//连接服务器按钮对应的槽函数
void Widget::on_connectBtn_clicked()
{
    //获取ui界面上的数据
    QString ip = ui->ipEdit->text();     //ip地址
    quint16 port = ui->portEdit->text().toUInt();    //端口号
    userName = ui->nameEdit->text();              //用户名

    //调用套接字成员函数，连接服务器
    //函数原型：void connectToHost(const QHostAddress &address, quint16 port, OpenMode mode = ReadWrite);
    //参数1：要被连接的服务器ip地址
    //参数2：服务器的端口号
    //参数3：默认为可读可写
    //返回值：无
    client->connectToHost(ip, port);
}


//处理connected信号的槽函数的定义
void Widget::connected_slot()
{
    QMessageBox::information(this,"成功","连接成功");
    //将相关组件禁用
    ui->ipEdit->setEnabled(false);
    ui->nameEdit->setEnabled(false);
    ui->portEdit->setEnabled(false);
    ui->connectBtn->setEnabled(false);

    //向服务器发送一条消息
    QString msg = userName + ": 进入聊天室";
    client->write( msg.toLocal8Bit() );
}


//自定义处理readyRead信号的槽函数
void Widget::readyRead_slot()
{
    //从套接字中读取数据
    QByteArray msg = client->readAll();

    //将读取下来的数据展示到ui界面上
    ui->msgListWidget->addItem( QString::fromLocal8Bit(msg) );
}

//消息发送按钮对应的槽函数
void Widget::on_sendBtn_clicked()
{
    //组织要发送的消息
    QString msg = userName + ": " + ui->msgEdit->text();

    //将消息发送给服务器
    client->write(msg.toLocal8Bit());

    //将消息展示到自己界面上
    //准备一个QListWidgetItem类的对象
    QListWidgetItem *item = new QListWidgetItem(msg);
    item->setTextAlignment(Qt::AlignRight);        //将文本右对齐
    ui->msgListWidget->addItem(item);

    //清空消息发送框的内容
    ui->msgEdit->clear();
}

//断开连接按钮对应的槽函数
void Widget::on_disConnectBtn_clicked()
{
    //执行断开连接的操作
    //准备发送消息给服务器
    QString msg = userName + ": 离开聊天室";
    client->write(msg.toLocal8Bit());

    //断开连接
    client->disconnectFromHost();
}


//自定义处理disconnected信号的槽函数的定义
void Widget::disconnected_slot()
{
    QMessageBox::information(this, "提示", "成功断开与服务器的连接");

    //将相关组件启用
    ui->ipEdit->setEnabled(true);
    ui->nameEdit->setEnabled(true);
    ui->portEdit->setEnabled(true);
    ui->connectBtn->setEnabled(true);
}


http://www.kler.cn/news/305035.html

相关文章：

  • 基于python+django+vue的农产品销售管理系统
  • django-admin自定义功能按钮样式
  • medium_socnet
  • 数据库与表的操作
  • 2024秋季云曦开学考
  • 商业预测 初识R
  • 数据结构基础详解:哈希表【理论计算篇】开放地址法_线性探测法_拉链法详解
  • 文件管理系统DCC与泛微OA系统集成案例
  • JVM面试真题总结（十）
  • HarmonyOS开发者基础认证试题
  • CSP-J阅读程序专题第二题 - 2
  • 回溯——12.N皇后
  • 源码编译安装python3.12没有ssl模块，python3.12 ModuleNotFoundError: No module named ‘_ssl‘
  • 【H2O2|全栈】关于CSS（2）CSS基础（二）
  • Android 设备的独立环境
  • 在Pycharm中使用GitHub
  • JavaScript 中的异步任务、同步任务、宏任务与微任务
  • Vue3 Day1Day2-Vue3优势ref、reactive函数
  • 基于STM32设计的智能家庭防盗系统(华为云IOT)(224)
  • 速盾：你知道高防 IP 和高防 CDN 的区别吗？
  • 846. 树的重心
  • git-fork操作指南
  • Qt_信号与槽
  • 【洛谷】P9752 [CSP-S 2023] 密码锁
  • C++：opencv生成结构元素用于膨胀腐蚀等cv::getStructuringElement
  • 中级练习[6]：Hive SQL订单配送与用户社交行为分析
  • Windows 环境下安装、使用、nodeJs 连接 TiDB 数据库
  • 使用 Milvus、vLLM 和 Llama 3.1 搭建 RAG 应用
  • 外观模式详解：如何为复杂系统构建简洁的接口
  • UE4_后期处理六—夜视仪、扫描线