举例讲解Android应用开发中OTTO框架的基本使用

OTTO是一个EventBus类型的事件传输总线,它可以提供“存储转发”的功能,让你APP中各个组件的交流更加便利,让你的程序分层更加清晰。

使用场景
OTTO基于Observer设计模式。它有发布者,订阅者这两个主要对象。OTTO的最佳实践就是通过反射牺牲了微小的性能,同时极大的提高了程序的耦合度,更加利于MVP分工开发与维护。业务层开发者在处理资源(比如Db, REST等)后并发布消息,展示层开发者(比如Activity/Fragment)就可以处理消息,而不用关心数据是怎么来的(在读报纸的时候需要知道编辑们如何排版印刷吗?),比如:

Fragment,Service或者Activity组件之间的通信。比如
导航菜单的NavigationDrawer与Activity的通信
Activity与Activity的通信(在设置界面上勾选了夜间模式,回到主界面就发现已经完成变色了;或者你在详细界面上点了一个赞,回到主界面发现已经同步增加了一个"赞")
MVP(Model View Presidenter)架构中,Model与Presidenter的回掉通信。包括但不限于REST, DB, SP, BroadcastReceiver, ContentObserver。

一、Android Studio中配置Otto (Eclipse中直接下载jar包导入)

跟之前介绍的其他的框架一样,它只需要简单地在build.gradle中配置下面的部分即可

dependencies {

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

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

  /

/otto 所需要依赖的包

}

二、开始使用
1. 订阅者
当你想进行订阅时,首先要打开注册(比如生命周期的启动/恢复部分)

Bus.register(this);

当你不再关注某个事情后,需要取消注册(比如生命周期的停止/暂停部分)

Bus.unregister(this);

当你对某个事情感兴趣的话,就加入@Subscribe进行关注。

 @Subscribe public void getMessage(@NonNull SomeEvent s) {
     //TODO: 在回掉中使用这个事件
  }

2. 发布者
当你想发布消息时,使用post即可,注意发布者同样需要事先注册。

Bus.post(SomeEvent);

实例说明
本文以短信服务接受为例,介绍OTTO的使用

1. 构造单例模式
BUS是一个单例,所以我们要创建一个单例模式,而最简单的单例当然是在Application中建立,记得在Manifest注册哦。

/**
 * Created by leon on 15/5/27.
 * 主线程事件总线,方便在异步任务中回掉
 */
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()) {
   //直接通过反射调用
   super.post(event);
  } else {
   //通过handler把异步任务发送到UI线程,然后再反射调用
   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. 发送者(Publisher)
现在我们要注册一个短信接收机器,为了与国内毒瘤软件抢占第一的短信监听,我们使用Service动态注册接收器,以抢占第一优先级。

建立一个常驻后台的服务,动态注册接收器,以抢占第一优先级。同样记得要把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); // 设置优先级
  GlobalContext.getBusInstance().register(mReceiver);//注册Bus
  registerReceiver(mReceiver, iFilter); // 注册广播
 }

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

接下来就是真正的发布者SmsReceiver了,大部分代码与网上都是一样的,注意看我是如何发布消息的。

public class SmsReceiver extends BroadcastReceiver {

 public SmsReceiver() {
 }

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

  Bundle bundle = intent.getExtras();
  //获取链路层的协议数据单元
  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: 这里应该加上你自己的过滤条件,比如手机号,短信内容
   //尽可能的拦截短信,这个命令在MIUI,flyme上都没有用
   abortBroadcast();
   GlobalContext.getBusInstance().post(msg);
  }
 }
}

从代码中可以看出,在Service中,我们控制了SmsReceiver中BUS的生命周期,之后在SmsReceiver中,通过post把消息发布出去

GlobalContext.getBusInstance().post(msg);

3. 接收者(Subscriber)
接收者可以是Activity,也可以是Fragment,还可以是Service。

我们以Fragment为例进行操作.

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,发布者是SmsReceiver,消息内容是SmsMessage。
通过以上操作,一个使用OTTO的消息传递总线就完成了。

4.综合demo
下面的Demo, 仅为了让大家知道“事件”被产生了之后,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"));//发布事件
   }
  });
 }

 @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 //产生事件
 public DataChangedEvent produceDataChangedEvent(){
  return new DataChangedEvent("this is changed String");
 }

}
(0)

相关推荐

  • Android中XUtils3框架使用方法详解(一)

    xUtils简介 xUtils 包含了很多实用的android工具. xUtils 支持大文件上传,更全面的http请求协议支持(10种谓词),拥有更加灵活的ORM,更多的事件注解支持且不受混淆影响... xUitls 最低兼容android 2.2 (api level 8) 今天给大家带来XUtils3的基本介绍,本文章的案例都是基于XUtils3的API语法进行的演示.相信大家对这个框架也都了解过, 下面简单介绍下XUtils3的一些基本知识. XUtils3一共有4大功能:注解模块,网络

  • 浅析KJFrameForAndroid框架如何高效加载Bitmap

    我们在写Android程序的时候,肯定会用到很多图片.那么对于图片的压缩处理自然是必不可少.为什么要压缩?我想这个问题不必在强调了,每个人在最初学习Android的时候肯定都会知道这么一个原因:我们编写的应用程序都是有一个最大内存限制,其中JAVA程序和C程序(NDK调用时)共享这一块内存大小,程序占用了过高的内存就容易出现OOM(OutOfMemory)异常.至于这个最大内存是多少,我们可以通过调用Runtime.getRuntime().maxMemory()方法验证一下. 正因为受到内存大

  • Android使用Fragment打造万能页面切换框架

    首先我们来回忆一下传统用Activity进行的页面切换,activity之间切换,首先需要新建intent对象,给该对象设置一些必须的参数,然后调用startActivity方法进行页面跳转.如果需要activity返回结果,则调用startActivityForResult方法,在onActivityResult方法中获得返回结果.此外,每一个要展示的activity需要在AndroidManifest.xml文件中注册.而且,如果在某些特定的情况下(比如65536方法数爆炸)要动态加载dex

  • Android开发框架之自定义ZXing二维码扫描界面并解决取景框拉伸问题

    先给大家展示下效果图: 扫描内容是下面这张,二维码是用zxing库生成的 由于改了好几个类,还是去年的事都忘得差不多了,所以只能上这个类的代码了,主要就是改了这个CaptureActivity.java package com.zxing.activity; import java.io.IOException; import java.util.Vector; import android.app.Activity; import android.content.Intent; import

  • 在Android中动态添加Panel框架的实现代码

    这里说是框架,说的大了点,其实没有那么复杂,只是一个容易扩展的基类而已.不过至少算是框架类的代码. 复制代码 代码如下: package arui; import android.app.Activity;  import android.os.Handler;  import android.os.Looper;  import android.os.Message;  import android.view.Gravity;  import android.view.LayoutInflat

  • 简略分析Android的Retrofit应用开发框架源码

    面对一个项目,对于Android应用开发框架的选择,我想过三种方案: 1.使用Loader + HttpClient + GreenDao + Gson + Fragment,优点是可定制性强,由于使用Google家自己的Loader和LoaderManager,代码健壮性强. 缺点是整套代码学习成本较高,使用过程中样板代码较多,(比如每一个Request都需要产生一个新类) 2.Volley,作为Google在IO大会上得瑟过的一个网络库,其实不算什么新东西(2013 IO发布),使用较为简单

  • Android Retrofit 2.0框架上传图片解决方案

    本文为大家分享了 Android Retrofit 2.0框架上传图片解决方案,具体内容如下 1.单张图片的上传 /** * 上传一张图片 * @param description * @param imgs * @return */ @Multipart @POST("/upload") Call<String> uploadImage(@Part("fileName") String description, @Part("file\&qu

  • android上的一个网络接口和图片缓存框架enif简析

    1.底层网络接口采用apache的httpclient连接池框架: 2.图片缓存采用基于LRU的算法: 3.网络接口采用监听者模式: 4.包含图片的OOM处理(及时回收处理技术的应用): 图片核心处理类:CacheView.java 复制代码 代码如下: package xiaogang.enif.image; import java.io.FilterInputStream; import java.io.IOException; import java.io.InputStream; imp

  • 六款值得推荐的android(安卓)开源框架简介

    1.volley 项目地址 https://github.com/smanikandan14/Volley-demo (1)  JSON,图像等的异步下载: (2)  网络请求的排序(scheduling) (3)  网络请求的优先级处理 (4)  缓存 (5)  多级别取消请求 (6)  和Activity和生命周期的联动(Activity结束时同时取消所有网络请求) 2.android-async-http 项目地址:https://github.com/loopj/android-asyn

  • Android详解之NoHttp最基本使用(无封装)

    NoHttp是专门做Android网络请求与下载的框架,NoHttp基本使用方法如下 本文demo源码下载地址: http://xiazai.jb51.net/201609/yuanma/AndroidNoHttp(jb51.net).rar 本文的例子来自上面的demo中的OriginalActivity中. 代码 对于新手, 看别人封装好的代码允许要稍微吃力一点,尤其是一个框架,所以我们先看NoHttp最原始的使用方法: public class OriginalActivity exten

随机推荐