SpringBoot+EventBus使用教程(一)

1、簡介

EventBus是一個基於發佈訂閱的事件總線,在Java和Android裏均可以使用。css

2、使用

1.引入pom

<dependency>
            <groupId>org.greenrobot</groupId>
            <artifactId>eventbus</artifactId>
            <version>3.1.1</version>
        </dependency>

2.定義事件監聽類

@Component
@Slf4j
public class EventListener {
    @Subscribe
    public void onMessageEvent(String event) {
        log.info("Subscribe message:{}", event);
    }
}

3.EventBusConfig

@Configuration
public class EventBusConfig {

    @Bean
    public EventBus eventBus(){
        return new EventBus();
    }

}

4.EventHandler

@Component
@Slf4j
public class EventHandler {

    @Autowired
    private EventBus eventBus;

    @Autowired
    private EventListener eventListener;

    @PostConstruct
    public void init() {
        eventBus.register(eventListener);
    }

    @PreDestroy
    public void destroy() {
        eventBus.unregister(eventListener);
    }

    public void eventPost(){
        eventBus.post("test");
        log.info("post event");
    }
}

5.測試類

@RunWith(SpringRunner.class)
@SpringBootTest
public class EventBusTest {

    @Autowired
    private EventHandler eventHandler;

    @Test
    public void postEvent(){
        eventHandler.eventPost();
    }

}

6.運行結果

2019-11-01 22:33:24.657  INFO 6656 --- [           main] com.sww.bizhi.eventbus.EventListener     : Subscribe message:test
2019-11-01 22:33:24.671  INFO 6656 --- [           main] com.sww.bizhi.eventbus.EventHandler      : post event

3、自定義事件

上面的例子,咱們發送和接收的都是string,若是我想event是個bean,怎麼操做?git

1.添加MessageEvent類

@Data
@Builder
public class MessageEvent {

    private Integer id;
    private String name;

}

2.修改EventHandler裏的eventPost方法(紅色字體部分)

public void eventPost(){
        eventBus.post(MessageEvent.builder().id(1).name("test").build());
        log.info("post event");
    }

3.修改EventListener類裏的onMessageEvent方法(紅色字體部分)

@Subscribe
    public void onMessageEvent(MessageEvent event) {
        log.info("Subscribe message:{}", event);
    }

4.運行測試類,查看結果

2019-11-01 22:53:24.273  INFO 2252 --- [           main] com.sww.bizhi.eventbus.EventListener     : Subscribe message:MessageEvent(id=1, name=test)
2019-11-01 22:53:24.278  INFO 2252 --- [           main] com.sww.bizhi.eventbus.EventHandler      : post event

4、最後

本篇初步介紹瞭如何在springboot裏使用eventbus,下一篇文章將介紹如何集成spring-boot-starter-guava-eventbusgithub

EventBus地址:https://github.com/greenrobot/EventBusspring

另外,本篇教程使用了lombok插件。springboot

相關文章
相關標籤/搜索