自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

Android系統(tǒng)如何通過(guò)NTP協(xié)議自動(dòng)同步時(shí)間,以及NTP服務(wù)的關(guān)鍵代碼邏輯

移動(dòng)開發(fā) Android
NTP 的主要目標(biāo)是提供高準(zhǔn)確性的時(shí)間。NTP 版本 4 (NTPv4) 可以提供毫秒級(jí)的精度,而更先進(jìn)的實(shí)現(xiàn)(如 RFC 5905 中定義的 NTP Secure 或 Precision Time Protocol, PTP)可以提供微秒或納秒級(jí)的精度。

NTP網(wǎng)絡(luò)時(shí)間協(xié)議

NTP (Network Time Protocol) 網(wǎng)絡(luò)時(shí)間協(xié)議用于同步計(jì)算機(jī)系統(tǒng)之間的時(shí)鐘。NTP允許計(jì)算機(jī)時(shí)鐘與參考時(shí)鐘源(如原子鐘、GPS 接收器或其他 NTP 服務(wù)器)進(jìn)行同步,時(shí)間的準(zhǔn)確性對(duì)于金融交易、網(wǎng)絡(luò)通信、科學(xué)研究和安全系統(tǒng)等應(yīng)用來(lái)說(shuō)至關(guān)重要。

NTP協(xié)議特點(diǎn)和功能:

  1. 「準(zhǔn)確性」:NTP 的主要目標(biāo)是提供高準(zhǔn)確性的時(shí)間。NTP 版本 4 (NTPv4) 可以提供毫秒級(jí)的精度,而更先進(jìn)的實(shí)現(xiàn)(如 RFC 5905 中定義的 NTP Secure 或 Precision Time Protocol, PTP)可以提供微秒或納秒級(jí)的精度。
  2. 「層次結(jié)構(gòu)」:NTP 使用層次結(jié)構(gòu)來(lái)組織服務(wù)器。時(shí)間信息從參考時(shí)鐘源(稱為“一級(jí)”服務(wù)器)流向“二級(jí)”服務(wù)器,再流向“三級(jí)”服務(wù)器,以此類推。每個(gè)服務(wù)器都會(huì)增加一定的延遲和誤差,NTP 算法會(huì)盡力補(bǔ)償這些誤差。
  3. 「時(shí)間同步」:NTP 通過(guò)交換時(shí)間戳和延遲測(cè)量來(lái)同步時(shí)間。NTP 客戶端向服務(wù)器發(fā)送一個(gè)時(shí)間請(qǐng)求,服務(wù)器響應(yīng)時(shí)附帶當(dāng)前時(shí)間戳??蛻舳巳缓笥?jì)算往返延遲,使用這些信息來(lái)調(diào)整其本地時(shí)鐘。
  4. 「可伸縮性」:NTP 可以在各種規(guī)模的網(wǎng)絡(luò)中運(yùn)行,從小型局域網(wǎng)到全球互聯(lián)網(wǎng)。NTP 服務(wù)器可以支持大量客戶端,并且通過(guò)負(fù)載均衡和冗余來(lái)提高可靠性和可用性。
  5. 「安全性」:NTP 的安全性是一個(gè)重要問(wèn)題,因?yàn)閻阂夥?wù)器可能嘗試提供錯(cuò)誤的時(shí)間信息。NTP Secure (RFC 5905) 提供了一種加密和認(rèn)證機(jī)制,可以確保時(shí)間信息的完整性和真實(shí)性。
  6. 「廣播和多播」:NTP 支持廣播和多播模式,大量客戶端可以同時(shí)從單個(gè)服務(wù)器獲取時(shí)間信息。
  7. 「兼容性」:NTP 與之前的互聯(lián)網(wǎng)時(shí)間同步協(xié)議(如 ICMP 時(shí)間戳和 Daytime 協(xié)議)兼容,并提供了更高級(jí)別的準(zhǔn)確性和功能。

Android NTP時(shí)間同步機(jī)制

Android系統(tǒng)的NTP時(shí)間同步通過(guò)訪問(wèn)Internet上的NTP服務(wù)器來(lái)自動(dòng)更新時(shí)間?;驹硎峭ㄟ^(guò)NTP協(xié)議與NTP服務(wù)器進(jìn)行通信,獲取當(dāng)前準(zhǔn)確的時(shí)間,然后同步到本地設(shè)備中。NTP服務(wù)器會(huì)返回一個(gè)時(shí)間戳,時(shí)間戳表示NTP服務(wù)器所認(rèn)為的當(dāng)前標(biāo)準(zhǔn)時(shí)間,Android設(shè)備可以通過(guò)與本地系統(tǒng)時(shí)間進(jìn)行比較,得出本地設(shè)備對(duì)準(zhǔn)確時(shí)間的偏差,并進(jìn)行時(shí)間校正。

自動(dòng)同步時(shí)間時(shí)區(qū)配置:

  • 進(jìn)入“設(shè)置”->“日期和時(shí)間”->“使用網(wǎng)絡(luò)提供的時(shí)間”菜單。
  • 打開“自動(dòng)確定時(shí)區(qū)”和“自動(dòng)確定日期和時(shí)間”選項(xiàng),讓設(shè)備自動(dòng)選擇最佳的NTP服務(wù)器進(jìn)行同步。

源碼分析

NTP是Android原生通過(guò)網(wǎng)絡(luò)獲取時(shí)間的機(jī)制,關(guān)鍵代碼邏輯在NetworkTimeUpdateService,NetworkTimeUpdateService是Android系統(tǒng)服務(wù),由SystemServer啟動(dòng)。

「初始化」

// frameworks/base/services/core/java/com/android/server/NetworkTimeUpdateService.java
public NetworkTimeUpdateService(Context context) {
    mContext = context;
    //NtpTrustedTime用于獲取網(wǎng)絡(luò)時(shí)間
    mTime = NtpTrustedTime.getInstance(context);
    mAlarmManager = mContext.getSystemService(AlarmManager.class);
    mTimeDetector = mContext.getSystemService(TimeDetector.class);
    mCM = mContext.getSystemService(ConnectivityManager.class);

    Intent pollIntent = new Intent(ACTION_POLL, null);
    //創(chuàng)建mPendingPollIntent,用于發(fā)送定時(shí)廣播
    mPendingPollIntent = PendingIntent.getBroadcast(mContext, POLL_REQUEST, pollIntent, 0);
    // 請(qǐng)求服務(wù)器頻率 86400000ms = 24h
    //從配置文件LINUX/android/frameworks/base/core/res/res/values/config.xml中解析獲得
    mPollingIntervalMs = mContext.getResources().getInteger(com.android.internal.R.integer.config_ntpPollingInterval);
    //請(qǐng)求時(shí)間間隔60000ms = 10min
    mPollingIntervalShorterMs = mContext.getResources().getInteger(com.android.internal.R.integer.config_ntpPollingIntervalShorter);
    //最大嘗試次數(shù) 3        
    mTryAgainTimesMax = mContext.getResources().getInteger(com.android.internal.R.integer.config_ntpRetry);

    mWakeLock = context.getSystemService(PowerManager.class).newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, TAG);
}

構(gòu)造方法中主要是對(duì)各種變量進(jìn)行初始化操作,NetworkTimeUpdateService在SystemServer.java創(chuàng)建時(shí),被SystemServer調(diào)用。

// frameworks/base/services/core/java/com/android/server/NetworkTimeUpdateService.java
/** Initialize the receivers and initiate the first NTP request */
public void systemRunning() {
    //注冊(cè)廣播
    registerForAlarms();
    //初始化Handler
    HandlerThread thread = new HandlerThread(TAG);
    thread.start();
    mHandler = new MyHandler(thread.getLooper());
    //向ConnectivityManager注冊(cè)網(wǎng)絡(luò)狀況監(jiān)聽
    mNetworkTimeUpdateCallback = new NetworkTimeUpdateCallback();
    mCM.registerDefaultNetworkCallback(mNetworkTimeUpdateCallback, mHandler);
    //使用ContentObsrver監(jiān)聽Settings.Global.AUTO_TIME值的變化
    mAutoTimeSettingObserver = new AutoTimeSettingObserver(mContext, mHandler,
            EVENT_AUTO_TIME_ENABLED);
    mAutoTimeSettingObserver.observe();
}

private void registerForAlarms() {
    mContext.registerReceiver(new BroadcastReceiver() {
        @Override
        public void onReceive(Context context, Intent intent) {
            mHandler.obtainMessage(EVENT_POLL_NETWORK_TIME).sendToTarget();
        }
    }, new IntentFilter(ACTION_POLL));
}
  • 調(diào)用registerForAlarms,注冊(cè)一個(gè)廣播接收者,接收ACTION_POLL廣播,收到后向消息隊(duì)列發(fā)送一個(gè)EVENT_POLL_NETWORK_TIME的事件。
  • 向ConnectivityManager注冊(cè)網(wǎng)絡(luò)狀況監(jiān)聽。
  • 監(jiān)聽Settings.Global.AUTO_TIME值的變化。

「NetworkTimeUpdateCallback」

// frameworks/base/services/core/java/com/android/server/NetworkTimeUpdateService.java
// 定義和注冊(cè)監(jiān)聽
mNetworkTimeUpdateCallback = new NetworkTimeUpdateCallback();

mCM.registerDefaultNetworkCallback(mNetworkTimeUpdateCallback, mHandler);

private class NetworkTimeUpdateCallback extends NetworkCallback {
    @Override
    public void onAvailable(Network network) {
        Log.d(TAG, String.format("New default network %s; checking time.", network));
        mDefaultNetwork = network;
        // Running on mHandler so invoke directly.
        onPollNetworkTime(EVENT_NETWORK_CHANGED);
    }

    @Override
    public void onLost(Network network) {
        if (network.equals(mDefaultNetwork)) mDefaultNetwork = null;
    }
}

NetworkTimeUpdateCallback實(shí)現(xiàn)了NetworkCallback接口,當(dāng)回調(diào)onAvailable(網(wǎng)絡(luò)切換/可用)時(shí),賦值mDefaultNetwork并調(diào)用onPollNetworkTime(EVENT_NETWORK_CHANGED)方法。

「AutoTimeSettingObserver」

// frameworks/base/services/core/java/com/android/server/NetworkTimeUpdateService.java
mAutoTimeSettingObserver = new AutoTimeSettingObserver(mContext, mHandler,EVENT_AUTO_TIME_ENABLED);
mAutoTimeSettingObserver.observe();

/**
 * Observer to watch for changes to the AUTO_TIME setting. It only triggers when the setting
 * is enabled.
 */
private static class AutoTimeSettingObserver extends ContentObserver {

    private final Context mContext;
    private final int mMsg;
    private final Handler mHandler;

    AutoTimeSettingObserver(Context context, Handler handler, int msg) {}

    void observe() {
        ContentResolver resolver = mContext.getContentResolver();
        resolver.registerContentObserver(Settings.Global.getUriFor(Settings.Global.AUTO_TIME),false, this);
    }

    @Override
    public void onChange(boolean selfChange) {
        if (isAutomaticTimeEnabled()) {
            mHandler.obtainMessage(mMsg).sendToTarget();
        }
    }

    /**
     * Checks if the user prefers to automatically set the time.
     */
    private boolean isAutomaticTimeEnabled() {
        ContentResolver resolver = mContext.getContentResolver();
        return Settings.Global.getInt(resolver, Settings.Global.AUTO_TIME, 0) != 0;
    }
}

監(jiān)聽Settings.Global.AUTO_TIME的變化,當(dāng)值改變且AUTO_TIME != 0 時(shí),向消息隊(duì)列發(fā)送一個(gè)類型為EVENT_AUTO_TIME_ENABLED的消息。

「MyHandler」

/** Handler to do the network accesses on */
private class MyHandler extends Handler {

    MyHandler(Looper l) {
        super(l);
    }

    @Override
    public void handleMessage(Message msg) {
        switch (msg.what) {
            case EVENT_AUTO_TIME_ENABLED:
            case EVENT_POLL_NETWORK_TIME:
            case EVENT_NETWORK_CHANGED:
                onPollNetworkTime(msg.what);
                break;
        }
    }
}

Handler發(fā)送的所有消息最終都會(huì)調(diào)用onPollNetworkTime。

「onPollNetworkTime」

private void onPollNetworkTime(int event) {
    // If we don't have any default network, don't bother.
    if (mDefaultNetwork == null) return;
    mWakeLock.acquire();
    try {
        onPollNetworkTimeUnderWakeLock(event);
    } finally {
        mWakeLock.release();
    }
}

當(dāng)前無(wú)網(wǎng)絡(luò)情況直接返回,并使用PowerManager.WakeLock調(diào)用onPollNetworkTimeUnderWakeLock(event)。

private void onPollNetworkTimeUnderWakeLock(int event) {
    // 使用NtpTrustedTime獲取網(wǎng)絡(luò)時(shí)間
    NtpTrustedTime.TimeResult cachedNtpResult = mTime.getCachedTimeResult();

    //cachedNtpResult.getAgeMillis()是上次請(qǐng)求ntp服務(wù)器的時(shí)間
    //如果大于等于1天,則強(qiáng)制刷新時(shí)間
    if (cachedNtpResult == null || cachedNtpResult.getAgeMillis() >= mPollingIntervalMs) {
        if (DBG) Log.d(TAG, "Stale NTP fix; forcing refresh");
        //該方法是個(gè)阻塞方法
        mTime.forceRefresh();
        cachedNtpResult = mTime.getCachedTimeResult();
    }

    //cachedNtpResult.getAgeMillis() < 1天
    if (cachedNtpResult != null && cachedNtpResult.getAgeMillis() < mPollingIntervalMs) {
        //設(shè)置定時(shí)廣播,1天后觸發(fā)
        resetAlarm(mPollingIntervalMs);

        // Suggest the time to the time detector. It may choose use it to set the system clock.
      // 設(shè)置系統(tǒng)時(shí)間
        TimestampedValue<Long> timeSignal = new TimestampedValue<>(
                cachedNtpResult.getElapsedRealtimeMillis(), cachedNtpResult.getTimeMillis());
        NetworkTimeSuggestion timeSuggestion = new NetworkTimeSuggestion(timeSignal);
        timeSuggestion.addDebugInfo("Origin: NetworkTimeUpdateService. event=" + event);
        mTimeDetector.suggestNetworkTime(timeSuggestion);
    } else {
        mTryAgainCounter++;
        if (mTryAgainTimesMax < 0 || mTryAgainCounter <= mTryAgainTimesMax) {
            //設(shè)置定時(shí)廣播,10分鐘后觸發(fā)
            resetAlarm(mPollingIntervalShorterMs);
        } else {
            //設(shè)置定時(shí)廣播,1天后觸發(fā)
            mTryAgainCounter = 0;
            resetAlarm(mPollingIntervalMs);
        }
    }
}

調(diào)用了resetAlarm(),該方法定時(shí)發(fā)送ACTION_POLL廣播。

private void resetAlarm(long interval) {
    mAlarmManager.cancel(mPendingPollIntent);
    long now = SystemClock.elapsedRealtime();
    long next = now + interval;
    mAlarmManager.set(AlarmManager.ELAPSED_REALTIME, next, mPendingPollIntent);
}

NetworkTimeUpdateService啟動(dòng)后有兩種方式觸發(fā)時(shí)間更新。

  • 網(wǎng)絡(luò)發(fā)生變化。
  • Settings中的AUTO_TIME開關(guān)變化(自動(dòng)同步日期時(shí)區(qū)開關(guān))。

最終都會(huì)調(diào)用onPollNetworkTimeUnderWakeLock去設(shè)置時(shí)間,根據(jù)獲取的cachedNtpResult情況設(shè)置不同時(shí)間的定時(shí)廣播再去嘗試更新時(shí)間。

責(zé)任編輯:武曉燕 來(lái)源: 沐雨花飛蝶
相關(guān)推薦

2022-01-27 08:53:31

LinuxNTP同步

2010-08-06 14:46:51

思科路由器NTP服務(wù)器配置

2017-01-09 09:20:07

Ubuntu NTP同步

2010-09-02 10:50:17

時(shí)間同步服務(wù)器

2019-06-10 15:50:54

LinuxNTP命令

2015-05-25 09:13:31

NTP網(wǎng)絡(luò)時(shí)間協(xié)議NTP服務(wù)器

2010-08-20 10:29:40

NTP

2009-11-26 14:42:03

開啟Suse ntp服

2024-10-12 17:23:30

2011-07-20 09:01:33

域控制器ntp服務(wù)器

2020-11-26 12:40:26

NTSNTP系統(tǒng)運(yùn)維

2025-03-12 10:31:01

2016-12-07 10:30:19

NTP網(wǎng)絡(luò)時(shí)間協(xié)議

2015-01-27 11:31:06

2018-03-19 19:00:54

2021-11-26 00:13:19

OracleRAC集群

2019-11-11 08:43:46

信息安全NTP服務(wù)放大攻擊

2018-02-23 09:32:13

LinuxUnixntpd

2019-05-07 10:00:03

ChronyNTPLinux

2022-04-30 09:41:14

LinuxNTP服務(wù)器
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)