Springboot でタスクを実行するためにリスニング スレッドを開始する方法

springboot はタスクを実行するためにリスニング スレッドを開始します

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);
}

springboot でのリスニング イベントの作成プロセス

Spring Boot プロジェクトでは、 @Async アノテーションを使用して非同期処理を実装できます。イベント リスニングには同期と非同期の 2 つのメソッドがあります。

イベントの一般的な手順

• 1: イベントを定義します。

• #2: リスナーを作成します。

• 3: リスナーがコンテナ内にあることを確認してください。

• 4: テスト用にイベントを公開します。

早速、いくつかの異なるメソッドのデモについて簡単に説明しましょう。

まず、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: メインのスタートアップ クラスを開始し、印刷テストを実行します。

2 番目のタイプ

#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();
    }
}

3 番目のタイプ

すべてアノテーションを使用します

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 中国語 Web サイトの他の関連記事を参照してください。