#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#define NTP_PORT               123               /*NTP专用端口号字符串*/

#define TIME_PORT              37               /* TIME/UDP端口号 */

#define NTP_SERVER_IP       "61.135.250.78"  /*国家授时中心IP*/

#define NTP_PORT_STR        "123"          /*NTP专用端口号字符串*/

#define NTPV1                "NTP/V1"      /*协议及其版本号*/

#define NTPV2                "NTP/V2"

#define NTPV3                "NTP/V3"

#define NTPV4                "NTP/V4"

#define TIME                "TIME/UDP"

#define NTP_PCK_LEN 48

#define LI 0

#define VN 3

#define MODE 3

#define STRATUM 0

#define POLL 4

#define PREC -6

#define JAN_1970  0x83aa7e80  /* 1900年～1970年之间的时间秒数 */

#define NTPFRAC(x)   (4294 * (x) + ((1981 * (x)) >> 11))

#define USEC(x)         (((x) >> 12) - 759 * ((((x) >> 10) + 32768) >> 16))

typedef struct _ntp_time

{

unsigned int coarse;

unsigned int fine;

} ntp_time;

struct ntp_packet

{

unsigned char leap_ver_mode;

unsigned char startum;

char poll;

char precision;

int  root_delay;

int  root_dispersion;

int reference_identifier;

ntp_time reference_timestamp;

ntp_time originage_timestamp;

ntp_time receive_timestamp;

ntp_time transmit_timestamp;

};

char protocol[32];

/*构建NTP协议包*/

int construct_packet(char *packet)

{

char version = 1;

long tmp_wrd;

int port;

time_t timer;

strcpy(protocol, NTPV3);

/*判断协议版本*/

if(!strcmp(protocol, NTPV1)||!strcmp(protocol, NTPV2)

||!strcmp(protocol, NTPV3)||!strcmp(protocol, NTPV4))

{

memset(packet, 0, NTP_PCK_LEN);

port = NTP_PORT;

/*设置16字节的包头*/

version = protocol[6] - 0x30;

tmp_wrd = htonl((LI <

|(MODE <

memcpy(packet, &tmp_wrd, sizeof(tmp_wrd));

/*设置Root Delay、Root Dispersion和Reference Indentifier */

tmp_wrd = htonl(1<<16);

memcpy(&packet[4], &tmp_wrd, sizeof(tmp_wrd));

memcpy(&packet[8], &tmp_wrd, sizeof(tmp_wrd));

/*设置Timestamp部分*/

time(&timer);

/*设置Transmit Timestamp coarse*/

tmp_wrd = htonl(JAN_1970 + (long)timer);

memcpy(&packet[40], &tmp_wrd, sizeof(tmp_wrd));

/*设置Transmit Timestamp fine*/

tmp_wrd = htonl((long)NTPFRAC(timer));

memcpy(&packet[44], &tmp_wrd, sizeof(tmp_wrd));

return NTP_PCK_LEN;

}

else if (!strcmp(protocol, TIME))/* "TIME/UDP" */

{

port = TIME_PORT;

memset(packet, 0, 4);

return 4;

}

return 0;

}

/*获取NTP时间*/

int get_ntp_time(int sk, struct addrinfo *addr, struct ntp_packet *ret_time)

{

fd_set pending_data;

struct timeval block_time;

char data[NTP_PCK_LEN * 8];

int  packet_len, data_len = addr->ai_addrlen, count = 0, result, i, re;

if (!(packet_len = construct_packet(data)))

{

return 0;

}

/*客户端给服务器端发送NTP协议数据包*/

if ((result = sendto(sk, data,

packet_len, 0, addr->ai_addr, data_len))

{

perror("sendto");

return 0;

}

/*调用select()函数，并设定超时时间为1s*/

FD_ZERO(&pending_data);

FD_SET(sk, &pending_data);

block_time.tv_sec=10;

block_time.tv_usec=0;

if (select(sk + 1, &pending_data, NULL, NULL, &block_time) > 0)

{

/*接收服务器端的信息*/

if ((count = recvfrom(sk, data,

NTP_PCK_LEN * 8, 0, addr->ai_addr, &data_len))

{

perror("recvfrom");

return 0;

}

if (protocol == TIME)

{

memcpy(&ret_time->transmit_timestamp, data, 4);

return 1;

}

else if (count

{

return 0;

}

/* 设置接收NTP包的数据结构 */

ret_time->leap_ver_mode = ntohl(data[0]);

ret_time->startum = ntohl(data[1]);

ret_time->poll = ntohl(data[2]);

ret_time->precision = ntohl(data[3]);

ret_time->root_delay = ntohl(*(int*)&(data[4]));

ret_time->root_dispersion = ntohl(*(int*)&(data[8]));

ret_time->reference_identifier = ntohl(*(int*)&(data[12]));

ret_time->reference_timestamp.coarse = ntohl (*(int*)&(data[16]));

ret_time->reference_timestamp.fine = ntohl(*(int*)&(data[20]));

ret_time->originage_timestamp.coarse = ntohl(*(int*)&(data[24]));

ret_time->originage_timestamp.fine = ntohl(*(int*)&(data[28]));

ret_time->receive_timestamp.coarse = ntohl(*(int*)&(data[32]));

ret_time->receive_timestamp.fine = ntohl(*(int*)&(data[36]));

ret_time->transmit_timestamp.coarse = ntohl(*(int*)&(data[40]));

ret_time->transmit_timestamp.fine = ntohl(*(int*)&(data[44]));

return 1;

} /* end of if select */

return 0;

}

/* 修改本地时间 */

int set_local_time(struct ntp_packet * pnew_time_packet)

{

struct timeval tv;

tv.tv_sec = pnew_time_packet->transmit_timestamp.coarse - JAN_1970;

tv.tv_usec = USEC(pnew_time_packet->transmit_timestamp.fine);

return settimeofday(&tv, NULL);

}

int main()

{

int sockfd, rc;

struct addrinfo hints, *res = NULL;

struct ntp_packet new_time_packet;

memset(&hints, 0, sizeof(hints));

hints.ai_family = AF_UNSPEC;

hints.ai_socktype = SOCK_DGRAM;

hints.ai_protocol = IPPROTO_UDP;

/*调用getaddrinfo()函数，获取地址信息*/

rc = getaddrinfo(NTP_SERVER_IP, NTP_PORT_STR, &hints, &res);

if (rc != 0)

{

perror("getaddrinfo");

return 1;

}

/* 创建套接字 */

sockfd = socket(res->ai_family, res->ai_socktype, res->ai_protocol);

if (sockfd <0 )

{

perror("socket");

return 1;

}

/*调用取得NTP时间的函数*/

if (get_ntp_time(sockfd, res, &new_time_packet))

{

/*调整本地时间*/

if (!set_local_time(&new_time_packet))

{

printf("NTP client success!\n");

}

}

close(sockfd);

return 0;

}