关于java:自写一个EventBus

首发于Enaium的集体博客


EventBus,什么是EventBus。

【腾讯云】云产品限时秒杀,爆款1核2G云服务器,首年99元

EventBus是事件公布-订阅总线,简略来说监听一个事件,一个办法订阅这个事件,如果事件调用,那么订阅了这个事件的办法也会跟着调用,这就是EventBus。

创立一个注解,用于订阅事件,名字能够轻易起,当然也能够叫Subscribe,我这里叫Event。

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Event {
}

创立Listener监听器。

public class Listener {
}

创立MethodBean类,来贮存订阅办法,Object是订阅类的对象,Method就是被订阅的办法。

public class MethodBean {
    private final Object object;
    private final Method method;

    public MethodBean(Object object, Method method) {
        this.object = object;
        this.method = method;
    }

    public Object getObject() {
        return object;
    }

    public Method getMethod() {
        return method;
    }
}

创立一个EventManager,来治理订阅的事件。

public class EventManager {
}

创立一个HashMap合集K是监听器,V是被调用的办法,因为一个监听器可能有多个办法,并且要保障线程平安,须要应用CopyOnWriteArrayList。

public class EventManager {
    private final HashMap<Class<? extends Listener>, CopyOnWriteArrayList<MethodBean>> events = new HashMap<>();
}

创立register和unregister办法来注册和勾销注册订阅的对象。

public class EventManager {
    public void register(Object o) {

    }

    public void unregister(Object o) {
        
    }
}

注册。

public void register(Object o) {
     Class<?> type = o.getClass();//获取类。

    for (Method method : type.getDeclaredMethods()) {//遍历出所有办法。
        if (method.getParameterTypes().length == 1 && method.isAnnotationPresent(Event.class)) {//保障办法只有一个参数,并且有Event这个注解。
            method.setAccessible(true);
            @SuppressWarnings("unchecked")
            Class<? extends Listener> listener = (Class<? extends Listener>) method.getParameterTypes()[0];

            MethodBean methodBean = new MethodBean(o, method);

            //把这些都put到events外面。
            if (events.containsKey(listener)) {
                if (!events.get(listener).contains(methodBean)) {
                    events.get(listener).add(methodBean);
                }
            } else {
                events.put(listener, new CopyOnWriteArrayList<>(Collections.singletonList(methodBean)));
            }
        }
    }
}

勾销注册很简略,只有将events的K和V移除就行。

public void unregister(Object o) {
    events.values().forEach(methodBeans -> methodBeans.removeIf(methodMethodBean -> methodMethodBean.getObject().equals(o)));
    events.entrySet().removeIf(event -> event.getValue().isEmpty());
}

创立一个getEvent办法来获取一个监听器的所有订阅。

public CopyOnWriteArrayList<MethodBean> getEvent(Class<? extends Listener> type) {
    return events.get(type);
}

创立一个单例。

public enum Main {

    INSTANCE;

    EventManager eventManager = new EventManager();
    
}

回到方才创立的Listener类。

创立一个call办法来进行事件触发操作,当事件触发,获取监听器的所有订阅办法来调用,参数就是以后的监听器。

public class Listener {
    public void call() {
        CopyOnWriteArrayList<MethodBean> methodBeans = Main.INSTANCE.eventManager.getEvent(this.getClass());

        if(methodBeans == null) {
            return;
        }

        methodBeans.forEach(event -> {
            try {
                event.getMethod().invoke(event.getObject(), this);
            } catch (IllegalAccessException | InvocationTargetException e) {
                e.printStackTrace();
            }
        });
    }
}

创立一个监听器。

public class UpdateEvent extends Listener {
}

一个简略的EventBus曾经写好了,当初来测试一下。

public enum Main {

    INSTANCE;

    EventManager eventManager = new EventManager();

    public static void main(String[] args) {
        Main.INSTANCE.eventManager.register(new Test());//register
        new UpdateEvent().call();
    }

    static class Test {
        @Event
        public void on(UpdateEvent e) {
            System.out.println("Event trigger");
        }
    }
}

源码

阿里云限时活动-2核2G-5M带宽-40-100G SSD服务器,特惠价86元/年(原价724元/年,限时99元续购三次),速抢

本文由乐趣区整理发布,转载请注明出处,谢谢。

You may also like...

发表评论

邮箱地址不会被公开。 必填项已用*标注

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据