【移動應(yīng)用開發(fā)技術(shù)】andriod搭建輪詢框架的方法

【移動應(yīng)用開發(fā)技術(shù)】andriod搭建輪詢框架的方法

在下給大家分享一下andriod搭建輪詢框架的方法，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！很多時候Android應(yīng)用需要每間隔一段時間向服務(wù)器請求數(shù)據(jù)，如果服務(wù)器數(shù)據(jù)有更新則通知界面變化。Android中最常用的紅點一般采用的就是輪詢，紅點是為了在數(shù)據(jù)有更新時及時的提醒用戶，比如朋友圈更新，當(dāng)用戶的朋友圈更新時就會顯示紅點，就是通過移動端不斷的向服務(wù)器查詢朋友圈的更新狀態(tài)。相關(guān)知識點在實現(xiàn)輪詢框架時會主要會要到下面兩個類，會結(jié)合輪詢框架對這三個類進行講解，在應(yīng)用中分析會理解更加深刻。1、IntentServiceIntentService是一種特殊的Service，繼承了Service并且是一個抽象類，必須創(chuàng)建它的子類才能用。IntentService可以用于執(zhí)行后臺耗時的任務(wù)，當(dāng)任務(wù)執(zhí)行后會自動停止，IntentService的優(yōu)先級比一般的線程高，比較適合執(zhí)行一些優(yōu)先級高的后臺任務(wù)。2、PendingIntentPendingIntent是延遲的intent，主要用來在某個事件完成后執(zhí)行特定的Action。PendingIntent包含了Intent及Context，所以就算Intent所屬程序結(jié)束，PendingIntent依然有效，可以在其他程序中使用。PendingIntent一般作為參數(shù)傳給某個實例，在該實例完成某個操作后自動執(zhí)行PendingIntent上的Action，也可以通過PendingIntent的send函數(shù)手動執(zhí)行，并可以在send函數(shù)中設(shè)置OnFinished表示send成功后執(zhí)行的動作。輪詢框架實現(xiàn)要實現(xiàn)輪詢，可以借鑒Handler中的looper機制，如下圖，維護一個消息隊列，循環(huán)的從消息隊列中取出消息來執(zhí)行，輪詢框架可以定時的向消息隊列中加入消息，然后循環(huán)中消息隊列中取出消息執(zhí)行。可以自己實現(xiàn)一個Looper，但是IntentService中已經(jīng)包含了一個Looper和一個HandlerThread。因此輪詢框架中使用IntentService作為循環(huán)框架。繼承IntentService接口來實現(xiàn)處理消息訪問服務(wù)器。PollingService用于每次輪詢時向請求服務(wù)器接口數(shù)據(jù)。public

class

PollingService

extends

IntentService

{

public

static

final

String

ACTION_CHECK_CIRCLE_UPDATE="ACTION_CHECK_CIRCLE_UPDATE";

public

static

final

long

DEFAULT_MIN_POLLING_INTERVAL

=

60000;//最短輪詢間隔1分鐘

public

PollingService()

{

super("PollingService");

}

@Override

protected

void

onHandleIntent(Intent

intent)

{

if

(intent

==

null)

return;

final

String

action

=

intent.getAction();

if

(ACTION_CHECK_Circle_UPDATE.equals(action))

{

CheckCircleOfFriendsUpdate();//這個是訪問服務(wù)器獲取朋友圈是否更新

}

}

}PollingService用來處理接到輪詢的消息之后在onHandleIntent(Intentintent)中根據(jù)Intent所帶有的action不同來進行訪問服務(wù)器不同的接口獲取數(shù)據(jù)。PollingUtil用于控制輪詢服務(wù)的開始和結(jié)束使用PollingUtil中的startPollingService來根據(jù)action和context生成一個PendingIntent，并將PendingIntent交給PollingScheduler來處理。PollingScheduler是一個線程池控制類。public

class

PollingUtil

{

/**

*

開始輪詢服務(wù)

*/

public

static

void

startPollingService(final

Context

context,

String

action)

{

//包裝需要執(zhí)行Service的Intent

Intent

intent

=

new

Intent(context,

PollingService.class);

intent.setAction(action);

PendingIntent

pendingIntent

=

PendingIntent.getService(context,

0,

intent,

PendingIntent.FLAG_UPDATE_CURRENT);

PollingScheduler.getInstance().addScheduleTask(pendingIntent,

0,

PollingService.DEFAULT_MIN_POLLING_INTERVAL);

}

}

/**

*

停止輪詢服務(wù)

*

*

@param

context

*/

public

static

void

stopPollingServices(Context

context,

String

action)

{

PollingScheduler.getInstance().clearScheduleTasks();

}

}PollingScheduler實現(xiàn)定時向IntentService的Looper中加入消息PollingScheduler中生成一個單線程池，addScheduleTask中定時的執(zhí)行pendingIntent.send(),其中PendingIntent是由PendingIntentpendingIntent=PendingIntent.getService(context,0,intent,PendingIntent.FLAG_UPDATE_CURRENT);生成的，pendingIntent.send()函數(shù)會調(diào)用Service.startService()來開啟一個服務(wù)。public

class

PollingScheduler

{

private

static

PollingScheduler

sInstance;

private

ScheduledExecutorService

mScheduler;

private

PollingScheduler()

{

mScheduler

=

Executors.newSingleThreadScheduledExecutor();

}

public

static

synchronized

PollingScheduler

getInstance()

{

if

(sInstance

==

null)

{

sInstance

=

new

PollingScheduler();

}

if

(sInstance.mScheduler.isShutdown())

{

sInstance.mScheduler

=

Executors.newSingleThreadScheduledExecutor();

}

return

sInstance;

}

public

void

addScheduleTask(final

PendingIntent

pendingIntent,

long

initialDelay,

long

period)

{

Runnable

command

=

new

Runnable()

{

@Override

public

void

run()

{

try

{

pendingIntent.send();

}

catch

(PendingIntent.CanceledException

e)

{

e.printStackTrace();

}

}

};

mScheduler.scheduleAtFixedRate(command,

initialDelay,

period,

TimeUnit.MILLISECONDS);

}

public

void

clearScheduleTasks()

{

mScheduler.shutdownNow();

}

}代碼分析先給出類圖之間的關(guān)系如下：

PollingService繼承了IntentService，并且在PollingUtil的startPollingService方法中通過Intentintent=newIntent(context,PollingService.class);和將PendingIntent與PollingService關(guān)聯(lián)起來，并將PendingIntent加入到定時執(zhí)行的線程池中，在PollingScheduler中使用pendingIntent.send();由于PendingIntent與PollingService關(guān)聯(lián)，所以執(zhí)行pendingIntent.send()的時候會調(diào)用PollingIntentServide中的onStart()方法。onStart（）方法是IntentService中的方法，代碼如下：

@Override

public

void

onStart(@Nullable

Intent

intent,

int

startId)

{

Message

msg

=

mServiceHandler.obtainMessage();

msg.arg1

=

startId;

msg.obj

=

intent;

mServiceHandler.sendMessage(msg);

}在onstart()中有一個mServiceHandler.sendMessage(msg);，找到mServiceHandler的生成位置：

@Override

public

void

onCreate()

{

super.onCreate();

HandlerThread

thread

=

new

HandlerThread("IntentService["

+

mName

+

"]");

thread.start();

mServiceLooper

=

thread.getLooper();

mServiceHandler

=

new

ServiceHandler(mServiceLooper);

}在IntentService的onCreate方法中生成了一個HandlerThread，一個mServiceLooper,一個mServiceHandler,其中mServiceHandler.sendMessage(msg)中的msg都會放到mServiceLooper，執(zhí)行時從mServiceLooper中取出執(zhí)行，其中ServiceHandler的代碼如下

private

final

class

ServiceHandler

extends

Handler

{

public

ServiceHandler(Looper

looper)

{

super(looper);

}

@Override

public

void

handleMessage(Message

msg)

{

onHandleIntent((Intent)msg.obj);

stopSelf(msg.arg1);

}