你可以使用如下的Go代码实现一个NTP客户端,其中包括NTP服务器地址可配置、每小时同步一次时间等功能:
package main
import (
"fmt"
"net"
"time"
)
const (
NTP_SERVER = "pool.ntp.org" // 可以根据需要更改为其他NTP服务器
)
func main() {
for {
ntpTime, err := getNetworkTime(NTP_SERVER)
if err != nil {
fmt.Println("Error: ", err)
} else {
fmt.Println("Network Time: ", ntpTime)
setTime(ntpTime)
}
time.Sleep(time.Hour) // 每隔一个小时同步一次时间
}
}
// 获取网络时间
func getNetworkTime(ntpServer string) (ntpTime time.Time, err error) {
conn, err := net.Dial("udp", ntpServer+":123")
if err != nil {
return
}
defer conn.Close()
conn.SetDeadline(time.Now().Add(5 * time.Second))
request := make([]byte, 48)
request[0] = 0x1B
_, err = conn.Write(request)
if err != nil {
return
}
response := make([]byte, 48)
_, err = conn.Read(response)
if err != nil {
return
}
//获取从1900年到目前的秒数并转换成UTC时间格式返回结果。
ntpUnixSecs := uint32(response[40])<<24 | uint32(response[41])<<16 | uint32(response[42])<<8 | uint32(response[43])
return time.Unix(int64(ntpUnixSecs-2208988800), 0), nil
}
// 设置系统时间
func setTime(ntpTime time.Time) {
err := syscall.Settimeofday(&syscall.Timeval{Sec: ntpTime.Unix()})
if err != nil {
fmt.Println("Error: ", err)
}
}
需要注意的是,该代码使用了 net.Dial() 方法与NTP服务器进行连接,并发送一个48字节的请求数据包。然后从响应中解析出网络时间,最后使用 syscall.Settimeofday() 方法设置系统时间。
内容由零声教学AI助手提供,问题来源于学员提问




