Initial MQTT bell app based on systray

myudp.cpp

@@ -0,0 +1,104 @@
+// myudp.cpp
+
+#include "myudp.h"
+#include <QTimer>
+#include <QNetworkInterface>
+
+MyUDP::MyUDP(QObject *parent) :
+    QObject(parent)
+{
+    // create a QUDP socket
+    socket = new QUdpSocket(this);
+
+    // The most common way to use QUdpSocket class is
+    // to bind to an address and port using bind()
+    // bool QAbstractSocket::bind(const QHostAddress & address,
+    //     quint16 port = 0, BindMode mode = DefaultForPlatform)
+    socket->bind(QHostAddress::AnyIPv4, 1234,QUdpSocket::ShareAddress);
+
+    connect(socket,SIGNAL(readyRead()),this,SLOT(readyRead()));
+
+    QTimer::singleShot(200, this, &MyUDP::join);
+
+}
+
+void MyUDP::join()
+{
+    setMulticast(QHostAddress("224.1.2.3"));
+}
+
+void MyUDP::setMulticast(QHostAddress address)
+{
+    if (listen_address != address) {
+
+        QList<QNetworkInterface> mListIfaces = QNetworkInterface::allInterfaces();
+
+        for (int i = 0; i < mListIfaces.length(); ++i) {
+            if (socket && socket->state() == QAbstractSocket::BoundState)
+                socket->leaveMulticastGroup(listen_address, mListIfaces.at(i));
+        }
+
+        listen_address = address;
+
+        for (int i = 0; i < mListIfaces.length(); ++i) {
+            qDebug() << socket->joinMulticastGroup(address,mListIfaces.at(i));
+        }
+
+
+        qDebug() << "EMIT MULTICAST CHANGED";
+        emit multicastChanged(address);
+    }
+}
+
+void MyUDP::HelloUDP()
+{
+    QByteArray Data;
+    Data.append("Hello from UDP");
+    qDebug() << "Sending message";
+
+    // Sends the datagram datagram
+    // to the host address and at port.
+    // qint64 QUdpSocket::writeDatagram(const QByteArray & datagram,
+    //                      const QHostAddress & host, quint16 port)
+    socket->writeDatagram(Data, QHostAddress::LocalHost, 1234);
+}
+
+void MyUDP::readyRead()
+{
+    // when data comes in
+    QByteArray buffer;
+    buffer.resize(socket->pendingDatagramSize());
+
+    QHostAddress sender;
+    quint16 senderPort;
+    int bellNumber;
+    QString header;
+    QString msg;
+
+    // qint64 QUdpSocket::readDatagram(char * data, qint64 maxSize,
+    //                 QHostAddress * address = 0, quint16 * port = 0)
+    // Receives a datagram no larger than maxSize bytes and stores it in data.
+    // The sender's host address and port is stored in *address and *port
+    // (unless the pointers are 0).
+
+    socket->readDatagram(buffer.data(), buffer.size(),
+                         &sender, &senderPort);
+
+
+    msg = QString::fromLatin1(buffer);
+    QStringList list1 = msg.split(QLatin1Char(':'));
+    qDebug() << msg;
+    qDebug() << "List Size: " << list1.size();
+    if (list1.size() >= 2) {
+        header = list1.at(0);
+        qDebug() << "H: " << header;
+        if (header == "BELL") {
+            bellNumber = list1.at(1).toInt();
+            emit packetArrived(bellNumber);
+        }
+    }
+
+    qDebug() << "Message from: " << sender.toString();
+    qDebug() << "Message port: " << senderPort;
+    qDebug() << "Message: " << buffer;
+}