Skip to main content

事件模型

在代码层面往往多个系统之间还会有直接或者间接的调用，为了降低代码耦合度可以使用 Hasor 的事件机制来进行深度解耦。

Hasor 事件的执行分为三种，它们的执行模型如下：

  • 同步(独享线程)
  • 同步(共享线程)
  • 异步

事件模型

无论是同步的事件模型，还是异步事件模型。在 Hasor 事件体系中，它们都有以下共同性质：

  • 按注册顺序执行事件监听器
  • 事件监听器接口相同
  • 事件注册方式相同

注册事件监听器​

实现一个监听器
import net.hasor.core.EventListener;
public class MyListener implements EventListener<Object> {
    public void onEvent(String event, Object eventData) throws InterruptedException {
        Thread.sleep(500);
        System.out.println("Receive Message:" + JSON.toJSONString(eventData));
    }
}
获取 EventContext 接口
ApiBinder apiBinder = ... 
EventContext ec = apiBinder.getEnvironment().getEventContext();

or

AppContext appContext = ...;
EventContext eventContext = appContext.getInstance(EventContext.class);

or

EventContext eventContext = appContext.getEnvironment().getEventContext();

or

public class MyBean {
    @Inject
    private EventContext eventContext;
}

接着我们通过 EventContext 将事件注册到容器中。

注册事件监听器
EventContext eventContext = ...
eventContext.addListener("EventName",new MyListener());

引发事件​

例如
eventContext.fireSyncEvent("EventName",...);