经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 程序设计 » C++ » 查看文章
65.QT-UDP组播实现多人共享桌面(同时支持收发显示)
来源：cnblogs　　作者：诺谦　　时间：2021/6/28 9:42:42　　对本文有异议

这里我们只是简单学习下通过udp组播如何共享桌面demo.帧率上面比较低,毕竟没有用推流,只是简单的将图片发送到组播地址,而加入组播地址的客户端去取数据显示而已.

主要是为了学习UDP知识而写的,真的想要做共享桌面的话,建议还是使用qt FFmpeg推流.速度上会快很多(后续有时间再来出)

1.Demo介绍

截图如下所示:

gif效果如下所示(有点大,加载有点久):

功能介绍

  • 一份代码同时支持收数据处理和发数据处理.
  • 自动检查帧率和每帧图片字节大小
  • 代码中使用了多线程和队列协助QWidget显示.
  • 当接收共享时,会在线程中不停接收数据,直到接收到完整的一份数据时,则放到队列中,然后供QWidget提取数据.
  • 当开启共享时,则在线程中抓取桌面数据,实时发送,并备份一个QPixmap供QWidget显示数据

 

代码和可以直接运行的程序都放在群里,需要的自行下载:

 

 

 

2.sharescreenthread.cpp代码如下所示

  1. #include "sharescreenthread.h"
  3. ShareScreenThread::ShareScreenThread(QThread *parent) : QThread(parent),
  4.     m_state(ShareScreen_None),
  5.     groupAddress("239.255.43.21"),
  6.     m_runCnt(0),
  7.     m_canRead(false),
  8.     m_sendQuality(20)
  9. {
  10.     m_recvQueue.clear();
  11. }
  14. bool ShareScreenThread::startGrabWindow()
  15. {
  16.     QMutexLocker locker(&m_mutex);
  17.     if (m_state == ShareScreen_Stop || m_state == ShareScreen_SendRunning) {
  18.         m_state = ShareScreen_SendRunning;
  19.         emit stateChange();
  20.         return true;
  21.     }
  22.     return false;
  23. }
  25. bool ShareScreenThread::stopGrabWindow()
  26. {
  27.     QMutexLocker locker(&m_mutex);
  28.     if (m_state == ShareScreen_SendRunning || m_state == ShareScreen_Stop) {
  29.         m_state = ShareScreen_EnterStop;
  30.         return true;
  31.     }
  33.     return false;
  34. }
  35. void ShareScreenThread::run()
  36. {
  37.     m_udp = new QUdpSocket();
  38.     qDebug()<<"绑定:"<<m_udp->bind(QHostAddress::AnyIPv4, 44544, QUdpSocket::ShareAddress | QUdpSocket::ReuseAddressHint);
  39.     qDebug()<<"加入:"<<m_udp->joinMulticastGroup(groupAddress);
  41.     while(1) {
  43.         switch (m_state) {
  44.             case ShareScreen_None:
  45.                 m_runCnt++;
  46.                 if (m_runCnt > 100) {
  47.                     m_state = ShareScreen_Stop;
  48.                     m_preGetWindowMSec = QDateTime::currentDateTime().toMSecsSinceEpoch();     //记录时间
  49.                     emit stateChange();
  50.                 }
  51.                 msleep(10);
  52.                 if(m_udp->hasPendingDatagrams() ) {
  53.                     m_state = ShareScreen_RecvRunning;
  54.                     emit stateChange();
  55.                     m_preGetWindowMSec = QDateTime::currentDateTime().toMSecsSinceEpoch();     //记录时间
  56.                     getWindow();
  57.                 }
  58.                 break;
  59.             case ShareScreen_Stop:
  60.                 if(m_udp->hasPendingDatagrams()) {
  61.                     m_state = ShareScreen_RecvRunning;
  62.                     emit stateChange();
  63.                     getWindow();
  64.                 }
  65.                 break;
  66.             case ShareScreen_RecvRunning:
  67.                 getWindow();
  68.                 break;
  69.             case ShareScreen_SendRunning:
  70.                 grabWindow();
  71.                 break;
  72.             case ShareScreen_EnterStop:     // 由于广播,自己会受到自己消息,需要清空
  73.                 if (m_udp->hasPendingDatagrams() ) {
  74.                     m_udp->receiveDatagram();
  75.                 } else {
  76.                     m_state = ShareScreen_Stop;
  77.                     emit stateChange();
  78.                 }
  79.                 break;
  81.             default: break;
  82.         }
  84.     }
  85. }

3.widget.cpp代码如下所示

  1. #include "widget.h"
  2. #include "ui_widget.h"
  3. Widget::Widget(QWidget *parent)
  4.     : QWidget(parent),
  5.       ui(new Ui::Widget)
  7. {
  8.     ui->setupUi(this);
  9.     connect(&m_thread, SIGNAL(stateChange()), this, SLOT(onStateChange()));
  10.     m_thread.start();
  12.     connect(&m_updateShow, SIGNAL(timeout()), this, SLOT(onUpdateShow()));
  14.     setWindowTitle("UDP共享屏幕");
  15. }
  17. Widget::~Widget()
  18. {
  19.     m_thread.terminate();
  20.     delete ui;
  21. }
  23. void Widget::onStateChange()
  24. {
  25.     qDebug()<<"onStateChange"<<m_thread.state();
  26.     switch (m_thread.state()) {
  27.         case ShareScreenThread::ShareScreen_None:  break;
  28.         case ShareScreenThread::ShareScreen_Stop: ui->labelHint->setText("等待共享..."); cleanShow(); ui->comboQuality->setEnabled(true); break;
  29.         case ShareScreenThread::ShareScreen_RecvRunning: ui->labelHint->setText("有人正在共享中?");
  31.             m_pressMSec = QDateTime::currentDateTime().toMSecsSinceEpoch();     //记录的时间
  32.             m_updateShowCnt = 0;
  33.             m_updateShow.start(25);
  34.             ui->comboQuality->setEnabled(false);
  35.             break;
  36.         case ShareScreenThread::ShareScreen_SendRunning: ui->labelHint->setText("您正在共享中?"); ui->comboQuality->setEnabled(true); break;
  37.         default: break;
  38.     }
  39. }
  41. void Widget::cleanShow()
  42. {
  43.     ui->labelShow->clear();
  44.     ui->labelByte->setText(QString("每帧: %1KB").arg(0));
  45.     ui->labelFPS->setText("当前FPS: "+ QString("%1").arg(0));
  47. }
  50. void Widget::onUpdateShow()
  51. {
  52.     bool getOk = false;
  53.     int size = 0;
  54.     QPixmap pix(m_thread.getPixmap(getOk, size));
  55.     QSize imageSize =pix.size();
  56.     if (size!=0)
  57.         ui->labelByte->setText(QString("每帧: %1KB").arg(size/1024));
  59.     if (getOk == false)
  60.         return;
  62.     pix = pix.scaled(ui->labelShow->size(), Qt::KeepAspectRatio);
  64.     if (m_thread.state() == ShareScreenThread::ShareScreen_RecvRunning) {
  65.         QPainter painter(&pix);
  66.         painter.setRenderHints(QPainter::Antialiasing);
  67.         QPixmap mouse(":/mouse");
  68.         double xratio = pix.width() / (double)imageSize.width();
  69.         double yratio = pix.height() / (double)imageSize.height();
  70.         painter.drawPixmap(m_thread.getMousePos().x()*xratio, m_thread.getMousePos().y()*yratio , 25*xratio, 25*yratio, mouse);
  72.     }
  74.     ui->labelShow->setPixmap(pix);
  76.     if (m_updateShowCnt++ >= 10) {
  77.         qint64 tmp = QDateTime::currentDateTime().toMSecsSinceEpoch();
  78.         qint64 durationMs = tmp - m_pressMSec;
  80.         int fps = m_updateShowCnt * 1000/durationMs;
  81.         ui->labelFPS->setText("当前FPS: "+ QString("%1").arg(fps));
  83.         m_updateShowCnt = 0;
  84.         m_pressMSec = tmp;
  85.     }
  87. }
  89. void Widget::on_btnStartShare_clicked()
  90. {
  91.     bool question;
  92.     switch (m_thread.state()) {
  93.         case ShareScreenThread::ShareScreen_None: customDialog::ShowMessageErr(this,"提示", "正在初始化中!"); return;
  94.         case ShareScreenThread::ShareScreen_Stop: cleanShow(); break;
  95.         case ShareScreenThread::ShareScreen_RecvRunning: customDialog::ShowMessageInfo(this,"提示", "有人正在共享中!"); return;
  96.         case ShareScreenThread::ShareScreen_SendRunning:  question = customDialog::ShowMessageQuestion(this,"询问", "是否取消共享?");
  97.             if (!question)
  98.                 return;
  99.     }
  103.     bool myStartd = ui->btnStartShare->text().contains("停止");
  105.     if (myStartd) {
  106.         m_thread.stopGrabWindow();
  107.         ui->btnStartShare->setText("开始共享");
  108.         ui->labelFPS->setText("当前FPS: 0");
  109.         m_updateShow.stop();
  111.         ui->labelShow->setPixmap(QPixmap());
  112.     } else {
  113.         m_thread.startGrabWindow();
  114.         ui->btnStartShare->setText("停止共享");
  115.         m_pressMSec = QDateTime::currentDateTime().toMSecsSinceEpoch();     //记录的时间
  116.         m_updateShowCnt = 0;
  117.         m_updateShow.start(12);
  118.     }
  120. }
  122. void Widget::keyPressEvent(QKeyEvent *event)
  123. {
  126.    if (ui->control->isHidden() && event->key() == Qt::Key_Escape) {
  127.         ui->control->show();
  128.         showMaximized();
  130.    }
  132. }
  135. void Widget::on_btnFull_clicked()
  136. {
  137.     ui->control->hide();
  138.     showFullScreen();
  140. }
  142. void Widget::on_comboQuality_currentIndexChanged(int index)
  143. {
  145.     switch (index) {
  146.         case 0 : m_thread.setQuality(20); break;
  147.         case 1 : m_thread.setQuality(38); break;
  148.         case 2 : m_thread.setQuality(50); break;
  149.     }
  150. }

 

原文链接：http://www.cnblogs.com/lifexy/p/14926509.html

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

C++热门文章

  • C/C++编程笔记：编写不会在C ++中编译的C程序，我教你呀！
  • 洛谷 P2085 最小函数值
  • 使用C++界面框架ImGUI开发一个简单程序
  • C++ Json解析CJsonObject的详细使用
  • C++编译错误杂记
  • 二分法（二）：采用二分法解决“最小化最大值问题”
  • C++实现json字符串与map的转换
  • C++借助curses库实现俄罗斯方块
  • 长乐培训Day5
  • 【OpenFOAM】——OpenFOAM入门算例学习

    • C++推荐文章

  • #8. 「模板」树链剖分
  • 预设型 DP
  • Standard Template Libary or C++ Standard Library
  • 一种优秀的虚拟机内存架构 - AQ
  • 如何让 MGR 不从 Primary 节点克隆数据？
  • TLScanary：Pwn中的利器
  • c++临时对象导致的生命周期问题
  • C++(Qt)-GIS开发-简易瓦片地图下载器
  • 逆向通达信 x 逆向微信 x 逆向Qt
  • C++面向对象

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号