标签：declared ref cache 模块 ota instance not 直接 param
Event 事件。它可以是任意类型。
Subscriber 事件订阅者。在EventBus3.0之前我们必须定义以onEvent开头的那几个方法，分别是onEvent、onEventMainThread、onEventBackgroundThread和onEventAsync，而在3.0之后事件处理的方法名可以随意取，不过需要加上注解@subscribe()，并且指定线程模型，默认是POSTING。
Publisher 事件的发布者。我们可以在任意线程里发布事件，一般情况下，使用EventBus.getDefault()就可以得到一个EventBus对象，然后再调用post(Object)方法即可。
/创建Eventbus public static EventBus getDefault() { if(instance==null) { synchronized (EventBus.class){ if (instance==null) { instance=new EventBus(); } } } return instance; }
注册
//注册 public void register(Object obj) { List<SubscribleMethod> list =cachemap.get(obj); if(list==null) { list =findSubscribleMethod(obj); cachemap.put(obj,list); } }
通信之间的寻找通过注解的方法寻找，这里为默认方式
@Subcrible(threadMode= ThreadMode.MAIN)
、
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Subcrible {
ThreadMode threadMode() default ThreadMode.MAIN;
}
Subcrible的各种状态
package com.example.eventbus; import java.lang.reflect.Method; public class SubscribleMethod { //回调方法 private Method mMethod; //线程模式 private ThreadMode mthreadMode; //方法中的参数 private Class<?> type; public SubscribleMethod(Method mMethod, ThreadMode mthreadMode, Class<?> type) { this.mMethod = mMethod; this.mthreadMode = mthreadMode; this.type = type; } public void setmMethod(Method mMethod) { this.mMethod = mMethod; } public void setMthreadMode(ThreadMode mthreadMode) { this.mthreadMode = mthreadMode; } public Method getmMethod() { return mMethod; } public ThreadMode getMthreadMode() { return mthreadMode; } public Class<?> getType() { return type; } public void setType(Class<?> type) { this.type = type; } }
通信寻找注解的方法
private List<SubscribleMethod> findSubscribleMethod(Object obj) { List<SubscribleMethod> list=new ArrayList<>(); Class< ?> clazz =obj.getClass(); Method[] methods =clazz.getDeclaredMethods(); while (clazz!=null) { //找父类的时候需要先判断一下是否系统级别的父类 String name=clazz.getName(); if(name.startsWith("java.")||name.startsWith("javax.") ||name.startsWith("android")) { break; } for (Method method:methods) { //找到带有Subcrible 注解的方法 Subcrible subcrible=method.getAnnotation(Subcrible.class); if (subcrible==null) { continue; } //判断subscrible 注解的方法中的参数类 Class<?>[] type= method.getParameterTypes(); if(type.length!=1) { Log.e("TAG", "eventBus only accept one para " ); } ThreadMode threadMode=subcrible.threadMode(); SubscribleMethod subscribleMethod=new SubscribleMethod(method,threadMode,type[0]); list.add(subscribleMethod); } clazz= clazz.getSuperclass(); } return list; } public void post(final Object type) { //直接循环 Map里的方法 ，找到相对得然后回调 Set<Object> set =cachemap.keySet(); Iterator<Object> iterator=set.iterator(); while (iterator.hasNext()) { final Object obj =iterator.next(); List<SubscribleMethod>list=cachemap.get(obj); for (final SubscribleMethod subscribleMethod:list){ //a(if 条件得对象)对象所对应得类信息是不是b if条件后面得对象对象所对应得接口或者父类 if (subscribleMethod.getType().isAssignableFrom(type.getClass())) { switch (subscribleMethod.getMthreadMode()) { case MAIN: //主线程 -主线程 if (Looper.myLooper()==Looper.getMainLooper()) { invoke(subscribleMethod,obj,type); } else { //子线程 -主线程 mHandler.post(new Runnable() { @Override public void run() { invoke(subscribleMethod,obj,type); } }); } break; } } } } } private void invoke(SubscribleMethod subscribleMethod, Object obj, Object type) { Method method=subscribleMethod.getmMethod(); try { method.invoke(obj,type); }catch (IllegalAccessException e) { e.printStackTrace(); } catch (InvocationTargetException e) { e.printStackTrace(); } } }
运行起来的效果如下
这里是源码包分享
链接：https://pan.baidu.com/s/1CnTNCndQHizktb4e338BnA
提取码：vcvx
复制这段内容后打开百度网盘手机App，操作更方便哦
标签：declared ref cache 模块 ota instance not 直接 param
原文地址：https://www.cnblogs.com/xujunjia/p/11497226.html
