生活案例
image.png
把Boss直聘比作EventBus。
Boss直聘中维护一个总表，键是企业，值是该企业需要招聘的岗位列表，这个概念很重要，一定要搞清楚。
对应到EventBus：
- 总表：名为METHOD_CACHE的Map，
- 企业：Activity的Class，
- 岗位列表：List<SubscriberMethod>
- 岗位：SubscriberMethod，也就是我们定义的接收方法的信息
岗位 SubscriberMethod :
/**
* 职位
*/
public class SubscriberMethod {
//职位要做什么事情
private Method method;
//室内还是室外
private ThreadMode threadMode;
//工作岗位类型
private Class<?> eventType;
public SubscriberMethod(Method method, Class<?> eventType, ThreadMode threadMode) {
this.method = method;
this.threadMode = threadMode;
this.eventType = eventType;
}
public Method getMethod() {
return method;
}
public ThreadMode getThreadMode() {
return threadMode;
}
public Class<?> getEventType() {
return eventType;
}
}
@Subscribe(threadMode = ThreadMode.MAIN)
public void onMessageEvent(MyBusEvent event) {
Log.i(TAG,"onMessageEvent接收到数据 = " + event.message);
}
- method对应的是onMessageEvent
- eventType对应的是MyBusEvent
这两个对应关系也很重要，要搞清楚。
METHOD_CACHE的定义如下：
//总表：METHOD_CACHE
//Class<?>对应阿里巴巴，List对应阿里巴巴中的所有职位
private Map<Class<?>, List<SubscriberMethod>> METHOD_CACHE = new HashMap<>();
注册：将该企业到Boss直聘上注册填写岗位信息
EventBus.getDefault().register(this);
发送事件：求职者搜索岗位
EventBus.getDefault().post( new MyBusEvent("fujunyang"));
简单总结：
- 总表：名为METHOD_CACHE的Map，
- 企业：Activity的Class，
- 岗位列表：List<SubscriberMethod>
- 岗位：SubscriberMethod，
注册：一个注册register，就是将该企业的所有岗位，添加到总表中。
总表（METHOD_CACHE）的键是企业（Activity），值是该企业所有岗位（List<SubscriberMethod>）。
发送事件：循环总表，在某个循环中，找出该企业对应的所有岗位。再循环所有岗位，找到求职者搜索的岗位是否和该企业所有岗位匹配。如果匹配就通过反射调用方法（method是onMessageEvent，参数是具体的Activity和MyBusEvent）
获取EventBus对象
使用单例，直接复用了EventBus的源代码
public class EventBus {
public static String TAG = "EventBus";
static volatile EventBus defaultInstance;
public static EventBus getDefault() {
if (defaultInstance == null) {
synchronized (EventBus.class) {
if (defaultInstance == null) {
defaultInstance = new EventBus();
}
}
}
return defaultInstance;
}
注册
EventBus通过如下实现注册
@Override
protected void onStart() {
super.onStart();
EventBus.getDefault().register(this);
}
注册的具体实现如下：
public void register(Object subscriber) {
Class<?> subscriberClass = subscriber.getClass();
List<SubscriberMethod> subscriberMethods = METHOD_CACHE.get(subscriberClass);
//如果不为空，说明阿里巴巴注册过，不需要再次注册
if (subscriberMethods == null) {
//如何寻找能够接收事件的方法？？通过注解
subscriberMethods = getSubscriberMethods(subscriber);
METHOD_CACHE.put(subscriberClass, subscriberMethods);
}
}
通过企业（Activity的Class）作为键，去总表METHOD_CACHE中获取所有该企业的职位subscriberMethods。
如果subscriberMethods为null，说明该企业还没有注册过，我们才去注册。如果注册过了，就不再注册。
private List<SubscriberMethod> getSubscriberMethods(Object subscriber) {
List<SubscriberMethod> subscriberMethods = new ArrayList<>();
Class clazz = subscriber.getClass();
//getDeclaredMethod获取的是类自身声明的所有方法，包含public、protected、private方法
Method[] methods = clazz.getDeclaredMethods();
//需要将父类的注解也找出来，比如BaseActivity中可能也添加了注解
while (clazz != null) {
String clazzName = clazz.getName();
//遇到系统类，直接跳出循环，不再去寻找
if (clazzName.startsWith("java.") || clazzName.startsWith("javax.") ||
clazzName.startsWith("android.") || clazzName.startsWith("androidx.")) {
break;
}
for (Method method : methods) {
Subscribe subscribeAnnotation = method.getAnnotation(Subscribe.class);
if (subscribeAnnotation == null) {
continue;
}
//检测方法 是否符合规范
Class[] parameterTypes = method.getParameterTypes();
if (parameterTypes.length != 1) {
throw new RuntimeException("EventBus只能接收一个参数");
}
Class<?> eventType = parameterTypes[0];
ThreadMode threadMode = subscribeAnnotation.threadMode();
SubscriberMethod subscriberMethod = new SubscriberMethod(method, eventType, threadMode);
subscriberMethods.add(subscriberMethod);
}
clazz = clazz.getSuperclass();
}
return subscriberMethods;
}
发送事件
//发送事件
//事件对应岗位，假设现在event是android岗位
public void post(Object event) {
// 找哪个activity需要接收
// 遍历总表，分别查看阿里和腾讯是否招android岗位
Set<Class<?>> set = METHOD_CACHE.keySet();
Iterator iterator = set.iterator();
while (iterator.hasNext()) {
//拿到公司，假设当前拿到的是阿里
Class<?> subscriberClass = (Class<?>) iterator.next();
//subscriberMethods是阿里的所有岗位集合
List<SubscriberMethod> subscriberMethods = METHOD_CACHE.get(subscriberClass);
for (SubscriberMethod subscriberMethod : subscriberMethods) {
//判断这个方法是否应该接收事件
//判断阿里的岗位中是否有招android岗位的
if (subscriberMethod.getEventType().isAssignableFrom(event.getClass())) {
// invoke(subscriberMethod, subscriberClass, event);
Method method = subscriberMethod.getMethod();
try {
//通过反射调用方法
method.invoke(subscriberClass.newInstance(), event);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
在MainActivity中使用：
@Subscribe(threadMode = ThreadMode.MAIN)
public void onMessageEvent(MyBusEvent event) {
Log.i(TAG,"onMessageEvent接收到数据 = " + event.message);
// textView.setText(event.message);
// Toast.makeText(MainActivity.this, event.message, Toast.LENGTH_SHORT).show();
}
@Override
protected void onStart() {
super.onStart();
EventBus.getDefault().register(this);
}
最简单的说：就是通过注解，反射调用对应的方法
