日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

當前位置:首頁 > 科技  > 軟件

Spring事件機制,深入剖析,提升你的技術水平!

來源: 責編: 時間:2023-11-01 09:18:38 289觀看
導讀環境:Spring5.3.231. 簡介Spring事件機制是一種用于處理系統內部或者外部事件的機制,它是Spring框架的一部分。事件機制基于監聽者設計模式實現,包括事件、發布器和監聽器三個主要部分。在Spring中,事件是主體,發布器負責

環境:Spring5.3.23AnG28資訊網——每日最新資訊28at.com

1. 簡介

Spring事件機制是一種用于處理系統內部或者外部事件的機制,它是Spring框架的一部分。事件機制基于監聽者設計模式實現,包括事件、發布器和監聽器三個主要部分。AnG28資訊網——每日最新資訊28at.com

在Spring中,事件是主體,發布器負責發布事件,監聽器負責處理事件。事件對象封裝了事件源對象和事件相關信息,用于在事件源和監聽器之間傳遞信息。發布器通過注入事件發布者實現,使用事件發布者發布事件。監聽器通過實現ApplicationListener接口來定義,用于對事件進行處理。AnG28資訊網——每日最新資訊28at.com

Spring容器提供了事件管理機制,內部很多節點都會發布事件,也支持自定義事件。在Spring Boot中,你可以使用ApplicationEventPublisher接口來發布事件,通過繼承ApplicationEvent抽象類來定義事件對象,通過實現ApplicationListener接口來定義事件監聽器。AnG28資訊網——每日最新資訊28at.com

總之,Spring事件機制是一個非常有用的工具,可以幫助你更好地管理和處理系統中的事件。AnG28資訊網——每日最新資訊28at.com

2. 事件發布及監聽

創建并發布自己的自定義事件。通過ApplicationEventAnG28資訊網——每日最新資訊28at.com

static class OrderEvent extends ApplicationEvent {  private Order order ;  public OrderEvent(Object source, Order order) {    super(source) ;    this.order = order ;  }  public Order getOrder() {    return this.order;  }}

要接收自定義 ApplicationEvent,可以創建一個實現 ApplicationListener 的類,并將其注冊為 Spring Bean。AnG28資訊網——每日最新資訊28at.com

static class OrderListener implements ApplicationListener<OrderEvent> {  @Override  public void onApplicationEvent(OrderEvent event) {    System.out.printf("監聽到定義事件:%s", event.getOrder().toString()) ;  }}

要發布自定義 ApplicationEvent,調用 ApplicationEventPublisher 上的 publishEvent() 方法。通常,可以通過創建一個實現 ApplicationEventPublisherAware 的類并將其注冊為 Spring Bean 來實現:AnG28資訊網——每日最新資訊28at.com

static class OrderService implements ApplicationEventPublisherAware {  private ApplicationEventPublisher eventPublisher ;  @Override  public void setApplicationEventPublisher(ApplicationEventPublisher eventPublisher) {    this.eventPublisher = eventPublisher ;  }  public void save(Order order) {    this.eventPublisher.publishEvent(new OrderEvent("create oder event", new Order()));  }}

基于注解方式實現事件監聽

你可以使用 @EventListener 注解在任意Bean 的任何方法上注冊事件監聽器。示例如下:AnG28資訊網——每日最新資訊28at.com

static class MyEventListener {      @EventListener  public void receiveOrderEvent(OrderEvent event) {    System.out.printf("監聽到定義事件:%s", event.getOrder().toString()) ;  }  }

通過一個注解,實現了事件的監聽,在該方法中指定了要監聽的事件類型。AnG28資訊網——每日最新資訊28at.com

如果你的方法需要監聽多個事件,或者你想定義一個不帶任何參數的方法,也可以在注解中指定事件類型。示例如下:AnG28資訊網——每日最新資訊28at.com

@EventListener({OrderEvent.class, UserEvent.class})public void receiveOrderEvent() {  System.out.printf("監聽到定義事") ;}

這里指明了只監聽OrderEvent, UserEvent兩個事件。AnG28資訊網——每日最新資訊28at.com

也可以直接通過ApplicationEvent攜帶參數,這樣可以通過判斷處理不同的事件類型,示例如下:AnG28資訊網——每日最新資訊28at.com

@EventListener({OrderEvent.class, UserEvent.class})public void receiveOrderEvent(ApplicationEvent event) {  System.out.printf("監聽到定義事件:%s", event.getSource()) ;}

我們還可以通過SpEL表達式過濾事件,示例如下:AnG28資訊網——每日最新資訊28at.com

// User對象static class User {  private Integer type ;  public User(Integer type) {    this.type = type ;  }}// UserEvent事件對象static class UserEvent extends ApplicationEvent {  private User user ;  public UserEvent(Object source, User user) {    super(source) ;    this.user = user ;  }  public User getUser() {    return user;  }} // 事件監聽; 過濾只有User對象的type屬性為1時才會觸發事件@EventListener(condition = "#event.user.type == 1")public void receiveOrderEvent(UserEvent event) {  System.out.printf("監聽到定義事件:%s", event.getUser()) ;}

3. 異步事件監聽

異步方式1:AnG28資訊網——每日最新資訊28at.com

如果想讓某個監聽器異步處理事件,可以通過 @Async 注解支持,示例如下:AnG28資訊網——每日最新資訊28at.com

@EventListener@Asyncpublic void receiveOrderEvent(UserEvent event) {  System.out.printf("%s - 監聽到定義事件:%s", Thread.currentThread().getName(), event.getUser()) ;}

執行結果:AnG28資訊網——每日最新資訊28at.com

SimpleAsyncTaskExecutor-1 - 監聽到定義事件:com.pack.main.events.EventMain$User@abb3dc

異步方式2:AnG28資訊網——每日最新資訊28at.com

自定義一個事件發布器AnG28資訊網——每日最新資訊28at.com

@Beanpublic SimpleApplicationEventMulticaster applicationEventMulticaster() {  SimpleApplicationEventMulticaster applicationEventMulticaster = new SimpleApplicationEventMulticaster();  applicationEventMulticaster.setTaskExecutor(Executors.newSingleThreadExecutor()) ;  return applicationEventMulticaster ;}

有個該事件發布器,容器在初始化時會先從容器中查找注冊的自定義發布器,源碼如下:AnG28資訊網——每日最新資訊28at.com

protected void initApplicationEventMulticaster() {    ConfigurableListableBeanFactory beanFactory = getBeanFactory();    // 判斷容器中是否有beanName = applicationEventMulticaster 的Bean    if (beanFactory.containsLocalBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME)) {      this.applicationEventMulticaster =          beanFactory.getBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, ApplicationEventMulticaster.class);    } else {      // 如果不存在則注冊一個默認的,該默認的將使用默認的當前執行線程執行      this.applicationEventMulticaster = new SimpleApplicationEventMulticaster(beanFactory);      beanFactory.registerSingleton(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, this.applicationEventMulticaster);    }  }

執行結果:AnG28資訊網——每日最新資訊28at.com

pool-1-thread-1 - 監聽到定義事件:com.pack.main.events.EventMain$User@50f8a6

異步事件注意事項:AnG28資訊網——每日最新資訊28at.com

  1. 如果異步事件監聽器拋出異常,它不會傳播給調用者。對于使用@Async的可以參考 AsyncUncaughtExceptionHandler。
  2. 異步事件監聽器方法不能通過返回值來發布后續事件。如果需要將另一個事件作為處理結果發布,請注入 ApplicationEventPublisher 以手動發布事件。

4. 事件監聽順序

如果需要在調用一個監聽器之前調用另一個監聽器,可以在方法聲明中添加 @Order 注解,示例如下:AnG28資訊網——每日最新資訊28at.com

@EventListener@Order(1)public void receiveOrderEvent1(UserEvent event) {  System.out.printf("%s - 監聽到定義事件 - 1:%s%n", Thread.currentThread().getName(), event.getUser()) ;}@EventListener@Order(0)public void receiveOrderEvent2(UserEvent event) {  System.out.printf("%s - 監聽到定義事件 - 2:%s%n", Thread.currentThread().getName(), event.getUser()) ;}

@Order中指定的值越小優先級越高,執行結果如下:AnG28資訊網——每日最新資訊28at.com

main - 監聽到定義事件 - 2:com.pack.main.events.EventMain$User@96bacfmain - 監聽到定義事件 - 1:com.pack.main.events.EventMain$User@96bacf

完畢!!!AnG28資訊網——每日最新資訊28at.com

本文鏈接:http://www.www897cc.com/showinfo-26-16278-0.htmlSpring事件機制,深入剖析,提升你的技術水平!

聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: Spring Boot應用中的配置文件選擇:YAML vs. Properties

下一篇: Go語言高級特性:Context深入解讀

標簽:
  • 熱門焦點
Top 主站蜘蛛池模板: 哈巴河县| 五莲县| 石楼县| 临颍县| 塔城市| 曲麻莱县| 扎鲁特旗| 滨海县| 买车| 乌鲁木齐市| 潍坊市| 颍上县| 荃湾区| 金阳县| 厦门市| 定日县| 漳平市| 洪雅县| 元江| 金阳县| 平凉市| 南平市| 永泰县| 增城市| 长寿区| 故城县| 嘉兴市| 金山区| 凤凰县| 滕州市| 荥阳市| 樟树市| 怀宁县| 双辽市| 托克托县| 东光县| 三原县| 大邑县| 汉寿县| 徐州市| 措美县|