一、消息中心

该消息中心是事件通信框架的核心代码 , 负责订阅方法的注册 , 消息事件转发 , 订阅方法取消注册操作 ;

package com.eventbus_demo.myeventbus;import android.os.Handler;
import android.os.Looper;import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Modifier;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class MyEventBus {/*** 方法缓存*      Key - 订阅类类型*      Value - 订阅方法 MySubscriberMethod 的集合* 取名与 EventBus 一致*/private static final Map<Class<?>, List<MySubscriberMethod>> METHOD_CACHE = new HashMap<>();/*** 解除注册时使用*      Key - 订阅者对象*      Value - 订阅者对象中所有的订阅方法的事件参数类型集合** 根据该订阅者对象 , 查找所有订阅方法的事件参数类型 ,  然后再到  METHOD_CACHE 中 ,*      根据事件参数类型 , 查找对应的 MySubscriberMethod 集合*      MySubscriberMethod 中封装 订阅者对象 + 订阅方法**/private final Map<Object, List<Class<?>>> typesBySubscriber;/*** Key - 订阅者方法事件参数类型* Value - 封装 订阅者对象 与 订阅方法 的 MySubscription 集合* 在构造函数中初始化* CopyOnWriteArrayList 在写入数据时会拷贝一个副本 ,*      写完之后 , 将引用指向新的副本 ,*      该集合的线程安全级别很高*/private final Map<Class<?>, CopyOnWriteArrayList<MySubscription>> subscriptionsByEventType;/*** 线程池*/private final ExecutorService executorService;/*** 全局单例*/private static MyEventBus instance;private MyEventBus() {subscriptionsByEventType = new HashMap<>();typesBySubscriber = new HashMap<>();executorService = Executors.newCachedThreadPool();}public static MyEventBus getInstance() {if (instance == null) {instance = new MyEventBus();}return instance;}/*** 注册订阅者* @param subscriber*/public void register(Object subscriber) {// 获取订阅者所属类Class<?> clazz = subscriber.getClass();// 查找订阅方法List<MySubscriberMethod> subscriberMethods = findSubscriberMethods(clazz);// 遍历所有订阅方法 , 进行订阅//      首先确保查找到的订阅方法不为空 , 并且个数大于等于 1 个if (subscriberMethods != null && !subscriberMethods.isEmpty()) {for (MySubscriberMethod method : subscriberMethods) {// 正式进行订阅subscribe(subscriber, method);}}}/*** 方法订阅*      将 订阅方法参数类型 和 订阅类 + 订阅方法 封装类 , 保存到*      Map<Class<?>, CopyOnWriteArrayList<MySubscription>> subscriptionsByEventType 集合中*          Key - 订阅者方法事件参数类型*          Value - 封装 订阅者对象 与 订阅方法 的 MySubscription 集合** 取消注册数据准备*      取消注册数据存放在 Map<Object, List<Class<?>>> typesBySubscriber 集合中*          Key - 订阅者对象*          Value - 订阅者方法参数集合** @param subscriber    订阅者对象* @param subscriberMethod        订阅方法*/private void subscribe(Object subscriber, MySubscriberMethod subscriberMethod) {// 获取订阅方法接收的参数类型Class<?> eventType = subscriberMethod.getEventType();// 获取 eventType 参数类型对应的 订阅者封装类 ( 封装 订阅者对象 + 订阅方法 ) 集合CopyOnWriteArrayList<MySubscription> subscriptions =subscriptionsByEventType.get(eventType);// 如果获取的集合为空 , 说明 eventType 参数对应的订阅方法一个也没有注册过//      这里先创建一个集合 , 放到 subscriptionsByEventType 键值对中if (subscriptions == null) {// 创建集合subscriptions = new CopyOnWriteArrayList<>();// 将集合设置到 subscriptionsByEventType 键值对集合中subscriptionsByEventType.put(eventType, subscriptions);}// 封装 订阅者对象 + 订阅方法 对象MySubscription subscription = new MySubscription(subscriber, subscriberMethod);// 将创建的 订阅者对象 + 订阅方法 对象 添加到  CopyOnWriteArrayList 集合中subscriptions.add(subscription);// 为取消注册准备数据//      设置 Map<Object, List<Class<?>>> typesBySubscriberList<Class<?>> eventTypes = typesBySubscriber.get(subscriber);if (eventTypes == null) {// 创建新的集合, 用于存放订阅方法的参数类型eventTypes = new ArrayList<>();// 将新的集合设置到 Map<Object, List<Class<?>>> typesBySubscriber 集合中typesBySubscriber.put(subscriber, eventTypes);}// 将新的 订阅方法类型 放入到集合中eventTypes.add(eventType);}/*** 根据订阅方法的事件参数查找订阅方法* @param subscriberClass   订阅者对象的类型* @return*/private List<MySubscriberMethod> findSubscriberMethods(Class<?> subscriberClass) {// 获取 Class<?> clazz 参数类型对应的 订阅者封装类List<MySubscriberMethod> subscriberMethods = METHOD_CACHE.get(subscriberClass);// 此处后期重构, 减少缩进if (subscriberMethods == null) {// 说明是首次获取 , 初始化 METHOD_CACHE 缓存// 反射获取 Class<?> subscriberClass 中的所有订阅方法subscriberMethods = findByReflection(subscriberClass);if (! subscriberMethods.isEmpty()) {METHOD_CACHE.put(subscriberClass, subscriberMethods);}} else {// 如果当前不是第一次获取, 则直接返回从 METHOD_CACHE 缓存中获取的 订阅者封装类 集合return subscriberMethods;}// 该分支走不到return subscriberMethods;}/*** 通过反射获取 Class<?> subscriberClass 订阅方法* @param subscriberClass 订阅类* @return*/private List<MySubscriberMethod> findByReflection(Class<?> subscriberClass) {// 要返回的 MySubscriberMethod 集合List<MySubscriberMethod> subscriberMethods = new ArrayList<>();// 通过反射获取所有带 @MySubscribe 注解的方法Method[] methods = subscriberClass.getMethods();// 遍历所有的方法 , 查找注解for (Method method : methods) {// 获取方法修饰符int modifiers = method.getModifiers();// 获取方法参数Class<?>[] params = method.getParameterTypes();// 确保修饰符必须是 public , 参数长度必须是 1if (modifiers == Modifier.PUBLIC && params.length == 1) {// 获取 MySubscribe 注解MySubscribe annotation = method.getAnnotation(MySubscribe.class);// 获取注解不为空if (annotation != null) {// 获取线程模式MyThreadMode threadMode = annotation.threadMode();// 此时已经完全确定该方法是一个订阅方法 , 直接进行封装MySubscriberMethod subscriberMethod = new MySubscriberMethod(method,         // 方法对象threadMode,     // 线程模式params[0]       // 事件参数);// 加入到返回集合中subscriberMethods.add(subscriberMethod);}}}return subscriberMethods;}/*** 接收到了 发布者 Publisher 发送给本消息中心 的 Event 消息事件对象*      将该事件对象转发给相应接收该类型消息的 订阅者 ( 订阅对象 + 订阅方法 )*      通过事件类型到*      Map<Class<?>, CopyOnWriteArrayList<MySubscription>> subscriptionsByEventType*      集合中查找相应的 订阅对象 + 订阅方法* @param event*/public void post(Object event) {// 获取事件类型Class<?> eventType = event.getClass();// 获取事件类型对应的 订阅者 集合CopyOnWriteArrayList<MySubscription> subscriptions =subscriptionsByEventType.get(eventType);// 确保订阅者大于等于 1 个if (subscriptions != null && subscriptions.size() > 0) {// 遍历订阅者并调用订阅方法for (MySubscription subscription : subscriptions) {postSingleSubscription(subscription, event);}}}/*** 调用订阅方法* @param subscription* @param event*/private void postSingleSubscription(MySubscription subscription, Object event) {// 判断当前线程是否是主线程//      获取 mainLooper 与 myLooper 进行比较 , 如果一致 , 说明该线程是主线程boolean isMainThread = false;// 下面的情况下 , 线程是主线程if (Looper.getMainLooper() == Looper.myLooper()) {isMainThread = true;}// 判断订阅方法的线程模式MyThreadMode threadMode = subscription.getSubscriberMethod().getThreadMode();switch (threadMode) {case POSTING:// 直接在发布线程调用订阅方法invokeMethod(subscription, event);break;case MAIN:case MAIN_ORDERED:// 如果发布线程是主线程, 直接调用if (isMainThread) {invokeMethod(subscription, event);} else {// 将订阅方法放到主线程执行// 获取主线程 Looper , 并通过 Looper 创建 HandlerHandler handler = new Handler(Looper.getMainLooper());// 在主线程中执行订阅方法handler.post(new Runnable() {@Overridepublic void run() {invokeMethod(subscription, event);}});}break;case BACKGROUND:case ASYNC:// 如果是主线程 , 切换到子线程执行if (isMainThread) {// 在线程池中执行方法executorService.execute(new Runnable() {@Overridepublic void run() {invokeMethod(subscription, event);}});} else {// 如果是子线程直接执行invokeMethod(subscription, event);}break;}}/*** 调用订阅者的订阅方法* @param subscription 订阅者对象 + 订阅方法* @param event 发布者传递的消息事件*/private void invokeMethod(MySubscription subscription, Object event) {try {// 通过反射调用订阅方法subscription.getSubscriberMethod().getMethod().invoke(subscription.getSubscriber(),   // 订阅者对象event                           // 事件参数类型);} catch (IllegalAccessException e) {e.printStackTrace();} catch (InvocationTargetException e) {e.printStackTrace();}}/*** 取消注册*      从 Map<Object, List<Class<?>>> typesBySubscriber 集合中获取*      订阅者对象 中的 订阅方法 参数集合**      然后再到*      Map<Class<?>, CopyOnWriteArrayList<MySubscription>> subscriptionsByEventType*      集合中获取 订阅方法参数类型 对应的 CopyOnWriteArrayList<MySubscription>> 集合*      MySubscription 中封装了 订阅者对象 + 订阅方法* @param subscriber*/public void unregister(Object subscriber) {// 首先获取 订阅者 对象中的订阅方法的参数集合List<Class<?>> types = typesBySubscriber.get(subscriber);// 遍历参数类型for (Class<?> type: types) {// 获取 接收 type 事件类型的 订阅者集合//      MySubscription 中封装了订阅者对象 + 订阅方法CopyOnWriteArrayList<MySubscription> subscriptions =subscriptionsByEventType.get(type);// 判定 CopyOnWriteArrayList<MySubscription> 集合中的 MySubscription 元素//      如果如果 封装类对象 中的 订阅者对象 与 本次取消注册的订阅者对象相同 , 则从集合中移除该订阅者// 记录集合大小int subscriptionsSize = subscriptions.size();for (int i = 0; i < subscriptionsSize; i++) {// 获取 订阅者对象 + 订阅方法 封装类 对象MySubscription subscription = subscriptions.get(i);// 如果 封装类对象 中的 订阅者对象 与 本次取消注册的订阅者对象相同//      将其从该集合中删除if (subscription.getSubscriber() == subscriber) {// 删除 i 索引元素subscriptions.remove(i);// 应用新的集合大小 , 集合少了一个元素subscriptionsSize--;// 第 i 个元素被删除了 , 之后会自增遍历下一个元素//      下一次遍历的还是第 i 个元素//      由于后面循环操作需要自增 , 想要之后仍然遍历第 i 个元素 ,//      这里对 i 进行自减操作i--;}}// 删除了订阅者 , 就完成了取消注册操作}}
}

二、订阅方法时的注解

定义一个注解 , 该注解用于修饰方法 ElementType.METHOD , 在运行时 , 用户调用 register 注册订阅者时 , 会分析哪个方法中存在该注解 , 将有注解的方法保存起来 , 以便之后的调用 ;

该注解需要保存到运行时 RetentionPolicy.RUNTIME ;

package com.eventbus_demo.myeventbus;import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;@Retention(RetentionPolicy.RUNTIME)     // 该注解保留到运行时
@Target(ElementType.METHOD)             // 该注解作用于方法
public @interface MySubscribe {/*** 注解属性, 设置线程模式, 默认是 POSTING,*      即在发布线程调用订阅方法* @return*/MyThreadMode threadMode() default MyThreadMode.POSTING;
}

三、订阅方法封装

将订阅方法 , 订阅方法的线程模式 , 订阅方法接收的事件类型 , 封装到类中 ;

package com.eventbus_demo.myeventbus;import java.lang.reflect.Method;/*** 该类中用于保存订阅方法相关信息*/
public class MySubscriberMethod {/*** 订阅方法*/private final Method method;/*** 订阅方法的线程模式*/private final MyThreadMode threadMode;/*** 订阅方法接收的事件类型*/private final Class<?> eventType;public MySubscriberMethod(Method method, MyThreadMode threadMode, Class<?> eventType) {this.method = method;this.threadMode = threadMode;this.eventType = eventType;}public Method getMethod() {return method;}public MyThreadMode getThreadMode() {return threadMode;}public Class<?> getEventType() {return eventType;}
}

四、订阅对象-方法封装

再次进行封装 , 将订阅者对象和订阅方法 , 封装到一个类中 , 这个类对象是注册 , 取消注册 , 事件调用操作的基本单元 ;

获取到该类的对象 , 就可以执行订阅方法 ;

package com.eventbus_demo.myeventbus;/*** 封装 订阅者对象 与 订阅方法*/
public class MySubscription {/*** 订阅者对象*/private final Object subscriber;/*** 订阅方法*/private final MySubscriberMethod subscriberMethod;public MySubscription(Object subscriber, MySubscriberMethod subscriberMethod) {this.subscriber = subscriber;this.subscriberMethod = subscriberMethod;}public Object getSubscriber() {return subscriber;}public MySubscriberMethod getSubscriberMethod() {return subscriberMethod;}
}

五、线程模式

仿照 EventBus 的线程模式 , 直接照搬过来 ;

package com.eventbus_demo.myeventbus;/*** 直接使用 EventBus 中的现成模式*/
public enum MyThreadMode {POSTING,MAIN,MAIN_ORDERED,BACKGROUND,ASYNC
}

六、Activity 中测试上述框架

在 Activity 中使用 @MySubscribe 注解修饰处理消息的方法 , 该方法必须是 public void 修饰的 , 只有一个参数 , 参数类型随意 , 调用 MyEventBus.getInstance().post 方法即可发送消息到该方法进行处理 ;

    /*** 使用 @MySubscribe 注解修饰处理消息的方法*      该方法必须是 public void 修饰的*      只有一个参数 , 参数类型随意*      调用 MyEventBus.getInstance().post 即可发送消息到该方法进行处理* @param msg*/@MySubscribepublic void onMessgeEvent(String msg){textView.setText(msg);}

在 onCreate 方法中 , 注册订阅方法 ;

    @Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);// 首先注册订阅 EventBusMyEventBus.getInstance().register(this);}

点击按钮 , 发送消息事件 , 这里发送了一个字符串 ;

        textView = findViewById(R.id.textView);// 设置点击事件, 点击后发送消息textView.setOnClickListener((View view)->{MyEventBus.getInstance().post("Hello EventBus !");});

完整 Activity 代码 :

package com.eventbus_demo;import android.os.Bundle;
import android.view.View;
import android.widget.TextView;import androidx.appcompat.app.AppCompatActivity;import com.eventbus_demo.myeventbus.MyEventBus;
import com.eventbus_demo.myeventbus.MySubscribe;import org.greenrobot.eventbus.EventBus;
import org.greenrobot.eventbus.Subscribe;
import org.greenrobot.eventbus.ThreadMode;/*** 使用 MyEventBus 依赖库*/
public class MainActivity3 extends AppCompatActivity {private TextView textView;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);textView = findViewById(R.id.textView);// 设置点击事件, 点击后发送消息textView.setOnClickListener((View view)->{MyEventBus.getInstance().post("Hello EventBus !");});// 首先注册订阅 EventBusMyEventBus.getInstance().register(this);}/*** 使用 @Subscribe 注解修饰处理消息的方法*      该方法必须是 public void 修饰的*      只有一个参数 , 参数类型随意*      调用 EventBus.getDefault().post 即可发送消息到该方法进行处理* @param msg*/@MySubscribepublic void onMessgeEvent(String msg){textView.setText(msg);}@Overrideprotected void onDestroy() {super.onDestroy();// 取消注册MyEventBus.getInstance().unregister(this);}
}

执行效果 : 点击后 , 页面变为如下效果 ;

七、博客源码

GitHub : https://github.com/han1202012/EventBus_Demo

【EventBus】事件通信框架 ( 总结 | 手写事件通信框架完整代码示例 | 测试上述框架 )相关推荐

手写数字识别神经网络完整代码，带详细注释。
神经网络使用的两个数据集:一个是训练集(60000条),一个是测试测试集(10000条),下载后直接放在程序目录下就可以了 mnist手写字体训练集6000条,mnist_train.csv mnis ...
手写滑动验证码，完整代码
一.概述滑动验证码在很多网站流行,一方面对用户体验来说,比较新颖,操作简单,另一方面相对图形验证码来说,安全性并没有很大的降低.当然到目前为止,没有绝对的安全验证,只是不断增加攻击者的绕过成本. 二 ...
基于Kera框架的手写数字识别
基于Kera框架的手写数字识别一.配置环境二.具体步骤 2.1 导入数据集 2.2 创建网络图层和网络结构 2.3 定义反向传播函数与优化函数 2.4 数据集和测试集归一化 2.5 标签制作三整 ...
MATLAB实现基于BP神经网络的手写数字识别+GUI界面+mnist数据集测试
文章目录 MATLAB实现基于BP神经网络的手写数字识别+GUI界面+mnist数据集测试一.题目要求二.完整的目录结构说明三.Mnist数据集及数据格式转换四.BP神经网络相关知识 4.1 ...
【Flutter】Flutter 混合开发 ( Flutter 与 Native 通信 | 完整代码示例 )
文章目录前言一.Android 端完整代码示例二.Flutter 端完整代码示例三.相关资源前言前置博客 : [Flutter]Flutter 混合开发 ( Flutter 与 Nativ ...
python写科学计算器代码_Python编程使用tkinter模块实现计算器软件完整代码示例...
Python编程使用tkinter模块实现计算器软件完整代码示例来源:中文源码网浏览: 次日期:2018年9月2日 Python编程使用tkinter模块实现计算器软件完整代码示例 ...
asp.net GridView手写事件，包括取主键、取值、更新、选择、删除
图片是本网站后台的友情链接管理页面: 前两者的代码比较固定,一般都是: 代码如下复制代码 protected void gvFriendLink_RowEditing(object sender, ...
手写事件代理函数（Delegated function）
'手写 ' 这个词 ,面试是不是听过无数遍呢 ! 今天我们来手写一个这样的事件委托函数 => function( parent, selector, type , handle) {} 你需 ...
uniapp手写_uni-app框架纯手写微信小程序开发左侧滑动菜单
原来到最后才发现有些东西,没有就真的没有.不行,就真的不行唠叨一会在学习的uni-app的微信小程序开发路上慢慢开始不一直依赖插件(但是使用插件是真的香,一直用一直香),在大佬的指引下学会自己去写 ...

【EventBus】事件通信框架 ( 总结 | 手写事件通信框架完整代码示例 | 测试上述框架 )

文章目录