贡献一段使用ESP8266连接NTP服务器获取时间的代码

1415926

做了个可以自动对时的时钟，没有从网上找到合适的读取NTP服务器时间的代码，自己写了一个，贡献出来，供需要的人参考。
使用的是ESP8266的AT指令，没有使用任何的库
有好几个函数，入口是第一个：synchDateTimeFromNTPServer()
比较粗糙，有很多地方没有判断指令是否执行成功。

1. 
   
2. 
   
3. 
   
4. /**
   
5. * 网络对时
   
6. */
   
7. void synchDateTimeFromNTPServer(){
   
8.   String cmd, respMessage;
   
9.   byte packetBuffer[48];
   
10.   
    
11.   cmd = "AT+CIPMUX=0";
    
12.   respMessage = execATCommand(cmd, 500, false);
    
13.   
    
14.   //Connect to the NTP server
    
15.   cmd = "AT+CIPSTART="UDP","1.cn.pool.ntp.org",123";
    
16.   respMessage = execATCommand(cmd, 500, false);
    
17.   
    
18.   cmd = "AT+CIPSEND=48";
    
19.   respMessage = execATCommand(cmd, 50, false);
    
20. 
    
21.   memset(packetBuffer, 0, 48);
    
22.   packetBuffer[0] = 0b11100011;   // LI, Version, Mode
    
23.   packetBuffer[1] = 0;     // Stratum, or type of clock
    
24.   packetBuffer[2] = 6;     // Polling Interval
    
25.   packetBuffer[3] = 0xEC;  // Peer Clock Precision
    
26.   packetBuffer[12]  = 49;
    
27.   packetBuffer[13]  = 0x4E;
    
28.   packetBuffer[14]  = 49;
    
29.   packetBuffer[15]  = 52;
    
30. 
    
31.   Serial.setTimeout(30000);
    
32.   while(Serial.available() > 0){
    
33.     Serial.read();
    
34.   }
    
35.   Serial.write(packetBuffer, 48);
    
36.   String data = "";
    
37.   unsigned long t1 = millis();
    
38.   byte ntpPackage[48];
    
39.   do{
    
40.     char r = Serial.read();
    
41.     if(r == '\n' || r == '\r'){
    
42.       data = "";
    
43.     }else if( r >= 0){
    
44.       data += r;
    
45.     }
    
46. 
    
47.     if(data == "+IPD,48:"){
    
48.       Serial.readBytes(ntpPackage, 48);
    
49.       parserNTPMessage(ntpPackage);
    
50.       break;
    
51.     }
    
52.   }while(millis() - t1 < 30000);
    
53. 
    
54.   cmd = "AT+CIPCLOSE";
    
55.   respMessage = execATCommand(cmd, 200, true);
    
56. }
    
57. 
    
58. 
    
59. /**
    
60. * 解析NTP服务器返回的报文，
    
61. *
    
62. */
    
63. void parserNTPMessage (byte ntpPackage[]){
    
64.   byte li = (byte) ((ntpPackage[0] >> 6) & 0x3);
    
65.   byte ver = (byte) ((ntpPackage[0] >> 3) & 0x7);
    
66.   byte mode = (byte) (ntpPackage[0] & 0x7);
    
67.   //Serial.println("  LI=" + String(li) + "; version=" + String(ver) + "; mode=" + String(mode));
    
68.   if(li == (byte) 11){
    
69.     //11表示当前不可对时（服务器处于闰秒状态）
    
70.     return;
    
71.   }
    
72.   unsigned long highWord = word(ntpPackage[40], ntpPackage[41]);
    
73.   unsigned long lowWord = word(ntpPackage[42], ntpPackage[43]);
    
74.   // combine the four bytes (two words) into a long integer
    
75.   // this is NTP time (seconds since Jan 1 1900):
    
76.   unsigned long secsSince1900 = highWord << 16 | lowWord;
    
77. 
    
78.   unsigned long secs = secsSince1900 + 8 * 3600L; //东八区，加8小时
    
79. 
    
80.   int y = 1900, mon, d, h, m, s, wk;
    
81. 
    
82.   wk = (secs / 86400L) % 7 + 1; //86400 is secons in one day; +1 for 1900/1/1 is Monday
    
83.   
    
84.   do{
    
85.     unsigned long ys;
    
86.     if(( y % 4 == 0 && y % 100 != 0) || y % 400 == 0){
    
87.       ys = 31622400L; //31622400 = 366 * 24 * 3600;
    
88.     }else{
    
89.       ys = 31536000L;  // 31536000 = 365 * 24 * 3600;
    
90.     }
    
91.     if(secs < ys){
    
92.       break;
    
93.     }else{
    
94.       secs -= ys;
    
95.       y++;
    
96.     }
    
97.   }while(1);
    
98.   
    
99.   int mons[12] = {31,28,31,30,31,30,31,31,30,31,30,31};
    
100.   if((y % 4 == 0 && y % 100 != 0) || y % 400 == 0){
     
101.     mons[1] = 29;
     
102.   }
     
103.   for(mon=0; mon < 12; mon ++){
     
104.     if(secs < mons[mon] * 86400L){
     
105.       break;
     
106.     }else{
     
107.       secs -= mons[mon] * 86400L;
     
108.     }
     
109.   }
     
110. 
     
111.   d = secs / 86400L + 1; //86400 = 24 * 3600 = how many seconds in a day
     
112.   secs = secs % 86400L;
     
113. 
     
114.   h = secs / 3600;
     
115.   secs = secs % 3600;
     
116.   m = secs / 60;
     
117.   s = secs % 60;
     
118.   
     
119.   //NTP服务器返回的时间已经解析完毕
     
120.   //TODO:如果需要更精确的时间，需要处理报文中的服务器收到请求和处理完毕的时间戳；
     
121.   //记录arduino发送NTP request和收到response的时间戳，
     
122.   //计算网络消耗掉的时长并加到这里获得的时间上
     
123. 
     
124.          
     
125.   //char buf[50];
     
126.   //snprintf(buf, sizeof(buf), "%04d/%02d/%02d %02d:%02d:%02d %0d", y, mon + 1, d, h, m, s, wk);
     
127.   //Serial.print("DATE: ");
     
128.   //Serial.println(buf);
     
129. }
     
130. 
     
131. 
     
132. /**
     
133. * 向TCP Server发送消息
     
134. */
     
135. void sendMessage(String msg){
     
136.   String cmd = "AT+CIPSEND=" + String(msg.length());
     
137.   execATCommand(cmd, 0, false);
     
138.   delay(10);
     
139.   //TODO:没有判断命令是否成功执行
     
140.   Serial.print(msg);
     
141. }
     
142. 
     
143. 
     
144. /**
     
145. * 获取ESP8266 IP地址
     
146. */
     
147. String getIPAddr(){
     
148.   String msg = execCommand("AT+CIFSR", 100);
     
149.   String ip = msg.substring(23,38);
     
150.   if(ip.indexOf(""") > 0){
     
151.     ip = ip.substring(0, ip.indexOf("""));
     
152.   }
     
153.   return ip;
     
154. }
     
155. 
     
156. 
     
157. String execCommand(String cmd, int timeout){
     
158.   return execATCommand(cmd, timeout, true);
     
159. }
     
160. 
     
161. 
     
162. /**
     
163. * 执行一个AT命令，并返回ESP8266的返回值
     
164. */
     
165. String execATCommand(String cmd, int timeout, boolean clearCache){
     
166.   //执行AT命令前，先把缓存内的数据都读完（不用）防止影响命令结果
     
167.   if(clearCache){
     
168.     while( Serial.available() > 0) {
     
169.       Serial.read();
     
170.     }
     
171.    
     
172.   }
     
173.   Serial.print(cmd);
     
174.   Serial.print("\r\n");
     
175.   String data = "";
     
176.   if(timeout > 0){
     
177.     //delay(50);
     
178.     long t1 = millis();
     
179.     //while(Serial.available() > 0){
     
180.     do{
     
181.         char r = Serial.read();
     
182.         if(r < 0){
     
183.           //r==-1 if nothing read
     
184.           continue;
     
185.         }
     
186.         if(r == '\r') {
     
187.           //舍弃回车，仅仅保留换行
     
188.         } else {
     
189.             data += r;  
     
190.         }
     
191.     }while((millis() - t1) < timeout);
     
192.   }
     
193.   return data;
     
194. }
     
195. 
     

复制代码

wetnt

收藏非常不错，有机会测试下了！

maidoo

最近正考虑NTP的方案改进家里的时钟呢，正好，太有帮助了。

fsj5098

最近正考虑NTP的方案改进家里的时钟呢

qjyjack612510

谢谢楼主，才学的，就想做个自动对时的钟。。。收下。。

ppc888

试了一下  月份少1   难道我在移植过程中弄坏了

sending NTP packet...
packet received, length=48
Seconds since Jan 1 1900 = 3704892427
Unix time = 1495903627
2017-5-28 0:47:7 --- wk7


显示正确的  因为在显示时补加了1
Serial.print(mon+1);

mondaywoo

初学者学习，感谢分享

1415926

ppc888 发表于 2017-5-28 00:47
试了一下  月份少1   难道我在移植过程中弄坏了

sending NTP packet...

1月用0；2月用1……12月用11表示，这个是大部分编程语言的习惯。

samsung206bw

真不错！一下就成功了！！！

super-power

请问楼主，8266芯片是不是要设置成wifi透传模式？