1. // widget.h
    2. #include <QWidget>
    3. #include <QUdpSocket>
    5. QT_BEGIN_NAMESPACE
    6. namespace Ui { class Widget; }
    7. QT_END_NAMESPACE
    9. class Widget : public QWidget
    10. {
    11.     Q_OBJECT
    13. public:
    14.     Widget(QWidget *parent,QString name);
    15.     ~Widget();
    16.     void closeEvent(QCloseEvent *);
    18. private:
    19.     Ui::Widget *ui;
    21. signals:
    22.     void closeWidget();   // 关闭窗口发送信号
    24. public:
    25.     enum MsgType {Msg,UsrEnter,UsrLeft};
    26.     void sndMsg(MsgType type); // 广播UDP消息
    27.     void usrEnter(QString userName);    // 处理新用户加入
    28.     void usrLeft(QString userName);     // 处理用户离开
    29.     QString getUsrName();   // 获取用户名
    30.     QString getMsg();       // 获取聊天信息
    31. private:
    32.     QUdpSocket* udpSocket;  // Udp套接字
    33.     qint16 port;            // 端口
    34.     QString uName;          // 用户名
    35.     void recvMsg();         // 接收Udp消息
    36. };
    1. // widget.cpp
    2. #include "widget.h"
    3. #include "ui_widget.h"
    4. #include <QDataStream>
    5. #include <QMessageBox>
    6. #include <QDateTime>
    8. Widget::Widget(QWidget *parent,QString name)
    9.     : QWidget(parent)
    10.     , ui(new Ui::Widget)
    11. {
    12.     ui->setupUi(this);
    14.     // 初始化操作
    15.     udpSocket = new QUdpSocket(this);   // 套接字
    16.     uName = name;   // 用户名
    17.     port = 9999;    // 端口号
    18.     /*
    19.      * ShareAddress模式, 允许不同的服务连接到相同的地址和端口,常用于多客户端监听同一个服务器端口
    20.      * ReuseAddressHint模式, 断线重新连接服务器
    21.      */
    22.     udpSocket->bind(port,QUdpSocket::ShareAddress|QUdpSocket::ReuseAddressHint);  // 绑定端口号
    23.     //sndMsg(UsrEnter);   // 发送新用户进入
    24.     // 点击发送按钮发送消息
    25.     connect(ui->Btn_Send,&QPushButton::clicked,[=](){
    26.         sndMsg(Msg);
    27.     });
    28.     // 监听别人发送的数据
    29.     connect(udpSocket,&QUdpSocket::readyRead,this,&Widget::recvMsg);
    30. }
    32. Widget::~Widget()
    33. {
    34.     delete ui;
    35. }
    37. void Widget::closeEvent(QCloseEvent*)
    38. {
    39.     emit closeWidget();
    40. }
    42. void Widget::sndMsg(Widget::MsgType type)
    43. {
    44.     // 发送的消息分为3种类型
    45.     // 发送的数据分3段处理. 第一段,类型;   第二段,用户名;    第三段,具体内容
    46.     QByteArray array;
    47.     QDataStream stream(&array,QIODevice::WriteOnly);
    48.     stream << type << getUsrName(); // 类型 和 用户名, 添加到流中
    50.     switch (type) {
    51.     case Msg:       // 普通消息发送
    52.         if(ui->msgTxtEdit->toPlainText() == "")
    53.         {   // 如果用户没有输入内容,不发消息
    54.             QMessageBox::warning(this,"警告","发送内容不能为空");
    55.             return;
    56.         }
    57.         stream << getMsg(); // 具体内容, 添加到流中
    58.         break;
    59.     case UsrEnter:
    61.         break;
    63.     case UsrLeft:
    65.         break;
    66.     default:
    67.         break;
    68.     }
    69.     // 书写报文
    70.     udpSocket->writeDatagram(array,QHostAddress::Broadcast,port);
    71. }
    73. QString Widget::getUsrName()
    74. {
    75.     return uName;
    76. }
    78. QString Widget::getMsg()
    79. {
    80.     QString str = ui->msgTxtEdit->toHtml();
    81.     ui->msgTxtEdit->clear();        // 清空输入框
    82.     ui->msgTxtEdit->setFocus();
    83.     return str;
    84. }
    86. void Widget::recvMsg()
    87. {
    88.     // 获取报文长度
    89.     qint64 size = udpSocket->pendingDatagramSize();
    90.     // 读取报文
    91.     QByteArray array = QByteArray(size,0);
    92.     udpSocket->readDatagram(array.data(),size);
    93.     // 解析数据
    94.     QDataStream stream(&array,QIODevice::ReadOnly); // 从array中读取数据到stream中
    95.     // 定义接收三段数据的三个变量
    96.     int msgType;
    97.     QString usrName;
    98.     QString msg;
    99.     stream >> msgType;  // 从stream中取出 类型
    100.     // 获取当前时间
    101.     QString time = QDateTime::currentDateTime().toString("yyyy-MM-dd hh-mm-ss");
    102.     switch (msgType) {
    103.     case Msg:
    104.         stream >> usrName >> msg;   // 从stream中取出 用户名 和 具体内容
    105.         // 追加聊天记录
    106.         ui->msgBrowser->setTextColor(Qt::blue); // 设置聊天框文本颜色
    107.         ui->msgBrowser->append("[" + usrName + "]" + time);
    108.         ui->msgBrowser->append(msg);
    109.         break;
    110.     case UsrEnter:
    112.         break;
    114.     case UsrLeft:
    116.         break;
    117.     default:
    118.         break;
    119.     }
    120. }