网站设计工具更好的做网站,运营推广怎么做,汽车4s店网站建设方案,云南网站建设公司排行测试环境
本文选用pc1作为客户端#xff0c;pc2#xff0c;以及一台虚拟机作为服务端。
pc1,pc2(客户端#xff09;: 虚拟机#xff08;服务端)#xff1a;
客户端
原理#xff1a;客户端通过发送广播消息信息到ip:255.255.255.255(QHostAddress::Broadcast),局域网…测试环境
本文选用pc1作为客户端pc2以及一台虚拟机作为服务端。
pc1,pc2(客户端: 虚拟机服务端)
客户端
原理客户端通过发送广播消息信息到ip:255.255.255.255(QHostAddress::Broadcast),局域网内的所有设备收到该消息回复客户端即可。客户端通过收到的回复统计当前有哪些设备在线。获取到本地的IPgetLocalIP函数获取到过滤了虚拟机网卡以及本地回环网卡后的ip地址。
#include udpclient.h
#include QDebug
#include QHostInfo
#include QNetworkInterface
#include iostreamudpClient::udpClient(QObject *parent) : QObject(parent)
{QString localIp getLocalIP();udpSocket new QUdpSocket;udpSocket-bind(QHostAddress(localIp),2001);connect(udpSocket,QUdpSocket::readyRead,this,udpClient::processData);}QString udpClient::getLocalIP() {QListQNetworkInterface interfaces QNetworkInterface::allInterfaces();foreach (const QNetworkInterface interface, interfaces) {QListQNetworkAddressEntry entries interface.addressEntries();qDebug()name:interface.humanReadableName()endl;if(interface.humanReadableName().contains(Loopback) ||interface.humanReadableName().contains(VMware Network Adapter)){continue;}foreach (const QNetworkAddressEntry entry, entries) {if (entry.ip().protocol() QAbstractSocket::IPv4Protocol) {qDebug() Local IP Address: entry.ip().toString() endl;}}}return QString();
}udpClient::~udpClient()
{if(udpSocket){delete udpSocket;}
}void udpClient::sendBroadCast()
{QByteArray datagram Device Discovery;udpSocket-writeDatagram(datagram,QHostAddress::Broadcast,8888);
}void udpClient::processData()
{while(udpSocket-hasPendingDatagrams()){QByteArray datagram;datagram.resize(udpSocket-pendingDatagramSize());QHostAddress sender;quint16 senderPort;udpSocket-readDatagram(datagram.data(), datagram.size(), sender, senderPort);qDebug() Received response from: sender.toString()port:senderPort endl;}
}
服务端
#include udpserver.h
#include iostreamudpServer::udpServer(QObject *parent) : QObject(parent)
{udpSocket new QUdpSocket(this);udpSocket-bind(QHostAddress::Any, 8888);connect(udpSocket, QUdpSocket::readyRead, this, udpServer::processPendingDatagrams);}void udpServer::processPendingDatagrams()
{while (udpSocket-hasPendingDatagrams()) {QByteArray datagram;datagram.resize(udpSocket-pendingDatagramSize());QHostAddress sender;quint16 senderPort;udpSocket-readDatagram(datagram.data(), datagram.size(), sender, senderPort);std::cout Received discovery message: datagram.data() std::endl;QByteArray response Device Found;udpSocket-writeDatagram(response, sender, senderPort);}
}
输出效果 优化
对客户端增加定时器同时将客户端对象移动到一个线程中这样就可以定时轮询设备发现了。
#include udpclient.h
#include QDebug
#include QHostInfo
#include QNetworkInterface
#include iostream
#include QTimer
#include QThreadudpClient::udpClient(QObject *parent) : QObject(parent)
{qDebug()thread id1:QThread::currentThreadId()endl;
}void udpClient::createSocket()
{qDebug()thread id2:QThread::currentThreadId()endl;QString localIp getLocalIP();udpSocket new QUdpSocket;udpSocket-bind(QHostAddress(localIp),2001);connect(udpSocket,QUdpSocket::readyRead,this,udpClient::processData);
}QString udpClient::getLocalIP() {QListQNetworkInterface interfaces QNetworkInterface::allInterfaces();foreach (const QNetworkInterface interface, interfaces) {QListQNetworkAddressEntry entries interface.addressEntries();qDebug()name:interface.humanReadableName()endl;if(interface.humanReadableName().contains(Loopback) ||interface.humanReadableName().contains(VMware Network Adapter)){continue;}foreach (const QNetworkAddressEntry entry, entries) {if (entry.ip().protocol() QAbstractSocket::IPv4Protocol) {qDebug() Local IP Address: entry.ip().toString() endl;}}}return QString();
}udpClient::~udpClient()
{if(udpSocket){delete udpSocket;}
}void udpClient::sendBroadCast()
{QByteArray datagram Device Discovery;udpSocket-writeDatagram(datagram,QHostAddress::Broadcast,8888);qDebug()sendBroadCast,thread id:QThread::currentThreadId()endl;
}void udpClient::processData()
{while(udpSocket-hasPendingDatagrams()){QByteArray datagram;datagram.resize(udpSocket-pendingDatagramSize());QHostAddress sender;quint16 senderPort;udpSocket-readDatagram(datagram.data(), datagram.size(), sender, senderPort);result.push_back(IpInfo(sender.toString(),senderPort));qDebug() Received response from: sender.toString()port:senderPort endl;}
}void tcpConnect(QString ip, quint16 port)
{}#include widget.h
#include ui_widget.h
#include QTimer
#include QEventLoopWidget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui-setupUi(this);client new udpClient;connect(ui-pushButton,QPushButton::clicked,client,udpClient::sendBroadCast);thread new QThread;connect(thread,QThread::finished,client,QObject::deleteLater);connect(thread,QThread::started,client,udpClient::createSocket);client-moveToThread(thread);timer new QTimer(this);connect(timer,QTimer::timeout,client,udpClient::sendBroadCast);timer-setInterval(500);thread-start();
// QEventLoop loop;
// QTimer::singleShot(500,loop,QEventLoop::quit);
// loop.exec();timer-start();qDebug()thread id:QThread::currentThreadId()endl;
}Widget::~Widget()
{delete ui;thread-quit();thread-wait();delete thread;threadnullptr;
}
