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

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

警惕!SpringBoot錯誤發布事件,造成死鎖Deadlock

來源: 責編: 時間:2024-06-12 08:43:40 170觀看
導讀環境:SpringBoot3.2.51. 死鎖復現1.1 自定義事件監聽public class PackApplicationEvent extends ApplicationEvent { private String message ; public PackApplicationEvent(String message, Object source) {

環境:SpringBoot3.2.5M0b28資訊網——每日最新資訊28at.com

1. 死鎖復現

1.1 自定義事件監聽

public class PackApplicationEvent extends ApplicationEvent {  private String message ;  public PackApplicationEvent(String message, Object source) {    super(source) ;    this.message = message ;  }  public String getMessage() {    return message ;  }}

自定義事件,接收消息及相關數據M0b28資訊網——每日最新資訊28at.com

1.2 自定義事件監聽

@Componentpublic class PackApplicationListener implements ApplicationListener<PackApplicationEvent> {  @Override  public void onApplicationEvent(PackApplicationEvent event) {    System.out.printf("接收到事件消息: %s, 數據: %s%n", event.getMessage(), event.getSource().toString()) ;    // TODO  }}

該事件監聽器只打印了信息。M0b28資訊網——每日最新資訊28at.com

1.3 發布事件

@Componentpublic class EventProcessor {  public EventProcessor(ApplicationEventPublisher eventPublisher) {    Thread t = new Thread(() -> {      eventPublisher.publishEvent(new PackApplicationEvent("自定義事件", EventProcessor.this));    });    t.start() ;    try {      System.out.println("線程啟動,等待執行完成...") ;      t.join() ;    } catch (InterruptedException e) {      System.err.printf("線程中斷: %s, 錯誤: %s%n", Thread.currentThread().getName(), e.getMessage()) ;    }  }}

該Bean在構造函數中新啟一個線程發布事件,同時通過join方法等待線程執行完成。M0b28資訊網——每日最新資訊28at.com

上面的程序運行后,發現輸出了上面的打印內容后應用沒有繼續運行。打印整個線程棧(通過jstack命令查看),如下:M0b28資訊網——每日最新資訊28at.com

圖片圖片M0b28資訊網——每日最新資訊28at.com

根據線程信息,main線程在創建EventProcessor對象時,會先持有DefaultSingletonBeanRegistry.singletonObjects這個ConcurrentHashMap對象鎖接著創建EventProcessor對象實例,在調用該對象的構造函數時,啟動新的線程Thread-1,該線程發布事件同時通過join方法等待T1這個線程完成,在發布事件時Spring容器會獲取所有的ApplicationListener,此時就會又創建PackApplicationListener對象,創建該對象同樣要獲取singletonObjects鎖對象,這樣就造成了死鎖。M0b28資訊網——每日最新資訊28at.com

主線程

圖片圖片M0b28資訊網——每日最新資訊28at.com

主線程創建EventProcessor對象。M0b28資訊網——每日最新資訊28at.com

Thread-1線程

圖片圖片M0b28資訊網——每日最新資訊28at.com

Thread-1線程獲取容器中的ApplicationListener類型的bean,該過程將執行到如下步驟:M0b28資訊網——每日最新資訊28at.com

圖片圖片M0b28資訊網——每日最新資訊28at.com

main線程持有singletonObjects鎖,Thread-1線程又期望獲取到該鎖,但是main線程還要等待Thread-1線程執行完成。這死鎖了。M0b28資訊網——每日最新資訊28at.com

以上是對死鎖的復現及原因進行了分析,接下來進行問題的解決。M0b28資訊網——每日最新資訊28at.com

2. 解決問題

2.1 解決方式1

不要在構造函數中發布事件,而是應該在所有的單例對象都創建完后再執行,也就是實現SmartInitializingSingleton接口,該接口對應的回調方法會在所有的單例bean都創建完以后執行,這樣就不會再出現deadlock問題。M0b28資訊網——每日最新資訊28at.com

@Componentpublic class EventProcessor implements SmartInitializingSingleton {  private final ApplicationEventPublisher eventPublisher ;  public EventProcessor(ApplicationEventPublisher eventPublisher) {    this.eventPublisher = eventPublisher ;  }  @Override  public void afterSingletonsInstantiated() {    Thread t = new Thread(() -> {      eventPublisher.publishEvent(new PackApplicationEvent("自定義事件", EventProcessor.this));    });    t.start() ;    try {      t.join() ;    } catch (InterruptedException e) {      System.err.printf("線程中斷: %s, 錯誤: %s%n", Thread.currentThread().getName(), e.getMessage()) ;    }  }}

這樣改造后容器能正常的啟動,同時事件也正常的發布&監聽。M0b28資訊網——每日最新資訊28at.com

afterSingletonsInstantiated方法的調用在如下:M0b28資訊網——每日最新資訊28at.com

public class DefaultListableBeanFactory {  public void preInstantiateSingletons() {    for (String beanName : beanNames) {      // 創建單例bean      getBean(beanName);    }    // 單例bean創建完成以后,執行afterSingletonsInstantiated回調方法    for (String beanName : beanNames) {      Object singletonInstance = getSingleton(beanName);      if (singletonInstance instanceof SmartInitializingSingleton smartSingleton) {        smartSingleton.afterSingletonsInstantiated();      }    }  }}

以上就不會在出現鎖問題。M0b28資訊網——每日最新資訊28at.com

2.2 解決方式2

升級Spring版本到Spring6.2(目前并沒有正式發布),你仍然可以使用6.2.0-SNAPSHOT版本,該版本通過多線程方式初始化Bean對象,這樣就不會出現deadlock問題。M0b28資訊網——每日最新資訊28at.com


M0b28資訊網——每日最新資訊28at.com

本文鏈接:http://www.www897cc.com/showinfo-26-93206-0.html警惕!SpringBoot錯誤發布事件,造成死鎖Deadlock

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

上一篇: 聊聊 Mybatis 動態 SQL

下一篇: 網易面試:SpringBoot如何開啟虛擬線程?

標簽:
  • 熱門焦點
Top 主站蜘蛛池模板: 肃宁县| 大姚县| 应城市| 油尖旺区| 石狮市| 唐河县| 陆川县| 宿迁市| 封丘县| 上栗县| 潍坊市| 华池县| 两当县| 赤城县| 青岛市| 科技| 蒲城县| 常熟市| 望奎县| 阳谷县| 偃师市| 芒康县| 蛟河市| 丽水市| 西宁市| 东台市| 循化| 澎湖县| 灌阳县| 来宾市| 新丰县| 石门县| 新津县| 哈巴河县| 永仁县| 南昌市| 彭阳县| 高清| 宜丰县| 永新县| 大化|