内容简介：观察者模式中的角色可以分为Subject和Observer，它们分别为被观察者和观察者，观察者观察被观察者的状态变更。google的guava中提供了EventBus功能，EventBus可以实现观察者模式，下面是一个简单的例子我们也可以自己实现一个EventBus，虽然在效率上没办法和google的实现相比，但是基本原理都是一样的。首先我们创建一个用于标记方法是否需要实现订阅的注解
观察者模式中的角色可以分为Subject和Observer，它们分别为被观察者和观察者，观察者观察被观察者的状态变更。google的guava中提供了EventBus功能，EventBus可以实现观察者模式，下面是一个简单的例子
import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;
public class TestEventBus {
public static void main(String[] args) {
EventBus eventBus = new EventBus("test");
// 注册一个listener
eventBus.register(new Listener());
// 遍历被注册的对象以及其方法，调用符合要求的方法
eventBus.post(new Event("hello, world"));
}
}
class Event {
public String message;
Event(String message) {
this.message = message;
}
}
class Listener {
@Subscribe
public void listen(Event event) {
System.out.println(event.message);
}
}
我们也可以自己实现一个EventBus，虽然在效率上没办法和google的实现相比，但是基本原理都是一样的。
首先我们创建一个用于标记方法是否需要实现订阅的注解
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Subscribe {
}
随后创建EventBus的核心类，其主要功能是添加或移除listener，以及根据传入的参数对符合要求的方法进行调用
public class EventBus {
private Set<Object> listeners = new HashSet<>();
public void register(Object listener) {
listeners.add(listener);
}
public void unregister(Object listener) {
listeners.remove(listener);
}
// 1. 遍历所有的listener对象；
// 2. 遍历所有的listener对象的方法；
// 3. 判断该方法是否添加了订阅注解，方法的参数个数和参数类型是否符合调用方的参数要求；
// 4. 如果一切条件都符合，执行该方法；
public void post(Object event) {
for (Object listener : listeners) {
Method[] methods = listener.getClass().getDeclaredMethods();
for (Method method : methods) {
if (method.isAnnotationPresent(Subscribe.class)) {
Class[] parameterTypes = method.getParameterTypes();
if (parameterTypes.length == 1 && parameterTypes[0] == event.getClass()) {
try {
// 调用方法
method.invoke(listener, event);
} catch (IllegalAccessException | InvocationTargetException e) {
e.printStackTrace();
}
}
}
}
}
}
}
最后我们对上面的实现进行测试
public class Test {
public static void main(String[] args) {
EventBus eventBus = new EventBus();
eventBus.register(new Listener());
eventBus.post("Mike");
}
}
class Listener {
@Subscribe
public void say(String name) {
System.out.println("hello, " + name);
}
}
测试代码打印出了如下结果
hello, Mike
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网
猜你喜欢:
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
数据密集型应用系统设计
Martin Kleppmann / 赵军平、李三平、吕云松、耿煜 / 中国电力出版社 / 2018-9-1 / 128
全书分为三大部分： 第一部分，主要讨论有关增强数据密集型应用系统所需的若干基本原则。首先开篇第1章即瞄准目标：可靠性、可扩展性与可维护性，如何认识这些问题以及如何达成目标。第2章我们比较了多种不同的数据模型和查询语言，讨论各自的适用场景。接下来第3章主要针对存储引擎，即数据库是如何安排磁盘结构从而提高检索效率。第4章转向数据编码（序列化）方面，包括常见模式的演化历程。 第二部分，我们将......一起来看看 《数据密集型应用系统设计》 这本书的介绍吧!
