专栏首页码匠的流水账spring event发布及监听实例

spring event发布及监听实例

本文主要介绍下如何在spring中进行发布时间以及接收事件

定义事件

public class DemoEvent extends ApplicationEvent {
    private String message;

    public DemoEvent(Object source, String message) {
        super(source);
        this.message = message;
    }
    public String getMessage() {
        return message;
    }
}

发布事件

    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;

    @GetMapping("/send-event")
    public Object sendEvent(@RequestParam String msg){
        DemoEvent demoEvent = new DemoEvent(this,msg);
        applicationEventPublisher.publishEvent(demoEvent);
        LOGGER.info("finish publish event");
        return "success";
    }

这里在mvc中发布,仅仅是为了演示。

接收事件(默认同步)

@Component
public class DemoEventListener implements ApplicationListener<DemoEvent>{

    private static final Logger LOGGER = LoggerFactory.getLogger(DemoEventListener.class);

    @Override
    public void onApplicationEvent(DemoEvent demoEvent) {
        LOGGER.info("receive event:{}",demoEvent.getMessage());
    }
}

这里是同步接收

异步处理事件

@Configuration
public class AsyncEventConfig {

    @Bean(name = "applicationEventMulticaster")
    public ApplicationEventMulticaster simpleApplicationEventMulticaster() {
        SimpleApplicationEventMulticaster eventMulticaster
                = new SimpleApplicationEventMulticaster();

        eventMulticaster.setTaskExecutor(new SimpleAsyncTaskExecutor());
        return eventMulticaster;
    }
}

加上这个配置就ok了,不然要注意,这里自己new的task executor,要优雅关闭的话,需要自己shutdown

SimpleApplicationEventMulticaster

spring-context-4.3.11.RELEASE-sources.jar!/org/springframework/context/event/SimpleApplicationEventMulticaster.java

    @Override
    public void multicastEvent(ApplicationEvent event) {
        multicastEvent(event, resolveDefaultEventType(event));
    }

    @Override
    public void multicastEvent(final ApplicationEvent event, ResolvableType eventType) {
        ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));
        for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) {
            Executor executor = getTaskExecutor();
            if (executor != null) {
                executor.execute(new Runnable() {
                    @Override
                    public void run() {
                        invokeListener(listener, event);
                    }
                });
            }
            else {
                invokeListener(listener, event);
            }
        }
    }

    private ResolvableType resolveDefaultEventType(ApplicationEvent event) {
        return ResolvableType.forInstance(event);
    }

可以看到,使用applicationEventMulticaster的时候,如果有线程池,则用线程池异步执行;否则则知直接调用listener的执行方法同步执行。

doc

  • Spring Events

本文分享自微信公众号 - 码匠的流水账(geek_luandun)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2017-09-29

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 聊聊kingbus的DumpBinlogAt

    DumpBinlogAt方法通过s.store.NewEntryReaderAt(startRaftIndex)获取reader,然后获取nextRaftInd...

    codecraft
  • 聊聊rocketmq的SequenceProducerImpl

    io/openmessaging/rocketmq/producer/SequenceProducerImpl.java

    codecraft
  • 聊聊kingbus的DumpBinlogAt

    DumpBinlogAt方法通过s.store.NewEntryReaderAt(startRaftIndex)获取reader,然后获取nextRaftInd...

    codecraft
  • bootstrap快速入门笔记(九)-响应式工具

    从 v3.2.0 版本起,形如 .visible-*-* 的类针对每种屏幕大小都有了三种变体,每个针对 CSS 中不同的 display 属性,列表如下:

    用户3055976
  • 设计模式(十八) 中介者模式

    当我们进行多人聊天的时候, 如果程序写成一对一的结构,那么当人数一多的时候程序就无法维护了。所以更好的做法就是抽象出一个聊天服务器,每个用户只和服务器进行通信。...

    乐百川
  • 2556. [NOIP2016]玩具谜题

    【题目描述】 小南有一套可爱的玩具小人,它们各有不同的职业。有一天,这些玩具小人把小南的眼镜藏了起来。小南发现玩具小人们围成了一个圈,它们有的面朝国内,有的面...

    attack
  • 爬虫的基本原理

    如果我们把互联网比作一张大的蜘蛛网,数据便是存放于蜘蛛网的各个节点,而爬虫就是一只小蜘蛛,

    py3study
  • 【视频讲解】-使用rmarkdown来制作html报表

    第一步:安装R语言及Rstudio 首先根据操作系统来安装R语言软件 最好是安装最新版 Download R for Windows from CRAN Dow...

    生信技能树
  • React Native在Windows下修改js代码后reload无效

    iOS下因为有watchman这个插件,所以启动很快(npm start),而Windows下则非常慢,最要命的是遇到了修改js文件后,点击reload居然一直...

    meteoric
  • CSS-Hack

    核心:<!– 1.什么是CSS Hack? 针对IE的不同版本设置不同的CSS属性, 我们就称之为CSS Hack

    用户7873631

扫码关注云+社区

领取腾讯云代金券