发帖 回复
返回列表
  • 7519阅读
  • 11回复

[提问]QT网络通信   UDP广播+多线程问题 [复制链接]

 上一主题 下一主题
离线suzhuorui
新手上路
 
只看楼主 倒序阅读 楼主  发表于: 2019-08-14
— 本帖被 圣域天子 从 Qt 作品展 移动到本区(2019-08-21) —
程序A中每次创建5个线程发送广播       但是程序B每次只能接收到2个。代码就是最简单的测试代码，求大佬告知问题所在
回复
举报
分享到 淘江湖 新浪 QQ微博 QQ空间 开心 人人 豆瓣 网易微博 百度 鲜果 白社会 飞信
离线firebolt
侠客
只看该作者 1楼 发表于: 2019-08-14
不明白广播为啥要用5个线程，如果是测试多线程需要给udpSocket加个锁。
回复
举报
离线yunchao630
新手上路
只看该作者 2楼 发表于: 2019-08-15
同上，发送广播的函数互斥一下
回复
举报
离线suzhuorui
新手上路
只看该作者 3楼 发表于: 2019-08-15
回 firebolt 的帖子
firebolt:不明白广播为啥要用5个线程，如果是测试多线程需要给udpSocket加个锁。 (2019-08-14 22:09) 

加锁的话，我是在run函数中加的，也没用呀
如果我想让 for循环中的5个线程 依次发送广播，就是等待第一个线程发送完毕再开始第二个线程，要怎么办呢？
回复
举报
离线suzhuorui
新手上路
只看该作者 4楼 发表于: 2019-08-15
回 suzhuorui 的帖子
suzhuorui:加锁的话，我是在run函数中加的，也没用呀
如果我想让 for循环中的5个线程 依次发送广播，就是等待第一个线程发送完毕再开始第二个线程，要怎么办呢？ (2019-08-15 14:12) 

用计时器可以做到    但是用for循环怎么做呢？求大神指点
回复
举报
离线powerriver
新手上路
只看该作者 5楼 发表于: 2019-08-20
使用信号/槽，不要使用循环的方式，在初始化时
    udpsocket = new QUdpSocket(this);
    bool ret = udpsocket->bind(port, QUdpSocket::ShareAddress|QUdpSocket::ReuseAddressHint);
    if (!ret)
        exit(0);
    connect(udpsocket, SIGNAL(readyRead()), this, SLOT(readPendingDatagrams()));

void Mainwindow::readPendingDatagrams()
{
    while(udpsocket->hasPendingDatagrams())
    {
     .....
回复
举报
离线suzhuorui
新手上路
只看该作者 6楼 发表于: 2019-08-21
回 powerriver 的帖子
powerriver:使用信号/槽，不要使用循环的方式，在初始化时
    udpsocket = new QUdpSocket(this);
    bool ret = udpsocket->bind(port, QUdpSocket::ShareAddress|QUdpSocket::ReuseAddressHint);
    if (!ret)
 &n .. (2019-08-20 22:52) 

我循环只是为了多开线程，而且我也有用到信号槽
我就是想测试一下这个广播，想看看一下子发送的人数多了（就是循环五次开了五个线程） ，   能不能全部接到，但结果是不能的，我也不知道问题出在哪里，所以.......大佬
回复
举报
离线青空飞羽
新手上路
只看该作者 7楼 发表于: 2019-08-21
UdpSend中的udpSocket应该放在run方法里去new吧，这样udpSocket才是属于线程，放到构造函数里new的话还是属于主线程
回复
举报
离线suzhuorui
新手上路
只看该作者 8楼 发表于: 2019-08-21
回 青空飞羽 的帖子
青空飞羽:
UdpSend中的udpSocket应该放在run方法里去new吧，这样udpSocket才是属于线程，放到构造函数里new的话还是属于主线程

青空飞羽:
UdpSend中的udpSocket应该放在run方法里去new吧，这样udpSocket才是属于线程，放到构造函数里new的话还是属于主线程

放进去了，但还是不可以。

我在run函数中加入了一个全局变量，并且加锁看了一下，现在的问题是在第一次点击发送广播按钮后只能接收到0和4，而接下来的每一次都能接收到5次正确的值，这是为什么呢？
回复
举报
离线suzhuorui
新手上路
只看该作者 9楼 发表于: 2019-08-22
问题解决了，上完整的代码

发送端界面cpp
复制代码
  1. #include "mainwindow.h"
  2. #include "ui_mainwindow.h"
  3. #include <QUdpSocket>
  4. #include "udpsend.h"
  5. #include <QMutex>
  8. MainWindow::MainWindow(QWidget *parent) :
  9.     QMainWindow(parent),
  10.     ui(new Ui::MainWindow)
  11. {
  12.       ui->setupUi(this);
  13. }
  16. MainWindow::~MainWindow()
  17. {
  18.       delete ui;
  19. }
  22. int num=0;
  23. QMutex mutex;
  26. void MainWindow::on_pushButton_clicked()
  27. {
  28.       UdpSend *thread[5];
  29.       for(int i=0;i<5;i++)
  30.       {
  31.             mutex.lock();
  32.             qDebug()<<i;
  33.             thread[i]=new UdpSend();
  34.             connect(thread[i],SIGNAL(finished()),this,SLOT(deleteLater()));
  35.             thread[i]->start();
  36.       }
  37. }





发送端线程cpp    
UdpSend线程类
复制代码
  1. [color=#000000]#include "udpsend.h"[/color]
  2. [color=#000000]#include <QMutex>[/color]
  3. [color=#000000]UdpSend::UdpSend(QObject *parent) : QThread(parent)[/color]
  4. [color=#000000]{[/color]
  7. [color=#000000]}[/color]
  10. [color=#000000]extern int num;[/color]
  11. [color=#000000]extern QMutex mutex;[/color]
  14. [color=#000000]void UdpSend::run()[/color]
  15. [color=#000000]{[/color]
  16. [color=#000000]    myUdpSocket=new QUdpSocket(this);[/color]
  17. [color=#000000]    QString data="广播"+QString::number(num);[/color]
  18. [color=#000000]    num++;[/color]
  19. [color=#000000]    myUdpSocket->writeDatagram(data.toUtf8(),QHostAddress::Broadcast,quint16(5555));[/color]
  20. [color=#000000]    mutex.unlock();[/color]
  21. [color=#000000]    exec();[/color]
  22. [color=#000000]}[/color]





接收端cpp


复制代码
  1. #include "mainwindow.h"
  2. #include "ui_mainwindow.h"
  5. MainWindow::MainWindow(QWidget *parent) :
  6.     QMainWindow(parent),
  7.     ui(new Ui::MainWindow)
  8. {
  9.       ui->setupUi(this);
  10.       udpsocket=new QUdpSocket(this);
  11.       udpsocket->bind(QHostAddress::AnyIPv4,quint16(5555));
  12.       connect(udpsocket,SIGNAL(readyRead()),this,SLOT(ricv_msg()));
  13. }
  16. MainWindow::~MainWindow()
  17. {
  18.       delete ui;
  19. }
  22. void MainWindow::ricv_msg()
  23. {
  24.       QHostAddress sendID;
  25.       quint16 sendport;
  26.       QByteArray data;
  27.       if(udpsocket->hasPendingDatagrams())
  28.       {
  29.             data.resize(udpsocket->pendingDatagramSize());
  30.             udpsocket->readDatagram(data.data(),data.size(),&sendID,&sendport);
  31.       }
  32.       QString str="发送端的IP："+sendID.toString()+"  端口号："+QString::number(sendport)+"  内容："+data;
  33.       ui->textBrowser->append(str);
  34. }



总结一下
1.首先使用循环创建多线程时需要加锁
2.在接收端的接收函数不要使用while(udpsocket->hasPendingDatagrams()),而要用if(udpsocket->hasPendingDatagrams())
3.接收数据的大小不能用data.resize(udpsocket->bytesAvailable());，而要用data.resize(udpsocket->pendingDatagramSize());，否则可能会有接收大小不一致，会导致出现意外乱码

以上代码为我个人意见，若有问题请指出来共同进步
回复
举报
离线fsu0413
圣骑士
只看该作者 10楼 发表于: 2019-08-23
回 suzhuorui 的帖子
suzhuorui:问题解决了，上完整的代码
发送端界面cpp
#include "mainwindow.h"
#include "ui_mainwindow.h"
....... (2019-08-22 09:56) 

用if肯定是错的，应该用while，后面的处理应该放到while里
回复
举报
离线suzhuorui
新手上路
只看该作者 11楼 发表于: 2019-08-23
回 fsu0413 的帖子
fsu0413:用if肯定是错的，应该用while，后面的处理应该放到while里 (2019-08-23 08:33) 

卧槽，我试了一下，果然可以。想了想if是只执行一次，while是可以接收一个用户的多个包。谢谢大佬指出错误
回复
举报
发帖 回复
返回列表
快速回复
限100 字节
 
上一个 下一个