EventBus3.0 事件总线

 dependencies {
      compile 'org.greenrobot:eventbus:3.0.0'
 }

• 定义事件：可以是任何的Java对象

   public class MessageEvent {
     public final String message;
     public MessageEvent(String message) {
         this.message = message;
     }
  }
  

• 构造订阅者：主要通过@Subscribe来注解

   public class ViewA extends View{    
  
       @Subscribe(threadMode = ThreadMode.MAIN)
       public void onMsgSend(MessageEvent event){
           doSomethingWith(event);
       }
   }
  

  订阅者的回调函数onMsgSend()可以是任何合规的函数名，并且由@Subscribe来注解。回调函数通过其唯一的参数MessageEvent对象与发布者传递的MessageEvent对象进行关联，起到被回调的作用；

• 构造发布者：

   public class ViewB extends View{    
  
       public void sendMsg(MessageEvent event){
         EventBus.getDefault().post(new MessageEvent("消息"));
       }
  
     }
  

• 发布者回调函数的@Subscribe注解的详细介绍：

  • threadMode 线程通信的方式

    EventBus可以很简单的实现线程间的切换，包括后台线程、UI线程、异步线程:

  ThreadMode.POSTING

    //默认调用方式，在发布者调用post方法的线程执行，避免了线程切换性能开销最少    
    @Subscribe(threadMode = ThreadMode.POSTING)      
    public void onMessage(MessageEvent event) {
        //do something
    }
  

  ThreadMode.MAIN

    //在UI主线程执行  
    @Subscribe(threadMode = ThreadMode.MAIN)      
    public void onMessage(MessageEvent event) {
        //do something
    }
  

  ThreadMode.BACKGROUND

      /**
          如果发布者调用post方法的线程不是主线程，则直接在该线程执行
          如果是主线程，则切换到后台单例线程，多个方法公用同个后
          台线程，按顺序执行，避免耗时操作
      **/
      @Subscribe(threadMode = ThreadMode.BACKGROUND)      
      public void onMessage(MessageEvent event) {
          //do something
      }
  

  ThreadMode.ASYNC

     /** 
        开辟新独立线程，用来执行耗时操作，例如网络访问
        EventBus内部使用了线程池，但是要尽量避免大量长时间运行
        的异步线程，限制并发线程数量
        可以通过EventBusBuilder修改，默认使用 Executors.newCachedThreadPool()
    **/
    @Subscribe(threadMode = ThreadMode.ASYNC)      
    public void onMessage(MessageEvent event) {
        //do something
    }
  

  • sticky类型的事件

  sticky事件表示事件订阅者在事件发布之后才注册的也能接收到该事件的特殊类型，类似Android SDK中的Sticky Broadcast即粘性广播：

  • 发布粘性事件

  EventBus.getDefault().postSticky(new MessageEvent("Hello everyone!")); 
  

  • 订阅粘性事件

  @Subscribe(sticky = true, threadMode = ThreadMode.MAIN)
  public void onEvent(MessageEvent event) {
     // UI updates must run on MainThread
     todo something
  }
  

  • 订阅事件处理优先级priority

  可以为相同事件的不同订阅者赋予不同的优先级priority，这样优先级高的订阅者将优先接收到事件，优先级低的排在后面。而且优先级高的订阅者在接收到事件后可以取消事件，同时优先级比较低的订阅者将不会再收到此取消的事件；

   //priority数值越大，优先级越高
   @Subscribe(priority = 100)
    public void onEvent(MessageEvent event) {
    // 取消分发的事件
        EventBus.getDefault().cancelEventDelivery(event) ;
   }