框架可以通过发送特定的数据 触发特定的组件

一、核心的数据分发器

1.Member 代表订阅的组件
2.subscribe：将所有的业务组件加入到了一个集合中
3.publish: 触发事件,尝试像所有订阅的事件集合中出入该类型数据，由他们决定是否处理

 */
public class DataBus {
  private static final DataBus INSTANCE = new DataBus();
  private final Set<Member> listeners = new HashSet<>();

  public static DataBus getInstance() {
    return INSTANCE;
  }
  public void subscribe(final Member member) {
    this.listeners.add(member);
  }
  public void unsubscribe(final Member member) {
    this.listeners.remove(member);
  }
  public void publish(final DataType event) {
      event.setDataBus(this);
     for(Member m:listeners){
        m.accepts(event);
     }
   }
}

数据类型

public class MessageData extends AbstractDataType {
  private final String message;
  public MessageData(String message) {
    this.message = message;
  }
  public String getMessage() {
    return message;
  }
  public static DataType of(final String message) {
    return new MessageData(message);
  }
}

被触发的模块

accept:代表这个模块处理什么样的数据 是否处理发过来的消息

public interface Member extends Consumer<DataType> {
  void accept(DataType event);
}

这是一个成员的例子，当accept方法在DataBus中触发时，这个模块会自己判断是否是需要它处理的数据
如果是就会执行相应的功能--handleEvent

public class MessageCollectorMember implements Member {

  private List<String> messages = new ArrayList<>();

  @Override
  public void accept(final DataType data) {
    if (data instanceof MessageData) {
      handleEvent((MessageData) data);
    }
  }

  private void handleEvent(MessageData data) {
    LOGGER.info(String.format("%s sees message %s", name, data.getMessage()));
    messages.add(data.getMessage());
  }
}