knight_event

Object o = new Object(); //消息的具体数据
String evnetType = "dealType"; //定义事件消息的类型
EventDate eventDate = new EventDate(this,o,evnetType); //组装消息
applicationContext.publishEvent(new EventDate(this, eventData)); /推送消息

//具体的事件处理器示例代码
@Component
public class XXEventHandler extends AbstractEventHandler<String,Object>{


    @Override
    boolean doHandler(Object data) {
        //处理具体业务逻辑的地方
        return false;
    }

    @Override
    void release() {
        //主要是做一些释放资源的操作，如果没有可以忽略不写
    }


    /**
     * 返回事件处理器的名称
     * @return
     */
    @Override
    public String getHandlerName() {
        return "dealEventHandler";
    }

    /**
     * 具体支持处理哪些类型的事件消息
     * @return
     */
    @Override
    public List supportEventTypeList() {
        return Arrays.asList("dealType");
    }
    
    /**
     * 提供事件处理器序号，按照从大到小的顺序进行事件消息处理
     * 如果无需顺序，可忽略该方法不提供重写，会有默认的序号0提供
     * @return
     */
    @Override
    public Integer getOrder() {
        return 1;
    }
}

@Bean
public EventHandlerPool eventHandlerPool() {
    return new EventHandlerPool();
}

//构建SimpleEventListener

@Bean
public SimpleEventListener simpleEvenetListener(@Autowired EventHandlerPool eventHandlerPool) {
    return new SimpleEventListener(eventHandlerPool);
}

//构建AsyncEventListener

@Bean
public AsyncEventListener asyncEventListener(@Autowired ThreadPoolExecutor threadPoolExecutor, @Autowired EventHandlerPool eventHandlerPool) {
    return new AsyncEventListener(threadPoolExecutor, eventHandlerPool);
}