網(wǎng)站首頁 編程語言 正文
正文
NTP是Android原生通過網(wǎng)絡(luò)獲取時間的機(jī)制,其中關(guān)鍵代碼邏輯都在NetworkTimeUpdateService,它是Android系統(tǒng)服務(wù),由SystemServer啟動。
本篇文章基于Android 10源碼分析。
初始化
我們從它的構(gòu)造方法開始分析:
public NetworkTimeUpdateService(Context context) {
mContext = context;
//NtpTrustedTime用于獲取網(wǎng)絡(luò)時間
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ā)送定時廣播
mPendingPollIntent = PendingIntent.getBroadcast(mContext, POLL_REQUEST, pollIntent, 0);
// 請求服務(wù)器頻率 86400000ms = 24h
//從配置文件LINUX/android/frameworks/base/core/res/res/values/config.xml中解析獲得
mPollingIntervalMs = mContext.getResources().getInteger(
com.android.internal.R.integer.config_ntpPollingInterval);
//請求時間間隔 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)造方法中主要是對各種變量進(jìn)行初始化操作,接下來分析systemRunning方法,它是個public方法,NetworkTimeUpdateService創(chuàng)建時,被SystemServer調(diào)用。
/** Initialize the receivers and initiate the first NTP request */
public void systemRunning() {
//注冊廣播
registerForAlarms();
//初始化Handler
HandlerThread thread = new HandlerThread(TAG);
thread.start();
mHandler = new MyHandler(thread.getLooper());
//向ConnectivityManager注冊網(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));
}
這個方法中NetworkTimeUpdateService注冊了三個監(jiān)聽:
- 1.調(diào)用registerForAlarms,注冊一個廣播接收者,接收ACTION_POLL廣播,收到后向消息隊(duì)列發(fā)送一個EVENT_POLL_NETWORK_TIME的事件;
- 2.向ConnectivityManager注冊網(wǎng)絡(luò)狀況監(jiān)聽;
- 3.監(jiān)聽Settings.Global.AUTO_TIME值的變化。
咱們對這三個監(jiān)聽以及如何觸發(fā)挨個的分析。
NetworkTimeUpdateCallback
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ò)切換/可用)時, 賦值mDefaultNetwork并調(diào)用onPollNetworkTime(EVENT_NETWORK_CHANGED)方法。
AutoTimeSettingObserver
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 時,向消息隊(duì)列發(fā)送一個類型為EVENT_AUTO_TIME_ENABLED的消息。
看到這有三個東西我們還沒確認(rèn),何時發(fā)送ACTION_POLL廣播、onPollNetworkTime方法實(shí)現(xiàn)、Handler的實(shí)現(xiàn)。為了更有條理我打亂一下順序,先介紹Handler和onPollNetworkTime。
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;
}
}
}
三種類型的消息最終都會調(diào)用onPollNetworkTime,只有參數(shù)不一樣。
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ǎng)絡(luò)情況直接返回,并使用PowerManager.WakeLock(屏幕恒亮)調(diào)用onPollNetworkTimeUnderWakeLock(event)。
private void onPollNetworkTimeUnderWakeLock(int event) {
// 使用NtpTrustedTime獲取網(wǎng)絡(luò)時間
NtpTrustedTime.TimeResult cachedNtpResult = mTime.getCachedTimeResult();
//cachedNtpResult.getAgeMillis()是上次請求ntp服務(wù)器的時間
//如果大于等于1天,則強(qiáng)制刷新時間
if (cachedNtpResult == null || cachedNtpResult.getAgeMillis() >= mPollingIntervalMs) {
if (DBG) Log.d(TAG, "Stale NTP fix; forcing refresh");
//該方法是個阻塞方法
mTime.forceRefresh();
cachedNtpResult = mTime.getCachedTimeResult();
}
//cachedNtpResult.getAgeMillis() < 1天
if (cachedNtpResult != null && cachedNtpResult.getAgeMillis() < mPollingIntervalMs) {
//設(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)時間
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è)置定時廣播,10分鐘后觸發(fā)
resetAlarm(mPollingIntervalShorterMs);
} else {
//設(shè)置定時廣播,1天后觸發(fā)
mTryAgainCounter = 0;
resetAlarm(mPollingIntervalMs);
}
}
}
注意到上面調(diào)用了resetAlarm(),該方法即是定時發(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);
}
總結(jié)一下onPollNetworkTimeUnderWakeLock做的事情:
總結(jié)
NetworkTimeUpdateService啟動后有兩種方式觸發(fā)時間更新。
1.網(wǎng)絡(luò)發(fā)生變化;
2.Settings中的AUTO_TIME開關(guān)變化;
最終都會調(diào)用onPollNetworkTimeUnderWakeLock去設(shè)置時間,根據(jù)獲取的cachedNtpResult情況設(shè)置不同時間的定時廣播再去嘗試更新時間。
原文鏈接:https://juejin.cn/post/7128738369659486239
相關(guān)推薦
- 2023-02-01 MongoDB?事務(wù)支持詳解_MongoDB
- 2022-11-19 Python教程之無限迭代器的使用詳解_python
- 2022-11-10 C語言宏定義容易認(rèn)不清的盲區(qū)梳理_C 語言
- 2022-05-22 Kubernetes探針使用介紹_云其它
- 2022-07-09 Python如何保留float類型小數(shù)點(diǎn)后3位_python
- 2022-09-13 flutter狀態(tài)管理Provider的使用學(xué)習(xí)_IOS
- 2022-07-16 CMake下調(diào)用anaconda的pytorch及numpy傳參CV::Mat給python(多線程
- 2022-07-14 python利用線程生成不同尺寸的縮略圖實(shí)例詳解_python
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細(xì)win安裝深度學(xué)習(xí)環(huán)境2025年最新版(
- Linux 中運(yùn)行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎(chǔ)操作-- 運(yùn)算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認(rèn)證信息的處理
- Spring Security之認(rèn)證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權(quán)
- redisson分布式鎖中waittime的設(shè)
- maven:解決release錯誤:Artif
- restTemplate使用總結(jié)
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實(shí)現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務(wù)發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結(jié)構(gòu)-簡單動態(tài)字符串(SD
- arthas操作spring被代理目標(biāo)對象命令
- Spring中的單例模式應(yīng)用詳解
- 聊聊消息隊(duì)列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠(yuǎn)程分支