EventBus学习笔记

EventBus学习笔记

使用方法

(1)首先需要定义一个消息类，该类可以不继承任何基类也不需要实现任何接口。
例如：

public class MessageEvent{
   private String mMsg;
   public MessageEvent (String msg) {
       mMsg = msg;
   }
   public String getMsg(){
       return mMsg;
   }
}

(2)在需要订阅事件的地方注册事件。比如activity的oncreate中，或者Application的onCreate方法中。

EventBus.getDefault().register(this);

(3)产生事件，即发送消息。

EventBus.getDefault().post(messageEvent);

(4)处理消息.

@Subscribe(threadMode = ThreadMode.Main)
public void XXX(MessageEvent messageEvent) {
    ...
}

在3.0之前，EventBus还没有使用注解方式。消息处理的方法也只能限定于onEvent、onEventMainThread、onEventBackgroundThread和onEventAsync，分别代表四种线程模型。

onEvent: 如果使用onEvent作为订阅函数，那么该事件在哪个线程发布出来的，onEvent就会在这个线程中运行，也就是说发布事件和接收事件线程在同一个线程。使用这个方法时，在onEvent方法中不能执行耗时操作，如果执行耗时操作容易导致事件分发延迟。
onEventMainThread: 如果使用onEventMainThread作为订阅函数，那么不论事件是在哪个线程中发布出来的，onEventMainThread都会在UI线程中执行，接收事件就会在UI线程中运行，这个在Android中是非常有用的，因为在Android中只能在UI线程中跟新UI，所以在onEvnetMainThread方法中是不能执行耗时操作的。
onEventBackground: 如果使用onEventBackgrond作为订阅函数，那么如果事件是在UI线程中发布出来的，那么onEventBackground就会在子线程中运行，如果事件本来就是子线程中发布出来的，那么onEventBackground函数直接在该子线程中执行。
onEventAsync： 使用这个函数作为订阅函数，那么无论事件在哪个线程发布，都会创建新的子线程在执行onEventAsync.

而在3.0之后，消息处理的方法可以随便取名，但是需要添加一个注解@Subscribe，并且要指定线程模型（默认为PostThread），四种线程模型，下面会讲到。

(5)取消消息订阅.

EventBus.getDefault().unregister(this);

线程模式

public enum ThreadMode {
    POSTING,///事件的处理在和事件的发送在相同的进程(如果在子线程中发布消息，则收到的消息也在子线程中)
    MAIN,///事件的处理会在UI线程中执行
    BACKGROUND,///事件的处理会在一个后台线程中执行，尽管是在后台线程中运行，事件处理时间不应太长。
    如果事件分发在主线程，件会被加到一个队列中，由一个线程依次处理这些事件，如果某个事件处理时间太长，会阻塞后面的事件的派发或处理。
    如果事件分发在后台线程，事件会立即执行处理。
    ASYNC ///事件处理会在单独的线程中执行，主要用于在后台线程中执行耗时操作，每个事件会开启一个线程（有线程池），但最好限制线程的数目。
}

黏性事件

类似broadcast中的Sticky Broadcast，消息先发送，等到注册之后还可以收到订阅消息。
它只能收到最新的一次消息。

public class StickyEventBusActivity extends AppCompatActivity {

  private int index = 0;
  @Override
  protected void onCreate(@Nullable Bundle savedInstanceState) {
      super.onCreate(savedInstanceState);
      setContentView(R.layout.sticky_eventbus);
      findViewById(R.id.post).setOnClickListener(new View.OnClickListener() {
          @Override
          public void onClick(View v) {
              EventBus.getDefault().postSticky(new MessageEvent("test :: " + index++));
          }
      });
      findViewById(R.id.regist).setOnClickListener(new View.OnClickListener() {
          @Override
          public void onClick(View v) {
              EventBus.getDefault().register(StickyEventBusActivity.this);
          }
      });

      findViewById(R.id.unregist).setOnClickListener(new View.OnClickListener() {
          @Override
          public void onClick(View v) {
              EventBus.getDefault().unregister(StickyEventBusActivity.this);
          }
      });
  }

  @Subscribe(threadMode = ThreadMode.POSTING, sticky = true)
  public void onMessageEventPostThread(MessageEvent messageEvent) {
      Log.e(EventBusActivity1.TAG, "onMessageEventPostThread POSTING : "+messageEvent.getMsg());
  }

  @Subscribe(threadMode = ThreadMode.MAIN, sticky = true)
  public void onMessageEventMainThread(MessageEvent messageEvent) {
      Log.e(EventBusActivity1.TAG, "onMessageEventMainThread :  "+messageEvent.getMsg());
  }

  @Subscribe(threadMode = ThreadMode.BACKGROUND, sticky = true)
  public void onMessageEventBackgroundThread(MessageEvent messageEvent) {
      Log.e(EventBusActivity1.TAG, "onMessageEventBackgroundThread : "+messageEvent.getMsg());
  }

  @Subscribe(threadMode = ThreadMode.ASYNC, sticky = true)
  public void onMessageEventAsync(MessageEvent messageEvent) {
      Log.e(EventBusActivity1.TAG, "onMessageEventAsync : "+ messageEvent.getMsg());
  }


}

感谢

很多关于eventbus的介绍文章的作者们。