• QTday05（TCP的服务端客户端通信）

    实现聊天室功能

    服务端代码：

    pro文件需要导入  network

    头文件：

    1. #ifndef WIDGET_H
    2. #define WIDGET_H
    3.  
    4. #include 
    5. #include //服务端
    6. #include //客户端
    7. #include 
    8. #include 
    9. #include 
    10.  
    11. QT_BEGIN_NAMESPACE
    12. namespace Ui { class Widget; }
    13. QT_END_NAMESPACE
    14.  
    15. class Widget : public QWidget
    16. {
    17.     Q_OBJECT
    18.  
    19. public:
    20.     Widget(QWidget *parent = nullptr);
    21.     ~Widget();
    22.  
    23. private slots:
    24.     void on_startBtn_clicked();
    25. public slots:
    26.     void newConnectSlot();//建立连接的槽函数
    27.     void readyReadSlot();//接收消息的槽函数
    28.  
    29. private:
    30.     Ui::Widget *ui;
    31.  
    32.     //实例化服务器对象
    33.     QTcpServer *server;
    34.     //创建存放客户端信息的容器
    35.     QList socketList;
    36. };
    37. #endif // WIDGET_H

    widget.cpp

    1. #include "widget.h"
    2. #include "ui_widget.h"
    3.  
    4. Widget::Widget(QWidget *parent)
    5.     : QWidget(parent)
    6.     , ui(new Ui::Widget)
    7. {
    8.     ui->setupUi(this);
    9.  
    10.     //实例化服务器对象
    11.     server=new QTcpServer(this);
    12.  
    13. }
    14.  
    15. Widget::~Widget()
    16. {
    17.     delete ui;
    18. }
    19.  
    20.  
    21. void Widget::on_startBtn_clicked()
    22. {
    23.     //监听任意ip的指定端口
    24.     bool listen_res=server->listen(QHostAddress::Any,ui->portLine->text().toUInt());
    25.     if(listen_res){
    26.         //监听成功
    27.         QMessageBox::information(this,"提示","设置监听成功",QMessageBox::Ok);
    28.  
    29.     }else{
    30.         //监听失败
    31.         QMessageBox::information(this,"提示","设置监听失败",QMessageBox::Ok);
    32.         return;
    33.     }
    34.     //等待连接
    35.     connect(server,&QTcpServer::newConnection,this,&Widget::newConnectSlot);
    36. }
    37.  
    38. void Widget::newConnectSlot()
    39. {
    40.     //接收到newConnect信号之后的槽函数，处理接下来的操作
    41.  
    42.     //获取客户端的套接字,加入容器
    43.     QTcpSocket *s=server->nextPendingConnection();
    44.     socketList.push_back(s);
    45.     qDebug() << "有新客户连接" << s->peerName() << ";" << s->peerAddress().toString() << ":" << QString::number(s->peerPort()) <
    46.     //此时如果客户端向服务器发送数据，客户端会发送一个readyRead信号
    47.     connect(s,&QTcpSocket::readyRead,this,&Widget::readyReadSlot);
    48. }
    49.  
    50. void Widget::readyReadSlot()
    51. {
    52.     //客户端有数据发送，触发改槽函数
    53.     //遍历容器,移除无效客户端，接收有效客户端消息
    54.     for (int i=0;icount();i++) {
    55.         //如果是非链接状态就移除
    56.         if(socketList.at(i)->state()==QAbstractSocket::UnconnectedState){
    57.             socketList.removeAt(i);
    58.         }
    59.     }
    60.     for (int i=0;icount();i++) {
    61.         //如果有字节，就读取并放到ui界面
    62.         if(socketList.at(i)->bytesAvailable()){
    63.             QByteArray msg=socketList.at(i)->readAll();
    64.             QString msgInfo=socketList.at(i)->peerAddress().toString()+":"+QString::number(socketList.at(i)->peerPort())+":"+QString::fromLocal8Bit(msg);
    65.             ui->listWidget->addItem(msgInfo);
    66.             for (int j=0;jcount();j++) {
    67.                 socketList.at(j)->write(msg);
    68.             }
    69.         }
    70.     }
    71. }

    ui:

    客户端代码：

    头文件

    1. #ifndef WIDGET_H
    2. #define WIDGET_H
    3.  
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8.  
    9. QT_BEGIN_NAMESPACE
    10. namespace Ui { class Widget; }
    11. QT_END_NAMESPACE
    12.  
    13. class Widget : public QWidget
    14. {
    15.     Q_OBJECT
    16.  
    17. public:
    18.     Widget(QWidget *parent = nullptr);
    19.     ~Widget();
    20.  
    21. private slots:
    22.     void on_connnectBtn_clicked();
    23.  
    24.     void on_disconnectBtn_clicked();
    25.  
    26.     void on_sendBtn_clicked();
    27.  
    28. public slots:
    29.     void connnectedSlot();
    30.     void readyReadSlot();
    31.     void disconnectedSlot();
    32.  
    33. private:
    34.     Ui::Widget *ui;
    35.  
    36.     //实例化客户端
    37.     QTcpSocket *socket;
    38.     //定义全局变量存储用户名
    39.     QString username;
    40. };
    41. #endif // WIDGET_H

    widget.cpp

    1. #include "widget.h"
    2. #include "ui_widget.h"
    3.  
    4. Widget::Widget(QWidget *parent)
    5.     : QWidget(parent)
    6.     , ui(new Ui::Widget)
    7. {
    8.     ui->setupUi(this);
    9.     //实例化客户端
    10.     socket=new QTcpSocket(this);
    11.     //将发送和断开连接 的按钮默认设置不可用
    12.     ui->sendBtn->setDisabled(true);
    13.     ui->disconnectBtn->setDisabled(true);
    14.  
    15.     ui->accoutLine->setText("张三");
    16.     ui->ipLine->setText("192.168.125.77");
    17.     ui->portLine->setText("8888");
    18.     //连接成功会触发connected信号，只需要一次
    19.     connect(socket,&QTcpSocket::connected,this,&Widget::connnectedSlot);
    20.  
    21.     //收信号
    22.     connect(socket,&QTcpSocket::readyRead,this,&Widget::readyReadSlot);
    23.  
    24.     connect(socket,&QTcpSocket::disconnected,this,&Widget::disconnectedSlot);
    25. }
    26.  
    27. Widget::~Widget()
    28. {
    29.     delete ui;
    30. }
    31.  
    32.  
    33. void Widget::on_connnectBtn_clicked()
    34. {
    35.     //连接服务器
    36.     username=ui->accoutLine->text();
    37.     QString ip=ui->ipLine->text();
    38.     quint16 port=ui->portLine->text().toUInt();
    39.     socket->connectToHost(ip,port);
    40.     //判断是否连接成功：连接成功后，户端会自动发射一个connected信号,
    41.  
    42. }
    43.  
    44. void Widget::connnectedSlot()
    45. {
    46.     QMessageBox::information(this,"提示","连接成功");
    47.  
    48.     QString msg=username+"进入聊天室";
    49.     socket->write(msg.toLocal8Bit());
    50.  
    51.     ui->sendBtn->setDisabled(false);
    52.     ui->connnectBtn->setDisabled(true);
    53.     ui->disconnectBtn->setDisabled(false);
    54.  
    55. }
    56.  
    57. void Widget::on_disconnectBtn_clicked()
    58. {
    59.  
    60.     QString msg=username+"离开聊天室";
    61.     socket->write(msg.toLocal8Bit());
    62.     socket->disconnectFromHost();
    63.  
    64. }
    65.  
    66. void Widget::on_sendBtn_clicked()
    67. {
    68.     if(ui->infoLine->text().isEmpty()){
    69.         QMessageBox::information(this,"提示","发送的消息不能为空");
    70.         return;
    71.     }
    72.     QString msg=ui->infoLine->text();
    73.     socket->write(msg.toLocal8Bit());
    74.     ui->infoLine->setText("");
    75. }
    76. void Widget::readyReadSlot(){
    77.     QByteArray msg=socket->readAll();
    78.  
    79.     ui->listWidget->addItem(QString::fromLocal8Bit(msg));
    80. }
    81.  
    82. void Widget::disconnectedSlot()
    83. {
    84.     ui->sendBtn->setDisabled(true);
    85.     ui->disconnectBtn->setDisabled(true);
    86.     ui->connnectBtn->setDisabled(false);
    87.     QMessageBox::information(this,"提示","断开连接成功");
    88. }

    ui:

    运行结果：客户端连接之后可以成功发送信息

    今日思维导图：

    将聊天功能加入到仿qq登录之后：

    代码：

    page2.h:

    1. #ifndef PAGE2_H
    2. #define PAGE2_H
    3.  
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9. #define PORT 8888
    10. #define IP "192.168.125.77"
    11.  
    12. namespace Ui {
    13. class Page2;
    14. }
    15.  
    16. class Page2 : public QWidget
    17. {
    18.     Q_OBJECT
    19.  
    20. public:
    21.     explicit Page2(QWidget *parent = nullptr);
    22.     ~Page2();
    23. public slots:
    24.     void login_slot();
    25.     void connectedSlot();
    26.     void readyReadSlot();
    27. private slots:
    28.     void on_sendBtn_clicked();
    29.  
    30. private:
    31.     Ui::Page2 *ui;
    32.  
    33.     QTcpSocket *socket;
    34.  
    35. };
    36.  
    37. #endif // PAGE2_H

    widget.h:

    1. #ifndef WIDGET_H
    2. #define WIDGET_H
    3.  
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9.  
    10.  
    11. QT_BEGIN_NAMESPACE
    12. namespace Ui { class Widget; }
    13. QT_END_NAMESPACE
    14.  
    15. class Widget : public QWidget
    16. {
    17.     Q_OBJECT
    18.  
    19. public:
    20.     Widget(QWidget *parent = nullptr);
    21.     ~Widget();
    22.  
    23.     void mousePressEvent(QMouseEvent *event) override;
    24.     void mouseMoveEvent(QMouseEvent *event) override;
    25.  
    26. public slots:
    27.     void loginButton_slot();
    28.  
    29.  
    30. signals:
    31.     void login_signal();
    32.  
    33. private:
    34.     Ui::Widget *ui;
    35.  
    36.     QPoint p;//定义全局变量p，记录位置
    37. public:
    38.     static QString username;
    39. };
    40.  
    41. #endif // WIDGET_H

    main.cpp:

    1. #include "widget.h"
    2. #include "page2.h"
    3.  
    4. #include 
    5.  
    6. int main(int argc, char *argv[])
    7. {
    8.     QApplication a(argc, argv);
    9.     Widget w;
    10.     w.show();
    11.  
    12.     Page2 p2;
    13.     QObject::connect(&w,&Widget::login_signal,&p2,&Page2::login_slot);
    14.     return a.exec();
    15. }

    page2.cpp:

    1. #include "page2.h"
    2. #include "widget.h"
    3. #include "ui_page2.h"
    4.  
    5. Page2::Page2(QWidget *parent) :
    6.     QWidget(parent),
    7.     ui(new Ui::Page2)
    8. {
    9.     ui->setupUi(this);
    10.     QMovie *movie = new QMovie(":/111/cai.gif");
    11.     ui->label->setMovie(movie);
    12.     ui->label->setScaledContents(true);
    13.     movie->start();
    14.     //实例化客户端
    15.     socket=new QTcpSocket(this);
    16.     qDebug() << "实例化客户端";
    17.     //建立connected信号和指定槽函数的连接
    18.     connect(socket,&QTcpSocket::connected,this,&Page2::connectedSlot);
    19.     //建立readyRead信号和指定槽函数连接
    20.     connect(socket,&QTcpSocket::readyRead,this,&Page2::readyReadSlot);
    21.  
    22. }
    23.  
    24. Page2::~Page2()
    25. {
    26.     delete ui;
    27. }
    28.  
    29. void Page2::login_slot()
    30. {
    31.     qDebug() << "登录按钮";
    32.     this->show();
    33.     //连接客户端
    34.     socket->connectToHost(IP,PORT);
    35. }
    36.  
    37. void Page2::connectedSlot()
    38. {
    39.     //连接成功后触发该槽函数
    40.     qDebug() << "连接成功";
    41.     QMessageBox::information(this,"提示","连接成功");
    42.  
    43.     QString msg=Widget::username+"加入了聊天";
    44.     socket->write(msg.toLocal8Bit());
    45. }
    46.  
    47. void Page2::readyReadSlot()
    48. {
    49.     //收到服务端发送的消息时触发该槽函数
    50.     QByteArray msg=socket->readAll();
    51.     ui->listWidget->addItem(QString::fromLocal8Bit(msg));
    52. }
    53.  
    54. void Page2::on_sendBtn_clicked()
    55. {
    56.     if(ui->infoEdit->toPlainText().isEmpty()){
    57.         QMessageBox::information(this,"提示","发送的消息不能为空");
    58.         return;
    59.     }
    60.     QString msg=ui->infoEdit->toPlainText();
    61.     socket->write(msg.toLocal8Bit());
    62.     ui->infoEdit->clear();
    63. }

    widget.cpp:

    1. #include "widget.h"
    2. #include "ui_widget.h"
    3. QString Widget::username="";
    4. Widget::Widget(QWidget *parent)
    5.     : QWidget(parent)
    6.     , ui(new Ui::Widget)
    7. {
    8.     ui->setupUi(this);
    9.     this->setFixedSize(560,430);
    10.     this->setStyleSheet("background-color:#faf7ec");
    11.     this->setWindowFlag(Qt::FramelessWindowHint);//无边框
    12.     QMovie *movie = new QMovie(":/111/cai.gif");
    13.     ui->backLabel->setMovie(movie);
    14.     ui->backLabel->setScaledContents(true);
    15.     movie->start();
    16.  
    17.     ui->closeButton->setStyleSheet("border-image:url(:/111/basketball.png)");
    18.  
    19.  
    20.     ui->avatorLabel->resize(60,60);
    21.     ui->avatorLabel->setStyleSheet("border-image:url(:/111/user.png);border-radius:30px");
    22.  
    23.     ui->accountLabel->setPixmap(QPixmap(":/111/account.jpg"));
    24.     //ui->accountLabel->resize(40,40);
    25.     ui->accountLabel->setScaledContents(true);
    26.  
    27.     ui->passwdLabel->setPixmap(QPixmap(":/111/passwd.jpg"));
    28.     //ui->passwdLabel->resize(40,40);
    29.     ui->passwdLabel->setScaledContents(true);
    30.  
    31.     ui->accoountLine->setPlaceholderText("账号");
    32.     ui->passwdLine->setPlaceholderText("密码");
    33.     ui->passwdLine->setEchoMode(QLineEdit::Password);
    34.  
    35.     ui->loginLabel->setPixmap(QPixmap(":/111/2.png"));
    36.     ui->loginLabel->setScaledContents(true);
    37.  
    38.     ui->loginButton->setStyleSheet("background-color:#409EFF;border-radius:5px");
    39.  
    40.     connect(ui->closeButton,SIGNAL(clicked()),this,SLOT(close()));
    41.  
    42.     connect(ui->loginButton,&QPushButton::clicked,this,&Widget::loginButton_slot);
    43.  
    44. }
    45.  
    46. Widget::~Widget()
    47. {
    48.     delete ui;
    49. }
    50.  
    51.  
    52. void Widget::loginButton_slot()
    53. {
    54.     //判断用户账号密码的正确性
    55.     if(ui->accoountLine->text()=="admin"&&ui->passwdLine->text()=="123456"){
    56.         username="admin";
    57.         qDebug() << "登录成功" <
    58.         QMessageBox::information(this,"提示","登录成功",QMessageBox::Ok);
    59.         this->close();
    60.         //开启新窗口,手动触发信号
    61.         emit login_signal();
    62.     }else{
    63.         qDebug() << "账号或者密码错误" <
    64.         int res=QMessageBox::information(this,"提示","账号或者密码错误,是否继续登录",QMessageBox::Ok|QMessageBox::No);
    65.         if(res==QMessageBox::Ok){
    66.             ui->passwdLine->setText("");
    67.         }else{
    68.             this->close();
    69.         }
    70.  
    71.     }
    72. }
    73. void Widget::mousePressEvent(QMouseEvent *event){
    74.     p=event->pos();
    75. }
    76. void Widget::mouseMoveEvent(QMouseEvent *event){
    77.     if(event->buttons()==Qt::LeftButton)
    78.     this->move(event->globalPos()-p);
    79. }
    80.

    page2.ui:

    widget.ui:

    运行结果：

  • 相关阅读:
    第18章_瑞萨MCU零基础入门系列教程之GPT
    去面试了几家BATJ等N家互联网大厂
    【LeetCode】【剑指offer】【队列的最大值（二）】
    熟悉又陌生的package.json
    【嵌入式开发 Linux 常用命令系列 7.2 -- awk 找到空格并插入字符】
    Activiti进阶
    【gcc/g++】2.三大编译方式(直接编译库 静态链接库 动态链接库)
    2024年（上海） 集成软件及系统管理博览会
    uniapp 底部导航 点击刷新当前页
    基本算法模板整理——链表，二叉树，快速排序
  • 原文地址：https://blog.csdn.net/weixin_53762703/article/details/133965142