#include "udpnet.h"

UDPNet::UDPNet(QObject *parent) :
    QObject(parent)
{
    udpReaction = new QUdpSocket();
    udpAccepct  = new QUdpSocket();
    connect(udpAccepct,SIGNAL(readyRead()),this,SLOT(acceptMessage()));
}
/**
 * @brief 获取一个空闲端口作为本次进程的通讯端口
 * @return 绑定是否成功
 */
int UDPNet::bindPort()
{
//    初始端口从10000开始
    int p=10000;
//    直到端口能被绑定
    while(!(udpAccepct->bind(QHostAddress::Any,p)))
    {
//        步长为一
          p++;
    }
//    返回绑定的端口号
    this->port=p;
    config.setValue("port_accepct",QString::number(port),"UDP");
    return p;
}
/**
 * @brief 发送消息
 * @param port 目标端口
 * @param ip 目标ip
 * @param message 发送信息
 */
void UDPNet::sendMessage(QString message,QString ip,int port)
{
    QByteArray byte=message.toAscii();
    QHostAddress address;
    address.setAddress(ip);
    qDebug()<<message;
    udpReaction->writeDatagram(byte.data(),message.size(),address,port);
}
/**
 * @brief 发送消息(与服务器的udp通信)
 * @param ip 目标ip
 * @param message 发送信息
 */
void UDPNet::sendMessage(QString message)
{
    QByteArray byte=message.toAscii();
    QHostAddress address;
    address.setAddress(config.getValue("ip","TCP"));
    udpReaction->writeDatagram(byte.data(),message.size(),address,config.getValue("port_reaction","UDP").toInt());
}
/**
  * @brief 接受消息
  * @param port 监听端口
  * @param ip 监听ip
  * @return 接收到的数据
  */
 void UDPNet::acceptMessage()
 {
     //拥有等待的数据报
      while(udpAccepct->hasPendingDatagrams()){
          QByteArray accept;
          accept.resize(udpAccepct->pendingDatagramSize());
          udpAccepct->readDatagram(accept.data(),accept.size());
          this->message=accept;
       }
      emit haveMessaeg(message);

 }