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 アノテーションを使用して非同期処理を実装できます。イベント リスニングには同期と非同期の 2 つのメソッドがあります。
1: イベントを定義します。
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: メインのスタートアップ クラスを開始し、印刷テストを実行します。 2 番目のタイプ #1: 最初のタイプと同じ 12: リスナーを作成します。
/** *第二种:打上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(); } }3 番目のタイプ
すべてアノテーションを使用します
1: 最初のタイプと同じ 12: リスナーを作成します。/** *第三种:采用@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 中国語 Web サイトの他の関連記事を参照してください。