亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

使用Spring事件機制實現異步的方法

發布時間:2020-09-11 23:06:21 來源:腳本之家 閱讀:715 作者:Joepis 欄目:編程語言

當把一個事件發布到Spring提供的ApplicationContext中,被監聽器偵測到,就會執行對應的處理方法。

事件本身
事件是一個自定義的類,需要繼承Spring提供的ApplicationEvent

@Data
public class MyEvent extends ApplicationEvent {
  private String msg;

  public MyEvent(Object source, String msg) {
    super(source);
    this.msg = msg;
  }
}

事件監聽

基本方法是實現ApplicationListener接口,自定義一個監聽器,實現onApplicationEvent()方法,然后添加到ApplicationContext

比如:

public class MyListener implements ApplicationListener<MyEvent> { 

  @Override 
  public void onApplicationEvent(MyEvent event) { 
    System.out.print("監聽到MyEvent事件"); 
  } 
} 
...
// SpringBoot的啟動類中添加監聽器
    public static void main(String[] args) {
    SpringApplication application = new SpringApplication(MyApplication.class);
    application.addListeners(new MyListener());
    application.run(args);
  }

也可以使用注解@EventListener(推薦):原理就是通過掃描這個注解,創建監聽器并添加到ApplicationContext

@Component
@Slf4j
public class MyEventHandler {

  @EventListener
  public void handleEvent(MyEvent event) {
    log.info("------------處理事件:{}", event.getMsg());
    try {
      Thread.sleep(5 * 1000L);
      log.info("事件1(5s)處理完成");
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }

}

事件發布

可以通過上下文對象的發布方法ConfigurableApplicationContext::publishEvent()來發布。

也可以實現ApplicationEventPublisherAware接口來發布(推薦)。

@Component
@Slf4j
public class EventService implements ApplicationEventPublisherAware {
  public ApplicationEventPublisher publisher;

  @Override
  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
    this.publisher = applicationEventPublisher;
  }

  public String doEventWork(String msg) {
    log.info("------------publish event:" + msg);
    MyEvent event = new MyEvent(this, msg);
    publisher.publishEvent(event);
    return "OK";
  }
}

測試代碼

@SpringBootTest
@RunWith(SpringRunner.class)
public class EventServiceTest {
  @Autowired
  private EventService service;

  @Test
  public void eventTest() {
    String msg="Java Code";
    service.doEventWork(msg);
  }
}

使用Spring事件機制實現異步的方法

注意

如果2個事件之間是繼承關系,會先監聽到子類事件,處理完再監聽父類。

// MyEvent2 extends MyEvent

@Component
@Slf4j
public class MyEventHandler {

  @EventListener
  public void handleEvent(MyEvent event) {
    log.info("------------處理事件:{}", event.getMsg());
    try {
      Thread.sleep(5 * 1000L);
      log.info("事件1(5s)處理完成");
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }

  @EventListener
  public void handleEvent2(MyEvent2 event) {
    log.info("------------處理事件2:{}", event.getMsg());
    try {
      Thread.sleep(10 * 1000L);
      log.info("事件2(10s)處理完成");
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
}

當我publish一個子類事件MyEvent2時,日志如下:

使用Spring事件機制實現異步的方法

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

安图县| 芮城县| 姜堰市| 门源| 宜兴市| 绥棱县| 巴南区| 稻城县| 板桥市| 临洮县| 南靖县| 沾益县| 芦山县| 大连市| 肥城市| 黎平县| 阿城市| 邹城市| 玉龙| 成安县| 南郑县| 西城区| 乌苏市| 玉田县| 奎屯市| 平塘县| 万载县| 乐清市| 台北县| 年辖:市辖区| 冷水江市| 启东市| 武强县| 镇雄县| 任丘市| 会理县| 根河市| 濮阳县| 喀喇沁旗| 蓬溪县| 讷河市|