vs2015+qt5.8.0 NTP协议的实现源码

#include "CNetwork.h" #include <QUdpSocket> #include <QDateTime> #include <QHostInfo> #include <QMessageBox> #include <QDebug> #include <time.h> #include <windows.h> CNetwork::CNetwork(QWidget *parent) : QMainWindow(parent) { ui.setupUi(this); QObject::connect(ui.pushButton, SIGNAL(clicked()), this, SLOT(verifyTime())); } void CNetwork::verifyTime() { // QString ntpHost = "202.120.2.101"; //use ntp server get network time // QString ntpHost = "192.168.11.132"; QString ntpHost = ui.IPlineEdit->text(); QUdpSocket udp_sock; udp_sock.connectToHost(ntpHost, 123); //request server time qint8 LI = 0; qint8 VN = 3; qint8 MODE = 3; qint8 STRATUM = 0; qint8 POLL = 4; qint8 PREC = -6; QDateTime epoch(QDate(1900, 1, 1)); qint32 second = quint32(epoch.secsTo(QDateTime::currentDateTime())); //////////////////////////////////////////////////// QDateTime preTime = QDateTime::currentDateTime(); qDebug() << "currnet time :" << QDateTime::currentDateTime().toString("yyyy.MM.dd hh:mm:ss.zzz"); qDebug() << "second :" << QString::number(second); qint32 temp = 0; QByteArray time_req(48, 0); time_req[0] = (LI << 6) | (VN << 3) | (MODE); time_req[1] = STRATUM; time_req[2] = POLL; time_req[3] = PREC & 0xff; time_req[5] = 1; time_req[9] = 1; time_req[40] = (temp = (second & 0xff000000) >> 24); temp = 0; time_req[41] = (temp = (second & 0x00ff0000) >> 16); temp = 0; time_req[42] = (temp = (second & 0x0000ff00) >> 8); temp = 0; time_req[43] = ((second & 0x000000ff)); QDateTime cur_dt; //block wait connect if (udp_sock.waitForConnected(3000)) { udp_sock.flush(); //request time udp_sock.write(time_req); QString s, tmp; for (int i = 0; i < 48; i++) { tmp.sprintf("%.2X", (unsigned char)time_req[i]); s.append(tmp); tmp.sprintf(" "); s.append(tmp); } qDebug() << s; //block wait reply if (udp_sock.waitForReadyRead(5000)) { QByteArray new_time; QDateTime epoch(QDate(1900, 1, 1)); QDateTime unix_start(QDate(1970, 1, 1)); if (udp_sock.pendingDatagramSize() == 0) { QMessageBox::information(this, "msg", "please ensure the NTP service's ip! "); return; } while (udp_sock.hasPendingDatagrams()) { new_time.resize(udp_sock.pendingDatagramSize()); udp_sock.read(new_time.data(), new_time.size()); } QString s, tmp; for (int i = 0; i < 48; i++) { tmp.sprintf("%.2X", (unsigned char)new_time[i]); s.append(tmp); tmp.sprintf(" "); s.append(tmp); } qDebug() << "rece message: " << s; QByteArray TransmitTimeStamp; TransmitTimeStamp = new_time.right(8); quint32 seconds = TransmitTimeStamp[0]; quint32 *a = &seconds; quint8 temp = 0; for (int j = 1; j <= 3; j++) { seconds = seconds << 8; temp = TransmitTimeStamp[j]; seconds = seconds + temp; } /////////////// quint8 temp1 = TransmitTimeStamp[4]; float x = 1000*(temp1 / 16) * (1.0/16.0); float y = 1000*(temp1 % 16) * (1.0 / 256.0); qint64 msecTemp = x + y; qDebug() << temp1; qDebug() << x; qDebug() << y; qDebug() << msecTemp; ///////////////////////////////////////// qDebug() << "seconds:" << QString::number(seconds); QDateTime newTime = QDateTime::currentDateTime(); qint64 value = newTime.toMSecsSinceEpoch() - preTime.toMSecsSinceEpoch(); //cur_dt.setSecsSinceEpoch(seconds - epoch.secsTo(unix_start)); cur_dt.setMSecsSinceEpoch((seconds - epoch.secsTo(unix_start))*1000); cur_dt = cur_dt.addMSecs(value/2+msecTemp); QString str = cur_dt.toString("yyyy.MM.dd hh:mm:ss.zzz"); ui.ResultlineEdit->setText(str); setSystemTime(cur_dt); } else { QMessageBox::information(this,"message","get ntp time is time out"); } udp_sock.disconnectFromHost(); udp_sock.close(); } else { QHostInfo info = QHostInfo::fromName(ntpHost); QString ip_addr = info.addresses().first().toString(); QMessageBox::information(this, "message", "connect ntp server is error!"); } } bool CNetwork::setSystemTime(const QDateTime &dateTime) //修改本地系统的时间 *添加kernel32.lib { SYSTEMTIME st; GetLocalTime(&st); st.wYear = dateTime.date().year(); st.wMonth = dateTime.date().month(); st.wDay = dateTime.date().day(); st.wHour = dateTime.time().hour(); st.wMinute = dateTime.time().minute(); st.wSecond = dateTime.time().second(); // st.wDayOfWeek= 0; st.wMilliseconds = dateTime.time().msec(); return SetLocalTime(&st); }