socket_udp.h

#ifndef SOCKET_UDP_H
#define SOCKET_UDP_H

#include <QObject>
#include <QQueue>
#include <QThread>
#include <QUdpSocket>
#include <QHostAddress>

#include <chrono>

#include "chat_packet_udp.h"


class SocketUDP : public QObject
{
    Q_OBJECT

private:
    QUdpSocket* uSocket;

    // 预置信息
    const QHostAddress serverAddr = QHostAddress("10.128.206.236");
    const quint16 serverPort = 8002;
    const quint16 clientPort = 8003;

    // 最大单包内容大小
    // UDP max payloadSize is 65507 Bytes (packetSize <= 65535)
    // but payloadSize <= 548 (packetSize <= 576) will not cause fragmentation
    // For macOS, 8192 bytes is at most.
    const quint16 maxPayloadSize = 8192;

    std::chrono::steady_clock::time_point timeLastSent = std::chrono::steady_clock::now();
    double waitToSendUs = 500;

    // 本机信息
    QHostAddress thisAddr;
    quint16 thisPort;

    // 接收信息
    QHostAddress receivedAddr;
    quint16 receivedPort;
    QByteArray receivedData;

signals:
    void on_receivedData(); // 信号先由socket传递给本类，从缓冲区读取完成后再发信号通知mainWindow取走

private slots:
    void on_receiveData();

public:
    SocketUDP();
    ~SocketUDP();

    QHostAddress GetReceivedAddr() { return this->receivedAddr; };
    quint16 GetReceivedPort() { return this->receivedPort; };
    QByteArray GetReceivedData() { return this->receivedData; };

    quint16 MaxPacketSize() { return this->maxPayloadSize; }
    QHostAddress ServerAddr() { return this->serverAddr; }
    quint16 ServerPort() { return this->serverPort; }

    bool SendPackedBytes(QByteArray& bytesPacked, QHostAddress targetAddr, quint16 targetPort);
    bool SendPackedBytes(QByteArray& bytesPacked);
};


#endif // SOCKET_UDP_H