easy-event

基于JSR269实现的事件驱动组件 image.png

###使用方法

1.实现EventConsumer接口, 如下

public class MyConsumer implements EventConsumer {

    @Override
    public void before(AroundMethod aroundMethod) {
        System.out.println("consume before");
    }

    @Override
    public void after(AroundMethod aroundMethod) {
        System.out.println("consume after");
    }

    @Override
    public void thrown(AroundMethod aroundMethod, Exception e) {
        System.out.println("consume thrown");
    }
    
    @Override
    public Executor executor() {
        return new ThreadPoolExecutor(4, 8, 1, TimeUnit.MINUTES, new ArrayBlockingQueue<>(100));
    }
}

2.目标方法上添加 @Event 注解

@Event({MyConsumer.class})
private int method1(String param) {
    System.out.println("业务逻辑:param =" + param);
    return 1;
}

如果是Spring项目，则在spring xml配置中添加如下配置，并将 MyConsumer 注入到Spring容器中

<bean class="com.github.binarybeing.easyevent.ConsumersConfiguration"/>