spring boot事件如何使用总结

熊孩纸 阅读:273 2022-02-24 12:27:40 评论:0
本文章主要介绍了spring boot事件如何使用,具有不错的的参考价值,希望对您有所帮助,如解说有误或未考虑完全的地方,请您留言指出,谢谢!

Spring 官方文档翻译如下 :

ApplicationContext 通过 ApplicationEvent 类和 ApplicationListener 接口进行事件处理。 如果将实现 ApplicationListener 接口的 bean 注入到上下文中,则每次使用 ApplicationContext 发布 ApplicationEvent 时,都会通知该 bean。 本质上,这是标准的观察者设计模式。

Spring的事件(Application Event)其实就是一个观察者设计模式,一个 Bean 处理完成任务后希望通知其它 Bean 或者说 一个Bean 想观察监听另一个Bean的行为。

Spring 事件只需要几步:

  • 自定义事件,继承 ApplicationEvent
  • 定义监听器,实现 ApplicationListener 或者通过 @EventListener 注解到方法上
  • 定义发布者,通过 ApplicationEventPublisher

代码示例:

1. 自定义Event

@Data 
public class DemoEvent extends ApplicationEvent { 
    private Long id; 
    private String message; 
 
    public DemoEvent(Object source, Long id, String message) { 
        super(source); 
        this.id = id; 
        this.message = message; 
    } 
}

2. 监听器

  • 实现ApplicationListener 接口(泛型为需要监听的事件类型)
@Component 
public class DemoListener implements ApplicationListener<DemoEvent> { 
 
    @Override 
    public void onApplicationEvent(DemoEvent demoEvent) { 
        System.out.println(">>>>>>>>>DemoListener>>>>>>>>>>>>>>>>>>>>>>>>>>>>"); 
        System.out.println("收到了:" + demoEvent.getSource() + "消息;时间:" + demoEvent.getTimestamp()); 
        System.out.println("消息:" + demoEvent.getId() + ":" + demoEvent.getMessage()); 
    } 
}
  • @EventListener(参数为需要监听的事件类型)
@Component 
public class DemoListener2 { 
 
    @EventListener 
    public void onApplicationEvent(DemoEvent demoEvent) { 
        System.out.println(">>>>>>>>>DemoListener2>>>>>>>>>>>>>>>>>>>>>>>>>>>>"); 
        System.out.println("收到了:" + demoEvent.getSource() + "消息;时间:" + demoEvent.getTimestamp()); 
        System.out.println("消息:" + demoEvent.getId() + ":" + demoEvent.getMessage()); 
    } 
}

3. 消息发布者

@Component 
public class DemoPublisher { 
 
    private final ApplicationContext applicationContext; 
 
    @Autowired 
    public DemoPublisher(ApplicationContext applicationContext) { 
        this.applicationContext = applicationContext; 
    } 
 
    public void publish(long id, String message) { 
        applicationContext.publishEvent(new DemoEvent(this, id, message)); 
    } 
 
}

4. 测试方法

@Test 
public void publisherTest() { 
    demoPublisher.publish(1L, "成功了!"); 
}

5.结果

>>>>>>>>>DemoListener2>>>>>>>>>>>>>>>>>>>>>>>>>>>> 
收到了:com.jiuxian.publisher.DemoPublisher@3a62c01e消息;时间:1551762322376 
消息:1:成功了! 
>>>>>>>>>DemoListener>>>>>>>>>>>>>>>>>>>>>>>>>>>> 
收到了:com.jiuxian.publisher.DemoPublisher@3a62c01e消息;时间:1551762322376 
消息:1:成功了!





标签:java
声明

1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。

我的关注

全民解析

搜索
排行榜
关注我们