EventBus

Source: Dev.to

SimpleEventBus 实现

import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;

// Concrete EventBus implementation
public class SimpleEventBus implements MyEventBus {

    private final ConcurrentHashMap>> listenersMap = new ConcurrentHashMap<>();

    // Publish an event to all listeners of a source
    public void push(String source, T event) {
        List> listeners = listenersMap.get(source);
        if (listeners != null && !listeners.isEmpty()) {
            for (MyEventListener listener : listeners) {
                try {
                    listener.onEvent(source, event);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }

    // Get number of subscribers for a source
    public int getSubscriberCount(String source) {
        List> listeners = listenersMap.get(source);
        return (listeners == null) ? 0 : listeners.size();
    }

    @Override
    public void subscribe(String source, MyEventListener listener) {
        listenersMap.computeIfAbsent(source, key -> new CopyOnWriteArrayList<>()).add(listener);
    }

    @Override
    public void unsubscribe(String source, MyEventListener listener) {
        listenersMap.computeIfPresent(source, (key, list) -> {
            list.remove(listener);
            return list.isEmpty() ? null : list;
        });
    }
}

使用示例

上面的 EventBus 是一个类似 Guava 的 EventBus 实现。无需额外说明。

class MessageListener implements MyEventListener {
    private final String name;

    public MessageListener(String name) { this.name = name; }

    @Override
    public void onEvent(String source, Message event) {
        System.out.println(name + " received from [" + source + "]: " + event.getText());
    }
}