public class StartApplicationListener implements ApplicationListener<ContextRefreshedEvent> {
@Override
public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
ApplicationContext applicationContext = contextRefreshedEvent.getApplicationContext();
ApplicationContext parent = applicationContext.getParent();
if (parent == null) {
CacheManager cacheManager = applicationContext.getBean(CacheManager.class);
Cache cache = cacheManager.getCache(MsConstants.NODE_CACHE_NAME);
new Thread(new Runnable() {
@Override
public void run() {
//代码
}
}).start();
}
}public static void main(String[] args) {
SpringApplication app = new SpringApplication(FigureServerApplication.class);
app.addListeners(new StartApplicationListener());
app.run(args);
}在Spring Boot專案中，您可以使用註解@Async來實現非同步處理，而事件監聽有同步和非同步兩種方式可供選擇。
#1：定義一個事件。
2: 建立一個監聽器。
3：確保監聽器在容器內。
4：發布事件，進行測試。
廢話不多說，簡單敘述幾個不同方式的demo。
首先，我們先建立一個springboot專案。
1：定義一個事件，需要繼承ApplicationEvent
public class MyEvent extends ApplicationEvent {
public MyEvent(Object source) {
super(source);
System.out.println("我是一个事件，目前在事件的构造器内");
}
}2：建立一個監聽器。直接實作ApplicationListener接口，重寫其中onApplicationEvent方法.
public class MyEventListener implements ApplicationListener<MyEvent> {
@Override
public void onApplicationEvent(MyEvent event) {
System.out.println("现在开始执行监听器中的内容,我是直接实现ApplicationListener接口的方式进行的");
System.out.println("event.getSource() = " + event.getSource());
}
}3：將監聽器手動新增進應用程式容器內，並進行發布事件。
@SpringBootApplication
public class EventTestApplication {
public static void main(String[] args) {
// SpringApplication.run(EventTestApplication.class, args);
//第一种：自己手动将监听器添加到application中
SpringApplication application = new SpringApplication(EventTestApplication.class);
//添加监听器
application.addListeners(new MyEventListener());
ConfigurableApplicationContext context = application.run(args);
//进行发布事件
context.publishEvent(new MyEvent("Event数据源"));
context.close();
}
}4：啟動主啟動類，進行列印測試。
1：同第一種的1
2：建立一個監聽器。
/**
*第二种：打上Compoent注解， 将事件监听器自动加入到应用容器中
* 这种方式不需要手动加入到容器中。
* */
@Component
public class MyEventListener2 implements ApplicationListener<MyEvent> {
@Override
public void onApplicationEvent(MyEvent event) {
System.out.println("现在开始执行监听器中的内容,我是打Compoent注解的方式进行的");
System.out.println("event.getSource() = " + event.getSource());
}
}3：發布事件，後續進行啟動類別測試即可。
@SpringBootApplication
public class EventTestApplication {
public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(EventTestApplication.class, args);
//发布事件
context.publishEvent(new MyEvent("source"));
context.close();
}
}全部採用註解的方式
1：同第一種的1
2：創建一個監聽器。
/**
*第三种:采用@EventListener注解的方式，不需要在类上实现ApplicationListener接口。
* 直接采用的是通过注解，将方法标识为一个监听器。
* */
@Component
public class MyEventListener3 {
@Async//异步注解。开启一个新线程。 去掉此注解则会变成同步监听。
@EventListener(classes = MyEvent.class)
public void TestListener(MyEvent myEvent){
System.out.println("我是@EventListener注解的方式实现的监听器");
System.out.println("myEvent.getSource() = " + myEvent.getSource());
}
}3：發布事件，後續進行啟動類別測試即可。
@SpringBootApplication
public class EventTestApplication {
public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(EventTestApplication.class, args);
//发布事件
context.publishEvent(new MyEvent("source"));
context.close();
}
}下面是程式碼的結構圖：
以上是springboot怎麼開啟一個監聽執行緒執行任務的詳細內容。更多資訊請關注PHP中文網其他相關文章！
