EventBus3.0以后使用了注解模式,接收消息的方法名可以让你任性的写写写,不再是以onEvent开头了,增加了可读性,用着更爽了。那么我们在搬砖的时候怎么去愉快的使用呢?
砖家认为可以在Activity与Activity、Activity与Fragment、线程之间愉快的传递数据,还可以替代intent传值,还不用去写序列化,卧槽,爽炸天有木有。
官网地址:
EventBus GitHub地址
在Android Studio中添加如下依赖即可使用:
compile 'org.greenrobot:eventbus:3.0.0'
one step :下面介绍下使用方法
1、首先需要写好注册与注销方法:
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
//注册EventBus
EventBus.getDefault().register(this);
}
@Override
protected void onDestroy() {
super.onDestroy();
//注销EventBus
EventBus.getDefault().unregister(this);
}
2、码好接收消息的方法:
自定义消息实体EventMessage,data使用泛型,可以接收任意类型的数据
public class EventMessage<T> {
private int type;
private T data;
public EventMessage(int type, T data) {
this.type = type;
this.data = data;
}
public int getType() {
return type;
}
public void setType(int type) {
this.type = type;
}
public T getData() {
return data;
}
public void setData(T data) {
this.data = data;
}
}
/**
* 接收消息
* @param msg
*/
@Subscribe(sticky = true,threadMode = ThreadMode.MAIN)
public void eventComing(EventMessage<String> msg){
if(msg.getType() == 2){
tv_content.setText(msg.getData());
}
}
sticky 设置是否接收粘性消息,threadMode 设置运行的线程,还有一个priority设置接收消息的优先级
根据type的值去区分不同的发送和接收。
3、发送消息:
发送消息可以分两种:
一、粘性消息
@Subscribe(sticky = true,threadMode = ThreadMode.MAIN)
sticky 为true的时候就是粘性消息,什么是粘性消息呢?就是EventBus可以先出消息体,然后在EventBus进行注册的时候从粘性消息队列中取出消息,进行接收,可用于替代intent传值。
发送方法使用:
EventBus.getDefault().postSticky(new EventMessage<String>(1,"来自第一世界的消息"));
注意:如果需要接收粘性消息后操作界面,那么threadMode = ThreadMode.MAIN设为主线程,而且EventBus注册必须在界面初始化之后进行,因为粘性消息在EventBus注册的时候被接收。
二、普通消息
普通消息,只能先注册后接收。发出的消息,只能注册过的EventBus进行接收。用于替代Handler+Message
使用方法:
EventBus.getDefault().post(new EventMessage<String>(2,"来自第二世界的消息"));
two step :下面介绍EventBus的原理。
源码大家可以根据原理自己观摩学习,对于砖家,你可以直接搬砖使用,但学习源码,能让你更懂得如何搬砖。各人自由发挥吧。
1、想成为订阅者,需要进行注册
EventBus.getDefault().register(this);
那么先从getDefault()方法走起,定睛一看,so easy,老司机都懂,不解释。
public static EventBus getDefault() {
if (defaultInstance == null) {
synchronized (EventBus.class) {
if (defaultInstance == null) {
defaultInstance = new EventBus();
}
}
}
return defaultInstance;
}
获取实例直接调用了EventBus构造方法
public EventBus() {
this(DEFAULT_BUILDER);
}
private final Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType;
private final Map<Object, List<Class<?>>> typesBySubscriber;
private final Map<Class<?>, Object> stickyEvents;
private final HandlerPoster mainThreadPoster;
private final BackgroundPoster backgroundPoster;
private final AsyncPoster asyncPoster;
EventBus(EventBusBuilder builder) {
//key为订阅事件 value为订阅这个事件的所有订阅者的CopyOnWriteArrayList
subscriptionsByEventType = new HashMap<>();
//以订阅者的类为key,以event事件类为value,在进行register或unregister的时候,会操作这HashMap。
typesBySubscriber = new HashMap<>();
//粘性事件的集合
stickyEvents = new ConcurrentHashMap<>();
//事件处理
mainThreadPoster = new HandlerPoster(this, Looper.getMainLooper(), 10);
backgroundPoster = new BackgroundPoster(this);
asyncPoster = new AsyncPoster(this);
......
}
register()方法:
public void register(Object subscriber) {
Class<?> subscriberClass = subscriber.getClass();
List<SubscriberMethod> subscriberMethods = subscriberMethodFinder.findSubscriberMethods(subscriberClass);
synchronized (this) {
for (SubscriberMethod subscriberMethod : subscriberMethods) {
subscribe(subscriber, subscriberMethod);
}
}
}
注册的时候通过subscriberMethodFinder的findSubscriberMethods方法去查找和缓存订阅者订阅了哪些事件.返回一个SubscriberMethod(SubscriberMethod里包含了这个方法的Method对象,以及将来响应订阅是在哪个线程的ThreadMode,以及订阅的事件类型eventType,以及订阅的优先级priority,以及是否接收粘性sticky事件的boolean值)对象的List。
接着回到subscribe(subscriber, subscriberMethod)中去,通过这个方法,我们就完成了注册。具体代码自行去观摩吧。
2、事件的发送Post
/** Posts the given event to the event bus. */
public void post(Object event) {
//获取当前线程信息
//currentPostingThreadState是一个ThreadLocal
//ThreadLocal 是一个线程内部的数据存储类,通过它可以在指定的线程中存储数据,
PostingThreadState postingState = currentPostingThreadState.get();
List<Object> eventQueue = postingState.eventQueue;
//把事件加入线程队列中
eventQueue.add(event);
if (!postingState.isPosting) {
postingState.isMainThread = Looper.getMainLooper() == Looper.myLooper();
postingState.isPosting = true;
if (postingState.canceled) {
throw new EventBusException("Internal error. Abort state was not reset");
}
try {
while (!eventQueue.isEmpty()) {
//不断从队列中获取发送单个事件
postSingleEvent(eventQueue.remove(0), postingState);
}
} finally {
postingState.isPosting = false;
postingState.isMainThread = false;
}
}
}
大致原理是通过ThreadLocal存储指定线程的数据,数据在当前线程中的事件队列中不停往外分发。
砖家说句话
EventBus先介绍到这,还有很多细节没有深入,大家各自去看吧。我们搬砖的时候首先得学会使用,解决工作中的问题,然后有空再去观摩下源码,学习学习。要想看懂这个源码,要会数据结构、设计模式、java注解与反射等。所以啊,基础要牢靠,滴滴滴,走起吧!!!
demo下载地址:
http://pan.baidu.com/s/1i5DUcML
要想看源码,也可参考如下文章,写的不错:
http://www.jianshu.com/p/f057c460c77e