From 3dedb6f74f7c86c2c5d918c5349e2264cd44b771 Mon Sep 17 00:00:00 2001 From: 1754048656 <1754048656@qq.com> Date: Wed, 3 Jan 2024 11:43:11 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E6=B7=BB=E5=8A=A0=20ntp=20=E6=97=B6?= =?UTF-8?q?=E9=97=B4=E6=A0=A1=E5=87=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/linsheng/FATJS/node/TaskBase.java | 2 + .../linsheng/FATJS/ntptime/NtpService.java | 59 ++++ .../linsheng/FATJS/ntptime/SntpClient.java | 281 ++++++++++++++++++ 3 files changed, 342 insertions(+) create mode 100644 app/src/main/java/com/linsheng/FATJS/ntptime/NtpService.java create mode 100644 app/src/main/java/com/linsheng/FATJS/ntptime/SntpClient.java diff --git a/app/src/main/java/com/linsheng/FATJS/node/TaskBase.java b/app/src/main/java/com/linsheng/FATJS/node/TaskBase.java index 824b821..8fedc3e 100644 --- a/app/src/main/java/com/linsheng/FATJS/node/TaskBase.java +++ b/app/src/main/java/com/linsheng/FATJS/node/TaskBase.java @@ -17,6 +17,7 @@ import com.caoccao.javet.interop.V8Host; import com.caoccao.javet.interop.converters.JavetProxyConverter; import com.linsheng.FATJS.findColor.ScreenLib; +import com.linsheng.FATJS.ntptime.NtpService; import com.linsheng.FATJS.okhttp3.WebSocketUtils; import com.linsheng.FATJS.utils.ExceptionUtil; import com.linsheng.FATJS.utils.FileUtils; @@ -54,6 +55,7 @@ public void initJavet(String script_path) { v8Runtime.getGlobalObject().set("UiObject", UiObject.class); v8Runtime.getGlobalObject().set("app", App.class); v8Runtime.getGlobalObject().set("Intent", Intent.class); + v8Runtime.getGlobalObject().set("ntpService", NtpService.class); if (!script.contains("let task = new engines()")) { script = base + "\n" + script; } diff --git a/app/src/main/java/com/linsheng/FATJS/ntptime/NtpService.java b/app/src/main/java/com/linsheng/FATJS/ntptime/NtpService.java new file mode 100644 index 0000000..3d8d90e --- /dev/null +++ b/app/src/main/java/com/linsheng/FATJS/ntptime/NtpService.java @@ -0,0 +1,59 @@ +package com.linsheng.FATJS.ntptime; + +import static com.linsheng.FATJS.config.GlobalVariableHolder.tag; + +import android.os.SystemClock; +import android.util.Log; + +import java.util.ArrayList; +import java.util.List; + +public class NtpService { + private static final String TAG = tag; + // "ntp1.aliyun.com" 不太稳 + private static String[] ntpServerPool = { + "ntp2.aliyun.com", "ntp3.aliyun.com", "ntp4.aliyun.com", + "ntp5.aliyun.com", "ntp6.aliyun.com", "ntp7.aliyun.com"}; + + public static long calibrationTime() { + SntpClient sntpClient = new SntpClient(); + List ntpTimeList = new ArrayList<>(); + int index = 0; + for (String serverHost : ntpServerPool) { + if (sntpClient.requestTime(serverHost, 3000)) { + long ntpTime = sntpClient.getNtpTime(); + long elapsedRealtime = SystemClock.elapsedRealtime(); + long ntpTimeReference = sntpClient.getNtpTimeReference(); + long now = sntpClient.getNtpTime() + SystemClock.elapsedRealtime() - sntpClient.getNtpTimeReference(); + // Log.d(TAG, String.format("Host:%s -> ntpTime = %s, elapsedRealtime = %s, ntpTimeReference = %s.", serverHost, ntpTime, elapsedRealtime, ntpTimeReference)); + long timeMillis = System.currentTimeMillis(); + long offset = (timeMillis - now); + Log.i(TAG, "calibrationTime ntpNow: " + now); + Log.i(TAG, "calibrationTime timeMillisNow: " + timeMillis); + Log.i(TAG, "calibrationTime offset: " + offset); + ntpTimeList.add(offset); + index ++; + } + } + if (ntpTimeList.size() == 0) { + return -1; + } + Log.i(TAG, "calibrationTime: index: " + index); + // 计算平均值 + return calculateAverage(ntpTimeList); + } + + public static long sysTime() { + return System.currentTimeMillis(); + } + + private static long calculateAverage(List list) { + long sum = 0; + // 计算总和 + for (long value : list) { + sum += value; + } + // 计算平均值 + return sum / list.size(); + } +} diff --git a/app/src/main/java/com/linsheng/FATJS/ntptime/SntpClient.java b/app/src/main/java/com/linsheng/FATJS/ntptime/SntpClient.java new file mode 100644 index 0000000..add3476 --- /dev/null +++ b/app/src/main/java/com/linsheng/FATJS/ntptime/SntpClient.java @@ -0,0 +1,281 @@ +/* + * Copyright (C) 2008 The Android Open Source Project + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.linsheng.FATJS.ntptime; + +import static com.linsheng.FATJS.config.GlobalVariableHolder.tag; + +import android.os.SystemClock; +import android.util.Log; + +import java.net.DatagramPacket; +import java.net.DatagramSocket; +import java.net.InetAddress; +import java.net.UnknownHostException; +import java.util.Arrays; + +/** + * Simple SNTP client class for retrieving network time. + * + * Sample usage: + * 
SntpClient client = new SntpClient();
+ * if (client.requestTime("time.foo.com")) {
+ *     long now = client.getNtpTime() + SystemClock.elapsedRealtime() - client.getNtpTimeReference();
+ * }
+ *
+ */ +public class SntpClient { + private static final String TAG = tag; + private static final boolean DBG = true; + + private static final int REFERENCE_TIME_OFFSET = 16; + private static final int ORIGINATE_TIME_OFFSET = 24; + private static final int RECEIVE_TIME_OFFSET = 32; + private static final int TRANSMIT_TIME_OFFSET = 40; + private static final int NTP_PACKET_SIZE = 48; + + private static final int NTP_PORT = 123; + private static final int NTP_MODE_CLIENT = 3; + private static final int NTP_MODE_SERVER = 4; + private static final int NTP_MODE_BROADCAST = 5; + private static final int NTP_VERSION = 3; + + private static final int NTP_LEAP_NOSYNC = 3; + private static final int NTP_STRATUM_DEATH = 0; + private static final int NTP_STRATUM_MAX = 15; + + // Number of seconds between Jan 1, 1900 and Jan 1, 1970 + // 70 years plus 17 leap days + private static final long OFFSET_1900_TO_1970 = ((365L * 70L) + 17L) * 24L * 60L * 60L; + + // system time computed from NTP server response + private long mNtpTime; + + // value of SystemClock.elapsedRealtime() corresponding to mNtpTime + private long mNtpTimeReference; + + // round trip time in milliseconds + private long mRoundTripTime; + + private static class InvalidServerReplyException extends Exception { + public InvalidServerReplyException(String message) { + super(message); + } + } + + public boolean host2Address(String host) { + try { + InetAddress address = InetAddress.getByName(host); + if (address != null) { + Log.d(TAG, "Server address: " + address.toString()); + return true; + } + } catch (UnknownHostException e) { + Log.e(TAG, "UnknownHost: " + host + " ,msg: " + e.getMessage()); + return false; + } + return false; + } + + /** + * Sends an SNTP request to the given host and processes the response. + * + * @param host host name of the server. + * @param timeout network timeout in milliseconds. + * @return true if the transaction was successful. + */ + public boolean requestTime(String host, int timeout) { + DatagramSocket socket = null; + InetAddress address = null; + try { + address = InetAddress.getByName(host); + socket = new DatagramSocket(); + socket.setSoTimeout(timeout); + byte[] buffer = new byte[NTP_PACKET_SIZE]; + DatagramPacket request = new DatagramPacket(buffer, buffer.length, address, NTP_PORT); + + // set mode = 3 (client) and version = 3 + // mode is in low 3 bits of first byte + // version is in bits 3-5 of first byte + buffer[0] = NTP_MODE_CLIENT | (NTP_VERSION << 3); + + // get current time and write it to the request packet + final long requestTime = System.currentTimeMillis(); + final long requestTicks = SystemClock.elapsedRealtime(); + writeTimeStamp(buffer, TRANSMIT_TIME_OFFSET, requestTime); + + socket.send(request); + + // read the response + DatagramPacket response = new DatagramPacket(buffer, buffer.length); + socket.receive(response); + final long responseTicks = SystemClock.elapsedRealtime(); + final long responseTime = requestTime + (responseTicks - requestTicks); + + // extract the results + final byte leap = (byte) ((buffer[0] >> 6) & 0x3); + final byte mode = (byte) (buffer[0] & 0x7); + final int stratum = (int) (buffer[1] & 0xff); + final long originateTime = readTimeStamp(buffer, ORIGINATE_TIME_OFFSET); + final long receiveTime = readTimeStamp(buffer, RECEIVE_TIME_OFFSET); + final long transmitTime = readTimeStamp(buffer, TRANSMIT_TIME_OFFSET); + + /* do sanity check according to RFC */ + // TODO: validate originateTime == requestTime. + checkValidServerReply(leap, mode, stratum, transmitTime); + + long roundTripTime = responseTicks - requestTicks - (transmitTime - receiveTime); + // receiveTime = originateTime + transit + skew + // responseTime = transmitTime + transit - skew + long clockOffset = ((receiveTime - originateTime) + (transmitTime - responseTime))/2; + // = ((originateTime + transit + skew - originateTime) + + // (transmitTime - (transmitTime + transit - skew)))/2 + // = ((transit + skew) + (transmitTime - transmitTime - transit + skew))/2 + // = (transit + skew - transit + skew)/2 + // = (2 * skew)/2 = skew + + Log.d(TAG, "Request time form ntp server success, " + address.toString() + " ,roundTripTime: " + roundTripTime); + if (DBG) { + Log.d(TAG, "round trip: " + roundTripTime + "ms, " + "clock offset: " + clockOffset + "ms"); + } + + // save our results - use the times on this side of the network latency + // (response rather than request time) + mNtpTime = responseTime + clockOffset; + mNtpTimeReference = responseTicks; + mRoundTripTime = roundTripTime; + + } catch (Exception e) { + if (DBG) { + Log.e(TAG, "Error address: " + String.valueOf(address)); + } + Log.e(TAG, "Request time from ntp server failed ,msg: " + e.getMessage()); + return false; + } finally { + if (socket != null) { + Log.i(TAG, "requestTime: socket close()"); + socket.close(); + } + } + return true; + } + + /** + * Returns the time computed from the NTP transaction. + * + * @return time value computed from NTP server response. + */ + public long getNtpTime() { + return mNtpTime; + } + + /** + * Returns the reference clock value (value of SystemClock.elapsedRealtime()) + * corresponding to the NTP time. + * + * @return reference clock corresponding to the NTP time. + */ + public long getNtpTimeReference() { + return mNtpTimeReference; + } + + /** + * Returns the round trip time of the NTP transaction + * + * @return round trip time in milliseconds. + */ + public long getRoundTripTime() { + return mRoundTripTime; + } + + private static void checkValidServerReply( + byte leap, byte mode, int stratum, long transmitTime) + throws InvalidServerReplyException { + if (leap == NTP_LEAP_NOSYNC) { + throw new InvalidServerReplyException("unsynchronized server"); + } + if ((mode != NTP_MODE_SERVER) && (mode != NTP_MODE_BROADCAST)) { + throw new InvalidServerReplyException("untrusted mode: " + mode); + } + if ((stratum == NTP_STRATUM_DEATH) || (stratum > NTP_STRATUM_MAX)) { + throw new InvalidServerReplyException("untrusted stratum: " + stratum); + } + if (transmitTime == 0) { + throw new InvalidServerReplyException("zero transmitTime"); + } + } + + /** + * Reads an unsigned 32 bit big endian number from the given offset in the buffer. + */ + private long read32(byte[] buffer, int offset) { + byte b0 = buffer[offset]; + byte b1 = buffer[offset + 1]; + byte b2 = buffer[offset + 2]; + byte b3 = buffer[offset + 3]; + + // convert signed bytes to unsigned values + int i0 = ((b0 & 0x80) == 0x80 ? (b0 & 0x7F) + 0x80 : b0); + int i1 = ((b1 & 0x80) == 0x80 ? (b1 & 0x7F) + 0x80 : b1); + int i2 = ((b2 & 0x80) == 0x80 ? (b2 & 0x7F) + 0x80 : b2); + int i3 = ((b3 & 0x80) == 0x80 ? (b3 & 0x7F) + 0x80 : b3); + + return ((long) i0 << 24) + ((long) i1 << 16) + ((long) i2 << 8) + (long) i3; + } + + /** + * Reads the NTP time stamp at the given offset in the buffer and returns + * it as a system time (milliseconds since January 1, 1970). + */ + private long readTimeStamp(byte[] buffer, int offset) { + long seconds = read32(buffer, offset); + long fraction = read32(buffer, offset + 4); + // Special case: zero means zero. + if (seconds == 0 && fraction == 0) { + return 0; + } + return ((seconds - OFFSET_1900_TO_1970) * 1000) + ((fraction * 1000L) / 0x100000000L); + } + + /** + * Writes system time (milliseconds since January 1, 1970) as an NTP time stamp + * at the given offset in the buffer. + */ + private void writeTimeStamp(byte[] buffer, int offset, long time) { + // Special case: zero means zero. + if (time == 0) { + Arrays.fill(buffer, offset, offset + 8, (byte) 0x00); + return; + } + + long seconds = time / 1000L; + long milliseconds = time - seconds * 1000L; + seconds += OFFSET_1900_TO_1970; + + // write seconds in big endian format + buffer[offset++] = (byte) (seconds >> 24); + buffer[offset++] = (byte) (seconds >> 16); + buffer[offset++] = (byte) (seconds >> 8); + buffer[offset++] = (byte) (seconds >> 0); + + long fraction = milliseconds * 0x100000000L / 1000L; + // write fraction in big endian format + buffer[offset++] = (byte) (fraction >> 24); + buffer[offset++] = (byte) (fraction >> 16); + buffer[offset++] = (byte) (fraction >> 8); + // low order bits should be random data + buffer[offset++] = (byte) (Math.random() * 255.0); + } +}