/eventbus-spring-boot-starter

Primary LanguageJava

基于EventBus的spring boot starter

用法

step1：在项目的pom.xml文件中添加如下依赖

    <dependency>
        <groupId>com.deepexi</groupId>
        <artifactId>deepexi-eventbus-spring-boot-starter</artifactId>
        <version>1.1.0</version>
    </dependency>

step2：在配置文件application.properties里面添加配置信息(配置会自动提示且有注释说明)

# 是否开启EventBus
deepexi.eventbus.enabled=true
# EventBus名字
deepexi.eventbus.name="com.deepexi"

step3：注册使用EventBus

3.1、注册Listener到EvenBus，必须为Spring的Bean，priority指定订阅方法执行顺序，name为自定义模块名，主要用于日志追踪

    @EventBusListener
    @Service
    public class DingMessageServiceImpl implement DingMessageService {
        // 订阅某个对象事件
        @Subscribe(priority=Priority.S_LEVEL, name="钉钉消息")
        @Override
        public void listen(Event e) {
        }
    }

3.2、发送EventBus事件

    @Service
    public class DingMessageServiceImpl implement DingMessageService {
        // 注入EventBus实例
        @Resource
        private EventBus eventBus;
        
        @Override
        public void sendMessage(){
            eventBus.post(new String("Msg"));
        }
    }