快捷導(dǎo)航

舉例講解Android應(yīng)用開發(fā)中OTTO框架的基本使用

更新時(shí)間：2016年02月19日 16:59:21 作者：BlackSwift

這篇文章主要介紹了Android應(yīng)用開發(fā)中OTTO框架的基本使用講解,文中舉了創(chuàng)建一個(gè)單例模式的應(yīng)用例子,需要的朋友可以參考下

OTTO是一個(gè)EventBus類型的事件傳輸總線，它可以提供“存儲轉(zhuǎn)發(fā)”的功能，讓你APP中各個(gè)組件的交流更加便利，讓你的程序分層更加清晰。

使用場景
OTTO基于Observer設(shè)計(jì)模式。它有發(fā)布者，訂閱者這兩個(gè)主要對象。OTTO的最佳實(shí)踐就是通過反射犧牲了微小的性能，同時(shí)極大的提高了程序的耦合度，更加利于MVP分工開發(fā)與維護(hù)。業(yè)務(wù)層開發(fā)者在處理資源（比如Db, REST等）后并發(fā)布消息，展示層開發(fā)者（比如Activity/Fragment）就可以處理消息，而不用關(guān)心數(shù)據(jù)是怎么來的（在讀報(bào)紙的時(shí)候需要知道編輯們?nèi)绾闻虐嬗∷?？），比如?/p>

Fragment，Service或者Activity組件之間的通信。比如
導(dǎo)航菜單的NavigationDrawer與Activity的通信
Activity與Activity的通信（在設(shè)置界面上勾選了夜間模式，回到主界面就發(fā)現(xiàn)已經(jīng)完成變色了；或者你在詳細(xì)界面上點(diǎn)了一個(gè)贊，回到主界面發(fā)現(xiàn)已經(jīng)同步增加了一個(gè)"贊"）
MVP(Model View Presidenter)架構(gòu)中，Model與Presidenter的回掉通信。包括但不限于REST, DB, SP, BroadcastReceiver, ContentObserver。

2016219165609512.png (512×512)

一、Android Studio中配置Otto (Eclipse中直接下載jar包導(dǎo)入)

跟之前介紹的其他的框架一樣，它只需要簡單地在build.gradle中配置下面的部分即可

dependencies {

  compile fileTree(dir: 'libs', include: ['*.jar'])

  compile 'com.android.support:appcompat-v7:19.+'

  /

/otto 所需要依賴的包

}

二、開始使用
1. 訂閱者
當(dāng)你想進(jìn)行訂閱時(shí)，首先要打開注冊（比如生命周期的啟動(dòng)/恢復(fù)部分）

Bus.register(this);

當(dāng)你不再關(guān)注某個(gè)事情后，需要取消注冊（比如生命周期的停止/暫停部分）

Bus.unregister(this);

當(dāng)你對某個(gè)事情感興趣的話，就加入@Subscribe進(jìn)行關(guān)注。

 @Subscribe public void getMessage(@NonNull SomeEvent s) {
     //TODO: 在回掉中使用這個(gè)事件
  }

2. 發(fā)布者
當(dāng)你想發(fā)布消息時(shí)，使用post即可，注意發(fā)布者同樣需要事先注冊。

Bus.post(SomeEvent);

實(shí)例說明
本文以短信服務(wù)接受為例，介紹OTTO的使用

1. 構(gòu)造單例模式
BUS是一個(gè)單例，所以我們要?jiǎng)?chuàng)建一個(gè)單例模式，而最簡單的單例當(dāng)然是在Application中建立，記得在Manifest注冊哦。

/**
 * Created by leon on 15/5/27.
 * 主線程事件總線，方便在異步任務(wù)中回掉
 */
public class MainThreadBus extends Bus {
 private final Handler handler = new Handler(Looper.getMainLooper());

 @Override public void post(final Object event) {
  if (Looper.myLooper() == Looper.getMainLooper()) {
   //直接通過反射調(diào)用
   super.post(event);
  } else {
   //通過handler把異步任務(wù)發(fā)送到UI線程，然后再反射調(diào)用
   handler.post(new Runnable() {
    @Override
    public void run() {
     MainThreadBus.super.post(event);
    }
   });
  }
 }
}

接著是Application的重寫

public class GlobalContext extends Application {

 //event bus singleton
 public static final MainThreadBus bus = new MainThreadBus();
 public static GlobalContext instance;

 @Override public void onCreate() {
  super.onCreate();
  instance = this;
 }

 public static MainThreadBus getBusInstance(){
  return bus;
 }

 public static GlobalContext getContextInstance(){
  return instance;
 }
}

2. 發(fā)送者（Publisher）
現(xiàn)在我們要注冊一個(gè)短信接收機(jī)器，為了與國內(nèi)毒瘤軟件搶占第一的短信監(jiān)聽，我們使用Service動(dòng)態(tài)注冊接收器，以搶占第一優(yōu)先級。

建立一個(gè)常駐后臺的服務(wù)，動(dòng)態(tài)注冊接收器，以搶占第一優(yōu)先級。同樣記得要把Service在Manifest注冊哦。

public class SmsService extends Service {

 private SmsReceiver mReceiver = null;

 public SmsService() {
 }

 @Override public IBinder onBind(Intent intent) {
  // TODO: Return the communication channel to the service.
  throw new UnsupportedOperationException("Not yet implemented");
 }

 @Override public void onCreate() {
  super.onCreate();
  Log.d(TAG, "onCreate");
  IntentFilter iFilter = null; // 意圖過濾對象
  mReceiver = new SmsReceiver(); // 廣播接收類初始化
  iFilter = new IntentFilter("android.provider.Telephony.SMS_RECEIVED");
  iFilter.setPriority(Integer.MAX_VALUE); // 設(shè)置優(yōu)先級
  GlobalContext.getBusInstance().register(mReceiver);//注冊Bus
  registerReceiver(mReceiver, iFilter); // 注冊廣播
 }

 @Override public void onDestroy() {
  super.onDestroy();
  if (mReceiver != null){
   GlobalContext.getBusInstance().unregister(mReceiver);//取消注冊Bus
   unregisterReceiver(mReceiver);
  } 
 }
}

接下來就是真正的發(fā)布者SmsReceiver了，大部分代碼與網(wǎng)上都是一樣的，注意看我是如何發(fā)布消息的。

public class SmsReceiver extends BroadcastReceiver {

 public SmsReceiver() {
 }

 @Override public void onReceive(Context context, Intent intent) {

  Bundle bundle = intent.getExtras();
  //獲取鏈路層的協(xié)議數(shù)據(jù)單元
  Object[] messages = (Object[]) bundle.get("pdus");
  SmsMessage[] sms = new SmsMessage[messages.length];
  // Create messages for each incoming PDU
  for (int n = 0; n < messages.length; n++) {
   sms[n] = SmsMessage.createFromPdu((byte[]) messages[n]);
  }
  for (SmsMessage msg : sms) {
   //TODO: 這里應(yīng)該加上你自己的過濾條件，比如手機(jī)號，短信內(nèi)容
   //盡可能的攔截短信，這個(gè)命令在MIUI，flyme上都沒有用
   abortBroadcast();
   GlobalContext.getBusInstance().post(msg);
  }
 }
}

從代碼中可以看出，在Service中，我們控制了SmsReceiver中BUS的生命周期，之后在SmsReceiver中，通過post把消息發(fā)布出去

GlobalContext.getBusInstance().post(msg);

3. 接收者（Subscriber）
接收者可以是Activity，也可以是Fragment，還可以是Service。

我們以Fragment為例進(jìn)行操作.

public class SMSControlFragment extends Fragment {

  Bus bus = GlobalContext.getBusInstance();

  @Override public void onAttach(Activity activity) {
    super.onAttach(activity);
    bus.register(this);
   }

  @Override public void onDetach() {
    super.onDetach();
    bus.unregister(this);
   }

  @Subscribe public void getMessage(SmsMessage s) {
    mTvNumber.setText(s.getOriginatingAddress());
    mTvMessage.setText(s.getMessageBody());
  }

}

訂閱者是Fragment，發(fā)布者是SmsReceiver，消息內(nèi)容是SmsMessage。
通過以上操作，一個(gè)使用OTTO的消息傳遞總線就完成了。

4.綜合demo
下面的Demo，僅為了讓大家知道“事件”被產(chǎn)生了之后，post出來，所有訂閱了該事件的類都會接到該事件，接受的先后順序，不由我們控制！

public class MyActivity extends ActionBarActivity {

 @Override
 protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  setContentView(R.layout.activity_my);
  findViewById(R.id.button_change).setOnClickListener(new View.OnClickListener() {
   @Override
   public void onClick(View view) {
    BusProvider.getBusInstance().post(new DataChangedEvent("this is changed String"));//發(fā)布事件
   }
  });
 }

 @Override
 protected void onResume() {
  super.onResume();
  BusProvider.getBusInstance().register(this);//注冊
  
 }

 @Override
 protected void onPause() {
  super.onPause();
  BusProvider.getBusInstance().unregister(this);//注銷
 }

 @Subscribe  //訂閱事件DataChangedEvent
 public void sayGoodOnEvent(DataChangedEvent event){
  Log.e("event", "good");
 }

 @Subscribe //訂閱事件
 public void sayBadOnEvent(DataChangedEvent event){
  Log.e("event", "bad");
 }

 @Produce //產(chǎn)生事件
 public DataChangedEvent produceDataChangedEvent(){
  return new DataChangedEvent("this is changed String");
 }

}

您可能感興趣的文章:

相關(guān)文章

Android入門之實(shí)現(xiàn)自定義可復(fù)用的BaseAdapter
這篇文章主要為大家詳細(xì)介紹了Android如何構(gòu)建一個(gè)可復(fù)用的自定義BaseAdapter，文中的示例代碼講解詳細(xì)，對我們學(xué)習(xí)Android有一定的幫助，需要的可以參考一下
2022-11-11
總結(jié)Android中多線程更新應(yīng)用的頁面信息的方式
這篇文章主要介紹了總結(jié)Android中多線程更新應(yīng)用的頁面信息的方式,文中共總結(jié)了runOnUiThread、Handler、AsyncTask異步以及View直接在UI線程中更新的方法,需要的朋友可以參考下
2016-02-02
Android中實(shí)現(xiàn)長按修改ListView對象的內(nèi)容
這篇文章主要給大家介紹了在Android中實(shí)現(xiàn)長按修改ListView對象內(nèi)容的相關(guān)資料，文中給出了完整的示例代碼，相信對大家具有一定的參考價(jià)值，需要的朋友們下面來一起看看吧。
2017-02-02
這篇文章主要介紹了基于Android的服務(wù)器端程序?qū)嵗【幱X得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧
2018-03-03