ホームページ  >  記事  >  Java  >  Springboot でタスクを実行するためにリスニング スレッドを開始する方法

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

WBOY
WBOY転載
2023-05-21 20:28:121204ブラウズ

    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 でタスクを実行するためにリスニング スレッドを開始する方法

    以上がSpringboot でタスクを実行するためにリスニング スレッドを開始する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

    声明:
    この記事はyisu.comで複製されています。侵害がある場合は、admin@php.cn までご連絡ください。