Multicast über WLAN empfangen

#include "mainwindow.h"

#include <QApplication>

#include <QUdpSocket>

#include <QNetworkInterface>

#include <QList>

#include <QDebug>

#include <QThread>

int main(int argc, char *argv[])

{

    QApplication a(argc, argv);

    MainWindow w;

    QList<QNetworkInterface> mListIfaces = QNetworkInterface::allInterfaces();

    QHostAddress groupAddress = QHostAddress("224.0.23.12");

    for (QList<QNetworkInterface>::iterator iter_if = mListIfaces.begin(); iter_if != mListIfaces.end(); iter_if++) {

       qDebug() << "======" << iter_if->humanReadableName();// << (mListIfaces.at(i).flags() & QNetworkInterface::CanMulticast) << (mListIfaces.at(i).flags() & QNetworkInterface::IsLoopBack << mListIfaces.at(i).isValid()?"ja":"nein");

        if ((iter_if->flags() & QNetworkInterface::CanMulticast) == 0) {

            continue;

        }

        if ((iter_if->flags() & QNetworkInterface::IsLoopBack) > 0) {

            continue;

        }

        QList<QNetworkAddressEntry> ha_all = iter_if->addressEntries();

        for (QList<QNetworkAddressEntry>::iterator ha_iter = ha_all.begin(); ha_iter != ha_all.end(); ha_iter++) {

            if (ha_iter->ip().protocol() != QAbstractSocket::NetworkLayerProtocol::IPv4Protocol) {

                continue;

            }

            qDebug() << ha_iter->ip().toString();

            QUdpSocket *sock_rx;

            sock_rx = new QUdpSocket();

            bool rez = sock_rx->bind(ha_iter->ip(), 3671, QUdpSocket::ShareAddress | QUdpSocket::ReuseAddressHint);

            qDebug() << "bind" << rez;

            if (!rez) {

                continue;

            }

            if (iter_if->humanReadableName() != "WLAN") {

                continue;

            }

            rez = sock_rx->joinMulticastGroup(groupAddress, *iter_if);

            QObject::connect(sock_rx,SIGNAL(channelReadyRead(int)),&w,SLOT(onUdpRx(int)));

            QUdpSocket *sock_tx = new QUdpSocket();

            sock_tx->bind(ha_iter->ip());

            QByteArray ss = QByteArrayLiteral("\x06\x10\x02\x01\x00\x0e\x08\x01");

            uint32_t ip = ha_iter->ip().toIPv4Address();

            ss.append((unsigned char)((ip >> 24) & 0xFF));

            ss.append((unsigned char)((ip >> 16) & 0xFF));

            ss.append((unsigned char)((ip >> 8) & 0xFF));

            ss.append((unsigned char)(ip & 0xFF));

            ss.append((uint8_t)((sock_rx->localPort() >> 8) & 0xFF));

            ss.append((uint8_t)((sock_rx->localPort()) & 0xFF));

            sock_tx->writeDatagram((const char*)ss.data(),ss.length(),QHostAddress("224.0.23.12"),3671);

            qDebug() << iter_if->humanReadableName() << rez << sock_rx->errorString();

        }

    }

    w.show();

    return a.exec();

}

#ifndef MAINWINDOW_H

#define MAINWINDOW_H

#include <QMainWindow>

namespace Ui {

class MainWindow;

}

class MainWindow : public QMainWindow

{

    Q_OBJECT

public:

    explicit MainWindow(QWidget *parent = 0);

    ~MainWindow();

public slots:

    void onUdpRx(int);

private:

    Ui::MainWindow *ui;

};

#endif // MAINWINDOW_H

#include "mainwindow.h"

#include "ui_mainwindow.h"

#include <QUdpSocket>

#include <QNetworkDatagram>

MainWindow::MainWindow(QWidget *parent) :

    QMainWindow(parent),

    ui(new Ui::MainWindow)

{

    ui->setupUi(this);

}

MainWindow::~MainWindow()

{

    delete ui;

}

void MainWindow::onUdpRx(int len) {

    printf("RX %i\n",len); fflush(stdout);

    QUdpSocket *sock = (QUdpSocket*)(QObject::sender());

    qDebug() << "avail" << sock->bytesAvailable() << sock->hasPendingDatagrams();

    QNetworkDatagram dg = sock->receiveDatagram();

    QByteArray data = dg.data().toHex();

    ui->bla->append(dg.senderAddress().toString()+":"+QString::number(dg.senderPort())+" ");

    ui->bla->append(dg.destinationAddress().toString()+":"+QString::number(dg.destinationPort())+" ");

    ui->bla->append(data);

    qDebug() << data;

    ui->bla->append("\n");

}