springboot에서 작업을 수행하기 위해 청취 스레드를 시작하는 방법-java지도 시간-php.cn

springboot에서 작업을 수행하기 위해 청취 스레드를 시작하는 방법

WBOY

풀어 주다： 2023-05-21 20:28:12

앞으로

1289명이 탐색했습니다.

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 주석을 사용하여 비동기 처리를 구현할 수 있으며 이벤트 청취에는 두 가지 유형이 있습니다. 동기식 및 비동기식 방법을 사용할 수 있습니다.

이벤트의 일반 단계

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: 메인 스타트업 수업을 시작하고 프린팅 테스트를 진행합니다.

두 번째 유형

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에서 작업을 수행하기 위해 청취 스레드를 시작하는 방법