QT使用UDP方式传输文件的关键代码

QT中使用UDP传输的核心代码：

void Sender::sendData()
{
if (!file.atEnd()) {
QByteArray line = file.read(8000);
udpSocket->writeDatagram( line , QHostAddress("192.168.0.175"),7755);
i++;
qDebug() << "send over!" << i << line.size();
}
}

void Sender::initSocket()
{
udpSocket = new QUdpSocket(this);
udpSocket->bind(QHostAddress::LocalHost, 7754);

connect(udpSocket, SIGNAL(readyRead()),
this, SLOT(readPendingDatagrams()));
}

void Sender::readPendingDatagrams()
{
//receive
while (udpSocket->hasPendingDatagrams()) {
QByteArray datagram;
datagram.resize(udpSocket->pendingDatagramSize());
QHostAddress sender;
quint16 senderPort;

udpSocket->readDatagram(datagram.data(), datagram.size(),
&sender, &senderPort);

qDebug() << datagram;
if (datagram == "1")
{
qDebug() <<"send ok!";
sendData();
}


}
}

void Sender::on_pushButton_clicked()
{

file.setFileName("/home/akaedu/Pictures/test.jpg");

if (!file.open(QIODevice::ReadOnly))
return;

sendData();
}



void Receiver::initSocket()
{
udpSocket = new QUdpSocket(this);
udpSocket->bind(QHostAddress::Any, 7755);

connect(udpSocket, SIGNAL(readyRead()),
this, SLOT(readPendingDatagrams()));
file.setFileName( "/home/akaedu/Pictures/test1.jpg" );
if (!file.open(QIODevice::WriteOnly | QIODevice::Append | QIODevice::Unbuffered))
return;
}


void Receiver::readPendingDatagrams()
{
//receive
while (udpSocket->hasPendingDatagrams()) {
QByteArray datagram;
datagram.resize(udpSocket->pendingDatagramSize());
QHostAddress sender;
quint16 senderPort;

udpSocket->readDatagram(datagram.data(), datagram.size(),
&sender, &senderPort);

file.write(datagram.data(),datagram.size());
i++;
udpSocket->writeDatagram("1",1, sender ,7754);

qDebug() << i << datagram.size();

}
}

相关项目的博文：