¡¾Æ½Í·¸çRVB2601´´ÒâÓ¦ÓÃ¿ª·¢¡¿Ê¹ÓÃÌåÑé06 -- NTPÊÚÊ±

sonicfirr ·¢±íÓÚ 2022-4-8 10:09

±¾Ìû×îºóÓÉ sonicfirr ÓÚ 2022-4-8 10:24 ±à¼

±¾Æª¼ÇÂ¼RVB2601Ê¹ÓÃNTP½øÐÐÍøÂçÊÚÊ±µÄ¿ª·¢¹ý³Ì£¬±¾ÈËÀúÊ±Èý´Î´óÊ±¼ä¶ÎÍ¶Èë²Å¸ã¶¨£¬Ò²ÊÇSDKÊ¹ÓÃÒÔÀ´Óöµ½µÄ×î´óÒ»¿Ó¡£

<h2 style="text-align:justify">1¡¢SNTPÐÐ²»Í¨</h2>

½×¶ÎÒ»£¬ÀúÊ±8Ð¡Ê±£¨Ò»¸öÏÂÎç¼ÓÍíÉÏ£©£¬Ê¹ÓÃSNTP×é¼þ£¬¸÷ÖÖ±àÒë´íÎó£¬Ï¡ÀïºýÍ¿µ½Ö±½Ó·ÅÆú¡£×îºóÒ²ÊÇÁªÏµÆ½Í·¸ç¼¼ÊõÖ§³Ö£¬ÁË½âµ½SNTPÃ»ÓÐÊÊÅä¡£Õâ¶Î¹¤×÷ÒÑ¾¹ýÁËÒ»¶ÎÊ±¼ä£¬µ±Ê±Ò²Ã»ÐÄÇé×ö²âÆÀ¼ÇÂ¼£¬´ó¸ÅÎÊÌâÊÇSNTP×é¼þÐèÒªLWIP°üµÄÖ§³Ö£¬¶øSDKÖÐ°üº¬SAL×é¼þÒÑ¾ÊÊÅäÁËLWIP°ü£¬µ«ÊÇ¹¦ÄÜÉÏ£¬ÌØ±ðÊÇÓ¦ÓÃ²ãÐÒéÊÊÅäÃ»ÓÐ×öÍêÕû¡£¶øµ¥¶À¼ÓÔØLWIP°ü£¬ÓÖ»á³öÏÖ´óÁ¿ÖØ¸´¶¨ÒåµÄÇé¿ö£¨ÓëSAL×é¼þÖÐµÄ³åÍ»£©£¬Òò´Ë³ý·ÇÏÂÁ¦ÆøÀ©Õ¹SAL×é¼þ£¬×Ô¼ºÌí¼ÓSNTPÖ§³Ö£¬·ñÔò´ËÂ·ÐÐ²»Í¨ÁË¡£

<h2 style="text-align:justify">2¡¢³¢ÊÔNTP</h2>

½×¶Î¶þ£¬´ó¸ÅÊÇÁ½Ììºó£¬»î¶¯Î¢ÐÅÈºÖÐÒÑ¾ÓÐºÜ¶àÍøÓÑ¶¼·´À¡ÁËSNTPµÄÎÊÌâ£¬ÓÐÈËÌáµ½¿ÉÒÔÊ¹ÓÃNTP£¬µ«ÊÇNTP»áÓöµ½SDKÖÐµÄBug£¬¾ÍÊÇdrv_wifi_at_w800×é¼þÖÐµÄw800_connect_remote()º¯ÊýµÄUDPÁ¬½ÓBug£¨NTPÊ¹ÓÃµÄUDPÐÒé£©£¬¹Ø¼üµã¾ÍÊÇº¯ÊýÊµÏÖÁ¬½ÓÔ¶¶ËTCP»òUDP·þÎñÆ÷Ê¹ÓÃµÄÊÇÍ¬Ò»ÌõÓï¾ä£¬Ò²¾ÍÊÇÏàÍ¬µÄATÃüÁî£¬µ«Êµ¼ÊW800µÄTCPÁ¬½ÓºÍUDPÁ¬½Ó£¬ËäÈ»ATÃüÁîÒ»Ñù£¬µ«ÊÇÄ¬ÈÏ²ÎÊýÏîÓÐ²î±ð¡£



 Í¼6-1 UDPÁ¬½ÓBugµã



Í¼6-2 AT+CIPSTARTÃüÁî¸ñÊ½ÒªÇó

Õë¶ÔÉÏÊöÎÊÌâ£¬½â¾ö·½·¨ÓÐÁ½¸ö£¬Ò»ÊÇÐÞ¸Ä“atparser_send()”Óï¾ä£¬Ôö¼ÓATÃüÁîµÄ±¾µØ¶Ë¿Ú²ÎÊý——ÒòÎªTCPÒ²¿ÉÒÔ´«µÝÕâ¸ö²ÎÊý£¬²¢ÇÒ¸Ä“tcp_client”Îª“udp_unicast”¡£¶þÊÇÔö¼Ó“case NET_TYPE_UDP_UNICAST:”·ÖÖ§µÄ´úÂë£¬¶îÍâÌá¹©Ò»¸öUDPÁ¬½ÓµÄº¯Êýµ÷ÓÃ¡£



Í¼6-3 Á½ÖÖÐÞ¸Ä·½·¨

ºÜÃ÷ÏÔ£¬·½·¨Ò»TCPºÍUDPÊ¹ÓÃÍ¬Ò»´«µÝµÄ±¾µØ¶Ë¿Ú²ÎÊý£¬ÕâÑù¾ÍÏÞÖÆÁË°å×ÓÍ¬Ê±¿ªÆôTCPºÍUDPµÄÄÜÁ¦£¬ËùÒÔ±¾ÈË×îÖÕ²ÉÓÃÁË·½·¨¶þ£¬ÄÇÃ´Ë÷ÐÔ½«NET_TYPE_TCP_CLIENT·ÖÖ§Ò²×öÁËÐÞ¸Ä£¬Ö»±£Áôtcp_clientÄ£Ê½µÄÊµÏÖ¡£



Í¼6-4 ÏîÄ¿×îÖÕÐÞ¸Ä·½·¨

ÉÏÊö·½·¨µÄÈ·±£Ö¤TCPºÍUDP²âÊÔµÄ³É¹¦£¬µ«ÊÇNTPÒÀÈ»Ã»ÓÐ²úÉúÐ§¹û£¬ÓÚÊÇ½øÒ»²½×ö´úÂë×·×Ù£¬×îºó×Ô¼º¸ø×Ô¼ºÍÚÁËÒ»¸ö¿Ó¡£ÒòÎª¾àÀëÐ´ÏÂ´ËÆªÒ²ÓÐÒ»¶ÎÊ±¼äÁË£¬ËùÒÔ¾ßÌå¹ý³Ì¼Ç²»ÇåÁË£¬´ó¸ÅÊÇÔÚw800_devops.cÖÐ¿´µ½º¯Êýw800_wifi_module_conn_start()»áµ÷ÓÃw800_connect_remote()£¬²ÂÏëËü¾ÍÊÇÉÏÒ»²ãÈë¿Ú——ÕâÒ»²ÂÏëºóÃæÍ¨¹ý²é¿´listÎÄ¼þ“ÏîÄ¿Ä¿Â¼/Lst/ÏîÄ¿Ãû.asm”·¢ÏÖÊÇ´íÎóµÄ¡£

´ø×ÅÕâ¸ö´íÎó²ÂÏë£¬±¾ÈË·¢ÏÖº¯ÊýÖÐ»á¶¯Ì¬Éú³ÉÒ»¸ö±¾µØ¶Ë¿Ú£¬µ«ÊÇÃ»ÓÐ´«µÝ¸øw800_connect_remote()£¬ÓÚÊÇ¾ÍÒÔÎªUDPÒ²ÒªÓÃÕâÀïÉú³ÉµÄ¶Ë¿Ú£¬ÓÚÊÇ×öÁËÏÂÊöµÄÐÞ¸Ä¡£



 

 

 



 



 



Í¼6-5 ²¢²»³É¹¦µÄ½×¶Î¶þ¹ý³Ì£¬ÊÂÊµÊÇ²Â²âÓÐÎó£¡

ÒòÎªÓÐÁË½×¶ÎÒ»µÄ´ì°Ü£¬½×¶Î¶þµÄUDP³É¹¦ºÍ×ÔÎÒ²Â²â´øÀ´µÄÃýÎó£¬ÓÖÊÇÀúÊ±´ó°ëÌìµÄÑÐ¾¿£¬½á¹û»¹ÊÇ·ÅÆú£¬ÉõÖÁ¾ö¶¨²»ÔÚÏîÄ¿ÖÐÊ¹ÓÃÍøÂçÊÚÊ±ÁË¡£

<h2 style="text-align:justify">3¡¢NTP×é¼þµÄÎÊÌâ</h2>

Ç°Á½¸ö½×¶ÎµÄ³¢ÊÔ»¹°üÀ¨¶ÔNTP×é¼þ°æ±¾µÄÊµÑé¡£



 Í¼6-6 ÏîÄ¿²âÊÔµÄNTP×é¼þ°æ±¾



  



 Í¼6-7 NTP×é¼þ7.4.5°æ±¾µÄÍ¬²½Ê±¼äº¯Êý



 Í¼6-8 NTP×é¼þ7.4.3°æ±¾µÄÍ¬²½Ê±¼äº¯Êý

Á½ÖÖ°æ±¾µÄÊ±¼äÍ¬²½º¯Êý¶¼»á±¨´í£¬ÆäÊµËüÃÇ¶¼ÊÇÓÖµ÷ÓÃÁË_ntp_sync_time()£¬¶øÕâ¸öº¯ÊýÓÐÒ»ÏµÁÐ´íÎó·µ»ØÅÐ¶Ï£¬Ëæ±ãÒ»¸ö¿¨×¡¾Í»á²»³É¹¦¡£

ºóÀ´Ò²ÊÇÔÚÎ¢ÐÅÈºÖÐ¿´µ½Ò»¸öÈºÓÑ@Ñî¹¤£¬NTP²âÊÔ³É¹¦£¬¶øÇÒ·ÖÏíµÄÐÞ¸Ä½ØÍ¼Óë±¾ÈËÔÚ½×¶Î¶þµÄ³¢ÊÔÒ»ÖÂ£¬ÓÚÊÇÁªÏëµ½×Ô¼ºµÄ²Â²â´íÎó£¬UDP±¾µØ¶Ë¿Ú¾ÍÊÇÒª×Ô¼º¶¨Òå£¬ÄÇÃ´Ö»¿ÉÄÜÊÇNTP²âÊÔº¯ÊýÖÐÓÐÎÊÌâ£¬ÓÚÊÇ×·×Ù_ntp_sync_time()£¬½«ÆäÖÐÖ±½ÓÊä³öÊ±¼äÐÅÏ¢µÄÓï¾äÈ¥µô×¢ÊÍ£¬Ë²¼ä³É¹¦ÁË¡£



Í¼6-9 NTPÍ¬²½Ê±¼äÊä³ö



 Í¼6-9 NTPÍ¬²½Ê±¼ä²âÊÔº¯ÊýµÄÐÞ¸Ä

Ð´ÏÂ´ËÆªÊ±£¬±¾ÈËÊÇÀûÓÃ¹¤×÷¿Õµ±Íê³ÉµÄ£¬¶øÇÒÔÚÐÂ½¨¹¤³ÌÖÐÖð²½¸´ÅÌÇ°ÆÚ¸÷ÖÖ²Ù×÷²¢×÷¼ÇÂ¼£¬´ËÊ±ÓÖ·¢ÏÖÒ»¸öbug£¬¾ÍÊÇÈç¹û×¢²áÁË½ÓÊÕ»Øµ÷£¬ntp¾ÍÊ§°Ü£¬¶øÈ¥µô»Øµ÷Ôò³É¹¦¡£Ó¦¸ÃËµ£¬ÔÚÏÂ¶ÔNTP»òSNTPµÄÊ¹ÓÃ£¬»¹ÊÇ´¦ÓÚ²»ÇóÉõ½â½×¶Î£¬Ö»ÊÇÖ±½Ó¼ÓÔØ·â×°ºÃµÄAPI£¬Õâ¸öbug³öÏÖµÄÔÒòÒ²Ö»ÄÜ²ÂÏëÊÇ£º“NTPÇëÇóÖÐ£¬±¾µØ»áÓëNTP Server½øÐÐ¶à´Î½»»¥£¬¶ø»Øµ÷º¯Êý»áÓ°ÏìÕâ¶à´Î½»»¥µÄ¹ý³Ì£¿”——ÆäÊµÕâ¸ö²ÂÏë×ÔÒÔÎªÊÇºÜ²»¿¿Æ×µÄ£¡£¡



 Í¼6-10 NTPµÄÐÂbug·¢ÏÖ£¬ÓëÊäÈë»Øµ÷×¢²áÓÐ³åÍ»

Ëæ×Å´úÂë±àÐ´£¬¸üÓÐÒâË¼µÄµØ·½³öÏÖÁË¡£Ö®Ç°ËäÈ»·¢ÏÖÊÇ_ntp_sync_time()ÖÐÓÐbug£¬µ«ÊÇ»¹²»È·¶¨ÊÇÄÄÀï£¬NTP¿ÉÒÔÊä³öÐÅÏ¢£¬µ«ÊÇ×îºó»¹ÊÇÊä³öÒ»¾ä“NTP sync error”ÂùëõÓ¦ÈËµÄ¡£ÓÚÊÇ±¾ÈË³¢ÊÔÖð¾äÌí¼ÓprintfÊä³ö£¬ÅÐ¶Ï³ö´íÎ»ÖÃ£¬Ã»Ïëµ½µÄÊÇÕâ»Ø¾ÓÈ»·µ»ØÁË“NTP sync success”ÁË¡£



 



 



Í¼6-11 NTPÍ¬²½Ê±¼äÄªÃû³É¹¦

4¡¢NTPÏÖ½×¶Î²âÊÔ´úÂë

NTP×é¼þ×îºóÑ¡ÓÃv7.4.3ÓëDemoµÄ°æ±¾Ò»ÖÂÁË£¬ntp.cÖÐÐÞ¸Ä_ntp_sync_time()º¯Êý¡£

<pre>
<code>static int _ntp_sync_time(char *server)
{
char buf;
size_t nbytes;
int sockfd, maxfd1;
struct sockaddr_in servaddr = {0,};
fd_set readfds;
struct timeval timeout, recvtv, tv, rcvtimeout = {3, 0};
double offset;

servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(NTP_PORT);

if (server == NULL) {
 //1.cn.pool.ntp.org is more reliable
 servaddr.sin_addr.s_addr = inet_host("ntp1.aliyun.com");
 LOGD(TAG, "ntp1.aliyun.com");
} else {
 servaddr.sin_addr.s_addr = inet_host(server);
 LOGD(TAG, "%s", server);
}
printf("--------------------->check server done! _ntp_sync_time()\n");

if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
 //LOGE(TAG, "socket error");
 return -1;
}

setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, &rcvtimeout, sizeof(struct timeval));

if (connect(sockfd, (struct sockaddr *)&servaddr, sizeof(struct sockaddr)) != 0) {
 //LOGE(TAG, "connect error");
 close(sockfd);
 return -errno;
}
printf("--------------------->connect server done! _ntp_sync_time()\n");

nbytes = BUFSIZE;

if (get_ntp_packet(buf, &nbytes) != 0) {
 //LOGE(TAG, "construct ntp request errorr");
 close(sockfd);
 return -1;
}

send(sockfd, buf, nbytes, 0);
printf("--------------------->send request pack done! _ntp_sync_time()\n");

FD_ZERO(&readfds);
FD_SET(sockfd, &readfds);
maxfd1 = sockfd + 1;

timeout.tv_sec= TIMEOUT;
timeout.tv_usec = 0;

if (select(maxfd1, &readfds, NULL, NULL, &timeout) > 0) {
 if (FD_ISSET(sockfd, &readfds)) {
 if ((nbytes = recv(sockfd, buf, BUFSIZE, 0)) < 0) {
 //LOGE(TAG, "recv error");
 close(sockfd);
 return -1;
 }

 //printf("nbytes = %d\n", nbytes);
 print_ntp((struct ntphdr *) buf);
 gettimeofday(&recvtv, NULL);
 offset = get_offset((struct ntphdr *)buf, &recvtv);

 gettimeofday(&tv, NULL);
 //TODO: ctime has some problem
#if 0
 LOGD(TAG, "system time:\t%s", ctime((time_t *) &tv.tv_sec));
#else
 //char *tbuf = NULL;
 //char tbuf;
 //strftime(tbuf, sizeof(tbuf), "%Y-%m-%d %T", localtime(&tv.tv_sec));
 //memset(&tv, 0, sizeof(tv));
 //tbuf = ctime((time_t *)&tv.tv_sec);
 //LOGD(TAG, "system time1:%s", tbuf);
#endif
#if 1

 tv.tv_sec += (int)offset;
 tv.tv_usec += offset - (int)offset;

 if (settimeofday(&tv, NULL) != 0) {
 //LOGE(TAG, "set time");
 close(sockfd);
 return -1;
 }
printf("--------------------->settimeofday done! _ntp_sync_time()\n");

 //TODO: ctime has some problem
 //LOGD(TAG, "ntp time:\t%s", ctime((time_t *) &tv.tv_sec));
#endif
 }
} else {
 close(sockfd);
printf("--------------------->select body error! _ntp_sync_time()\n");
 return -1;
}

close(sockfd);
printf("--------------------->whole done! _ntp_sync_time()\n");
return 0;
}</code></pre>

w800_api.cÖÐÐÞ¸Äw800_connect_remote()º¯Êý£¬Ôö¼ÓUDP·ÖÖ§¡£ÆäÖÐ¶Ë¿ÚºÅÊÇ×Ô¼ºËæÒâ¶¨ÒåµÄ£¬±¾ÈË¾õµÃ»¹ÊÇµ¥¶À¶¨Òå¶Ë¿ÚºÅ±È½Ï·½±ã¡£

<pre>
<code>int32_t udp_local_port = 1338;
int w800_connect_remote(int id, net_conn_e type, char *srvname, uint16_t port)
{
int ret = -1;
int ret_id;

if (g_net_status < NET_STATUS_GOTIP) {
 LOGE(TAG, "net status error\n");
 return -1;
}

aos_mutex_lock(&g_cmd_mutex, AOS_WAIT_FOREVER);

atparser_clr_buf(g_atparser_uservice_t);

switch (type) {
 case NET_TYPE_TCP_SERVER:
 /* TCP Server can NOT ignore lport */
 break;

 case NET_TYPE_UDP_UNICAST:
printf("UDP_UNICAST mode\n");
ret = atparser_send(g_atparser_uservice_t, "AT+CIPSTART=%d,%s,%s,%d,%d", id, "udp_unicast", srvname, port, udp_local_port);
break;

 case NET_TYPE_TCP_CLIENT:
printf("TCP_CLIENT mode\n");
 ret = atparser_send(g_atparser_uservice_t, "AT+CIPSTART=%d,%s,%s,%d", id, "tcp_client", srvname, port);
 break;

 default:
 LOGE(TAG, "type=%d err!", type);
 return -1;

}

if (ret == 0) {
 ret = -1;

 if ((atparser_recv(g_atparser_uservice_t, "OK\n") == 0) \
 && (atparser_recv(g_atparser_uservice_t, "+EVENT=CONNECT,%d\n", &ret_id) == 0)) {
 if (ret_id == id) {
 ret = 0;
 }
 }
}

atparser_cmd_exit(g_atparser_uservice_t);

aos_mutex_unlock(&g_cmd_mutex);

return ret;
}</code></pre>

        »ùÓÚHello World DemoÀ©Õ¹£¬init.cÖÐÌí¼ÓÒ»¸öntpº¯Êý£¬ÕâÑùÔÚntpÍ¬²½ºóÔÙ½øÐÐ´«Êä²ãinput»Øµ÷º¯ÊýµÄ×¢²á¡£ÆäÖÐDelay()º¯ÊýÊÇDemo OLEDÇý¶¯ÖÐ¶¨Òå£¬²éÑ¯SysTickµÄÂß¼£¬Ã»ÓÐÓÃaos_sleep()£¬ÊÇÅÂÈÎÎñÅÜ·É¡£ÁíÍâ£¬ÕâÀïµÄÑÓÊ±Ò²ÊÇÎªÁËºÍÇ°ÃæµÄÍøÂç³õÊ¼»¯¼ä¸ô¿ªÀ´£¬²»¼ÓÒ²¿ÉÒÔ¡£È»ºó£¬¾ÍÊÇÍøÂçÊÂ¼þ»Øµ÷ÖÐ£¬ÔÚ»ñµÃIP¼´Á¬½ÓAPºó½øÐÐntp²âÊÔ¡£Ä¿Ç°£¬Ð´µ½ÕâÀïÊ±»¹Ã»ÓÐÑÐ¾¿Ìí¼ÓÊ±Çø½ÃÕýºÍRTC£¬ºóÐø¿ÉÒÔÔÚÆô¶¯Ê±×öÒ»´ÎÊ±¼äÍ¬²½¾ÍºÃ¡£

<pre>
<code>//ntp test func
void aita_ntptest(void) {
Delay(1000); //delay 1s then use ntp
ntp_sync_time("ntp1.aliyun.com");

//register input event callback for w800 module
w800_packet_input_cb_register(&aita_w800in_cb);
}

//network event callback function
static void network_event(uint32_t event_id, const void *param, void *context) {
switch(event_id) {
case EVENT_NETMGR_GOT_IP: {
LOGD(TAG, "EVENT_NETMGR_GOT_IP\n");
printf("start polling_timer. periodic: %d min\n", period);
aita_StartTimer;
aita_ntptest();
break;
}
case EVENT_NETMGR_NET_DISCON: {
LOGD(TAG, "EVENT_NETMGR_NET_DISCON\n");
printf("ready to restart wifi connection...\n");
aita_InitNetwork();
// netmgr_reset(app_netmgr_hdl, 30);
break;
}
}
}</code></pre>

Jacktang ·¢±íÓÚ 2022-4-9 17:07

»ùÓÚHello World DemoÀ©Õ¹£¬init.cÖÐÌí¼ÓÒ»¸öntpº¯Êý£¬ÕâÑùÔÚntpÍ¬²½ºóÔÙ½øÐÐ´«Êä²ãinput»Øµ÷º¯ÊýµÄ×¢²áÓÐÊÕ»ñ£¬£¬£¬

Õâ¸ö±ØÐëÊÕ²Ø£¬Â¥Ö÷µÄNTPÊÚÊ±²âÊÔ£¬»¨·ÑÁËºÜ´ó¾«Á¦¾ÑéÂúÂú

sonicfirr ·¢±íÓÚ 2022-4-9 20:42

Jacktang ·¢±íÓÚ 2022-4-9 17:07
»ùÓÚHello World DemoÀ©Õ¹£¬init.cÖÐÌí¼ÓÒ»¸öntpº¯Êý£¬ÕâÑùÔÚntpÍ¬²½ºóÔÙ½øÐÐ´«Êä²ãinput»Øµ÷º¯ÊýµÄ×¢²áÓÐ ...

Ð»Ð»£¬ÔÞÉÍ

Ò³: [1]

µç×Ó¹¤³ÌÊÀ½ç-ÂÛÌ³'s Archiver

¡¾Æ½Í·¸çRVB2601´´ÒâÓ¦ÓÃ¿ª·¢¡¿Ê¹ÓÃÌåÑé06 -- NTPÊÚÊ±