文章目錄

• 一、消息中心
• 二、訂閱方法時的注解
• 三、訂閱方法封裝
• 四、訂閱對象-方法封裝
• 五、線程模式

一、消息中心

---

此處暫時只實現一個單例類 , 后續 注冊訂閱者 , 處理事件傳遞 , 取消注冊訂閱者 , 等功能在該單例類的基礎上擴展 ;

package com.eventbus_demo.myeventbus;public class MyEventBus {/*** 全局單例*/private static MyEventBus instance;private MyEventBus() {}public static MyEventBus getInstance() {if (instance == null) {instance = new MyEventBus();}return instance;}}

二、訂閱方法時的注解

---

定義一個注解 , 該注解用于修飾方法 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 的線程模式 , 直接照搬過來 ;

線程模式用法參考 【EventBus】Subscribe 注解分析 ( Subscribe 注解屬性 | threadMode 線程模型 | POSTING | MAIN | MAIN_ORDERED | ASYNC) ;

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

總結

以上是生活随笔為你收集整理的【EventBus】事件通信框架 ( 实现几个关键的封装类 | 消息中心 | 订阅注解 | 订阅方法封装 | 订阅对象-方法封装 | 线程模式 )的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。