欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot實(shí)現(xiàn)自定義事件的方法詳解

 更新時(shí)間：2022年06月22日 09:03:41   作者：IT利刃出鞘  
這篇文章將用實(shí)例來和大家介紹一下如何在SpringBoot中自定義事件來使用觀察者模式。文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)SpringBoot有一定的幫助，需要的可以參考一下

簡介

說明

本文用實(shí)例來介紹如何在SpringBoot中自定義事件來使用觀察者模式。

事件的順序

可使用實(shí)現(xiàn)Ordered接口的方式，調(diào)整監(jiān)聽器順序。

注意：必須是同時(shí)實(shí)現(xiàn) ApplicationListener<MyEvent>,Ordered這樣的方法才能控制順序。

下邊幾種都是無法控制順序的：

  • @Component+@EventListerner+實(shí)現(xiàn)Ordered
  • 實(shí)現(xiàn) ApplicationListener<MyEvent>+@Order

步驟1：自定義事件

通過繼承ApplicationEvent來自定義事件。

構(gòu)造器的參數(shù)為該事件的相關(guān)數(shù)據(jù)對(duì)象，監(jiān)聽器可以獲取到該數(shù)據(jù)對(duì)象，進(jìn)而進(jìn)行相關(guān)邏輯處理。

package com.example.event;
 
import org.springframework.context.ApplicationEvent;
 
public class MyEvent extends ApplicationEvent {
 
    public MyEvent(Object source) {
        super(source);
    }
 
}

步驟2：自定義監(jiān)聽器

方案1：ApplicationListener

法1：@EventListener

監(jiān)聽單個(gè)事件

package com.example.event;
 
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
 
public class MyListener {
    @EventListener
    public void abc(MyEvent event) {
        System.out.println("監(jiān)聽器：     " + "MyListener");
        System.out.println("  線程：     " + Thread.currentThread().getName());
        System.out.println("  事件：     " + event);
        System.out.println("  事件的數(shù)據(jù)：" + event.getSource());
    }
}

或者

package com.example.event;
 
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
 
public class MyListener {
    @EventListener({MyEvent.class})
    public void abc(ApplicationEventevent) {
        System.out.println("監(jiān)聽器：      " + "MyListener");
        System.out.println("  線程：      " + Thread.currentThread().getName());
        System.out.println("  事件：      " + event);
        System.out.println("  事件的數(shù)據(jù)： " + event.getSource());
    }
}

上邊的辦法比較好，因?yàn)椴恍枰愋娃D(zhuǎn)換了。直接就能確定是MyEvent類型。

監(jiān)聽多個(gè)事件

事件進(jìn)來之后，可以使用if(event instanceOf MyEvent.class)來判斷是哪種事件。

package com.example.event;
 
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
 
@Component
public class MyListener {
    @EventListener({MyEvent.class, MyEvent2.class})
    public void abc(ApplicationEvent event) {
        System.out.println("監(jiān)聽器：      " + "MyListener");
        System.out.println("  所在線程：  " + Thread.currentThread().getName());
        System.out.println("  事件：      " + event);
        System.out.println("  事件的數(shù)據(jù)：" + event.getSource());
    }
}

監(jiān)聽所有ApplicationEvent

若使用這種寫法，啟動(dòng)時(shí)會(huì)打印很多Spring自帶的事件。任意ApplicationEvent都會(huì)進(jìn)入這里邊。

package com.example.event;
 
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
 
@Component
public class MyListener {
    @EventListener
    public void abc(ApplicationEvent event) {
        System.out.println("監(jiān)聽器：     " + "MyListener");
        System.out.println("  所在線程： " + Thread.currentThread().getName());
        System.out.println("  事件：     " + event);
        System.out.println("  事件的數(shù)據(jù)：" + event.getSource());
    }
}

法2：實(shí)現(xiàn)ApplicationListener<T>接口

public class MyListener implements ApplicationListener<MyEvent>{
 
    public void onApplicationEvent(MyEvent event){
        System.out.println("監(jiān)聽器：     " + "MyListener");
        System.out.println("  所在線程： " + Thread.currentThread().getName());
        System.out.println("  事件：     " + event);
        System.out.println("  事件的數(shù)據(jù)：" + event.getSource());
    }
}

方案2：SmartApplicationListener

源碼如下

public interface SmartApplicationListener extends ApplicationListener<ApplicationEvent>, Ordered {
    boolean supportsEventType(Class<? extends ApplicationEvent> var1);
 
    default boolean supportsSourceType(@Nullable Class<?> sourceType) {
        return true;
    }
 
    default int getOrder() {
        return 2147483647;
    }
}

supportsEventType：支持的事件的類型

supportsSourceType：支持的數(shù)據(jù)的類型

getOrder：2147483641：是2^31-1，也就是32位的int的最大正數(shù) 。

示例

事件

package com.example.event;
 
import org.springframework.context.ApplicationEvent;
 
public class MyEvent extends ApplicationEvent {
 
    public MyEvent(Object source) {
        super(source);
    }
 
}

監(jiān)聽器1

package com.example.event;
 
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.SmartApplicationListener;
import org.springframework.stereotype.Component;
 
@Component
public class MyListener implements SmartApplicationListener {
 
    @Override
    public boolean supportsEventType(Class<? extends ApplicationEvent> aClass) {
        return aClass == MyEvent.class;
    }
 
    @Override
    public boolean supportsSourceType(Class<?> sourceType) {
        return sourceType == String.class;
    }
 
    @Override
    public int getOrder() {
        return 2;
    }
 
    @Override
    public void onApplicationEvent(ApplicationEvent event) {
        System.out.println("監(jiān)聽器：      " + "MyListener");
        System.out.println("  所在線程：  " + Thread.currentThread().getName());
        System.out.println("  事件：      " + event);
        System.out.println("  事件的數(shù)據(jù)：" + event.getSource());
        System.out.println("  是MyEvent？：" + (event instanceof MyEvent));
    }
}

監(jiān)聽器2

package com.example.event;
 
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.SmartApplicationListener;
import org.springframework.stereotype.Component;
 
@Component
public class MyListener2 implements SmartApplicationListener {
 
    @Override
    public boolean supportsEventType(Class<? extends ApplicationEvent> aClass) {
        return aClass == MyEvent.class;
    }
 
    @Override
    public boolean supportsSourceType(Class<?> sourceType) {
        return sourceType == String.class;
    }
 
    @Override
    public int getOrder() {
        return 1;
    }
 
    @Override
    public void onApplicationEvent(ApplicationEvent event) {
        System.out.println("監(jiān)聽器：      " + "MyListener2");
        System.out.println("  所在線程：  " + Thread.currentThread().getName());
        System.out.println("  事件：      " + event);
        System.out.println("  事件的數(shù)據(jù)：" + event.getSource());
        System.out.println("  是MyEvent？：" + (event instanceof MyEvent));
    }
}

發(fā)布器

package com.example.event;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
 
@Component
public class MyPublisher {
    @Autowired
    ApplicationContext applicationContext;
 
    public void myPublish(String message) {
        System.out.println("發(fā)布器所在線程：" + Thread.currentThread().getName());
        applicationContext.publishEvent(new MyEvent(message));
    }
}

測試

package com.example.controller;
 
import com.example.event.MyPublisher;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class HelloController {
    @Autowired
    MyPublisher myPublisher;
 
    @GetMapping("/test1")
    public String test1() {
        myPublisher.myPublish("Hello");
        return "test1 success";
    }
 
}

啟動(dòng)后，訪問：http://localhost:8080/test1

后端輸出：

發(fā)布器所在線程：http-nio-8080-exec-2
監(jiān)聽器：      MyListener2
  所在線程：  http-nio-8080-exec-2
  事件：      com.example.event.MyEvent[source=Hello]
  事件的數(shù)據(jù)：Hello
  是MyEvent？：true
監(jiān)聽器：      MyListener
  所在線程：  http-nio-8080-exec-2
  事件：      com.example.event.MyEvent[source=Hello]
  事件的數(shù)據(jù)：Hello
  是MyEvent？：true

如果將監(jiān)聽器的實(shí)現(xiàn)的Ordered順序顛倒，則輸出結(jié)果如下：

發(fā)布器所在線程：http-nio-8080-exec-1
監(jiān)聽器：      MyListener
  所在線程：  http-nio-8080-exec-1
  事件：      com.example.event.MyEvent[source=Hello]
  事件的數(shù)據(jù)：Hello
  是MyEvent？：true
監(jiān)聽器：      MyListener2
  所在線程：  http-nio-8080-exec-1
  事件：      com.example.event.MyEvent[source=Hello]
  事件的數(shù)據(jù)：Hello
  是MyEvent？：true

步驟3：注冊(cè)監(jiān)聽器

方式適用范圍能否搭配@Async注解，進(jìn)行異步監(jiān)聽
@Component所有監(jiān)聽器能
application.yml中添加配置實(shí)現(xiàn)ApplicationListener<T>接口的監(jiān)聽器不能
啟動(dòng)類中注冊(cè)實(shí)現(xiàn)ApplicationListener<T>接口的監(jiān)聽器不能

法1：@Component（適用于所有監(jiān)聽器）

package com.example.event;
 
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
 
@Component
public class MyListener {
    @EventListener
    public void abc(MyEvent event) {
        System.out.println("監(jiān)聽器：" + "MyListener");
        System.out.println("線程：" + Thread.currentThread().getName());
        System.out.println("事件：" + event);
        System.out.println("事件的數(shù)據(jù)：" + event.getSource());
    }
}

package com.example.event;
 
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
 
@Component
public class MyListener2 implements ApplicationListener<MyEvent> {
 
    @Override
    public void onApplicationEvent(MyEvent event) {
        System.out.println("監(jiān)聽器：" + "MyListener2");
        System.out.println("線程：" + Thread.currentThread().getName());
        System.out.println("事件：" + event);
        System.out.println("事件的數(shù)據(jù)：" + event.getSource());
    }
}

法2：application.yml中添加配置

只適用于實(shí)現(xiàn)ApplicationListener<T>接口的監(jiān)聽器

context:
  listener:
    classes: com.example.event.MyListener,com.example.event.MyListener2

法3：啟動(dòng)類中注冊(cè)

只適用于實(shí)現(xiàn)ApplicationListener<T>接口的監(jiān)聽器

package com.example;
 
import com.example.event.MyListener;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
 
@SpringBootApplication
public class DemoApplication {
    public static void main(String[] args) {
        // 原來是這樣的：SpringApplication.run(DemoApplication.class, args);
        ConfigurableApplicationContext context = SpringApplication.run(DemoApplication.class, args);
        context.addApplicationListener(new MyListener());
    }
}

步驟4：發(fā)布事件

法1：注入ApplicationContext，調(diào)用其publishEvent方法

package com.example.event;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
 
@Component
public class MyPublisher {
    @Autowired
    ApplicationContext applicationContext;
 
    public void myPublish(String message) {
        applicationContext.publishEvent(new MyEvent(message));
    }
}

法2：啟動(dòng)類中發(fā)布

package com.example;
 
import com.example.event.MyEvent;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
 
@SpringBootApplication
public class DemoApplication {
    public static void main(String[] args) {
        //原來是：SpringApplication.run(DemoApplication.class, args);
        ConfigurableApplicationContext context =SpringApplication.run(DemoApplication.class, args);
        context.publishEvent(new MyEvent("Hello"));
    }
}

以上就是SpringBoot實(shí)現(xiàn)自定義事件的方法詳解的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot自定義事件的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

相關(guān)文章

  • 記一次線程爆滿導(dǎo)致服務(wù)器崩潰的問題排查及解決

    記一次線程爆滿導(dǎo)致服務(wù)器崩潰的問題排查及解決

    這篇文章主要介紹了記一次線程爆滿導(dǎo)致服務(wù)器崩潰的問題排查及解決，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2022-10-10
  • Java jdbc批量多線程讀取CVS文件入庫

    Java jdbc批量多線程讀取CVS文件入庫

    這篇文章主要為大家詳細(xì)介紹了Java jdbc批量多線程讀取CVS文件入庫，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2019-08-08
  • Java this、final等關(guān)鍵字總結(jié)

    Java this、final等關(guān)鍵字總結(jié)

    這篇文章主要對(duì)java中this、final等關(guān)鍵字進(jìn)行了總結(jié),需要的朋友可以參考下
    2017-04-04
  • Spring中@Conditional注解的用法

    Spring中@Conditional注解的用法

    這篇文章主要介紹了Spring中@Conditional注解的用法,@Conditional是Spring4新提供的注解,它的作用是按照一定的條件進(jìn)行判斷,滿足條件給容器注冊(cè)bean,需要的朋友可以參考下
    2024-01-01
  • java中hibernate二級(jí)緩存詳解

    java中hibernate二級(jí)緩存詳解

    本篇文章中主要介紹了java中hibernate二級(jí)緩存詳解，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2017-05-05
  • 深入解析反編譯字節(jié)碼文件中的代碼邏輯JVM中的String操作

    深入解析反編譯字節(jié)碼文件中的代碼邏輯JVM中的String操作

    這篇文章主要介紹了深入解析反編譯字節(jié)碼文件中的代碼邏輯JVM中的String操作,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-10-10
  • Java異常ClassCastException的解決

    Java異常ClassCastException的解決

    這篇文章主要介紹了Java異常ClassCastException的解決,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-11-11
  • Java 替換字符串中的回車換行符的方法

    Java 替換字符串中的回車換行符的方法

    Java 替換字符串中的回車換行符的方法，需要的朋友可以參考一下
    2013-03-03
  • Java貪心算法超詳細(xì)講解

    Java貪心算法超詳細(xì)講解

    人之初性本善，但是隨著自身的經(jīng)歷、生活環(huán)境等因素的影響，人逐漸會(huì)生出貪嗔癡。實(shí)際上不光人有貪念，我們的算法也會(huì)有貪念，今天就和大家介紹下一個(gè)有貪念的算法模型---貪心算法，看看一個(gè)算法是怎么產(chǎn)生貪念的
    2022-05-05
  • Java深入學(xué)習(xí)圖形用戶界面GUI之創(chuàng)建窗體

    Java深入學(xué)習(xí)圖形用戶界面GUI之創(chuàng)建窗體

    圖形編程中，窗口是一個(gè)重要的概念，窗口其實(shí)是一個(gè)矩形框，應(yīng)用程序可以使用其從而達(dá)到輸出結(jié)果和接受用戶輸入的效果，學(xué)習(xí)了GUI就讓我們用它來創(chuàng)建一個(gè)窗體
    2022-05-05

最新評(píng)論