채널톡 아이콘

인프런 커뮤니티 질문&답변

gudwlszz님의 프로필 이미지

작성한 질문수 1

스프링부트로 직접 만들면서 배우는 대규모 시스템 설계 - 게시판

Transactional Outbox 테스트

이벤트 폴링이 안되시는 분들

해결된 질문

작성

·

71

·

수정됨

0

스프링 최신버전으로 하신분들은

messageRelayPublishPendingEventExecutor가 Executer를 반환하면 안되고 TaskScheduler를 반환해야 한다고 하네요.

@Bean
public TaskScheduler messageRelayPublishPendingEventExecutor() {
    ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
    scheduler.setPoolSize(1);
    scheduler.setThreadNamePrefix("task-scheduler-");
    scheduler.initialize();
    return scheduler;
}

이렇게 작성하시고

ArticleApplication에 @EnableScheduling을 추가해주시면 이벤트가 잘 폴링됩니다.

 

@EntityScan(basePackages = "kuke.board")
@SpringBootApplication
@EnableJpaRepositories(basePackages = "kuke.board")
@EnableScheduling
public class ArticleApplication {
    public static void main(String[] args) {
        SpringApplication.run(ArticleApplication.class, args);
    }
}

답변 2

0

쿠케님의 프로필 이미지
쿠케
지식공유자

최신 버전에서는 미동작하는 부분이 있나보군요..! 지식 공유 감사합니다~!!

0

인프런 AI 인턴님의 프로필 이미지

안녕하세요, 인프런 AI 인턴입니다. gudwlszz님.

Spring Boot에서 이벤트를 폴링할 때 TaskScheduler를 사용해야 하는 이유와 이를 설정하는 방법에 대해 질문해 주셨습니다. 최신 버전의 Spring Boot에서는 스케줄링을 위해 Executor 대신 TaskScheduler를 사용하는 것이 권장됩니다. 이는 스케줄링 작업을 효율적으로 관리하고, 특정 인터페이스를 사용하여 더 나은 기능 확장성을 제공하기 때문입니다.

해결 방법

  1. TaskScheduler 설정:

    • TaskScheduler는 스케줄링 작업을 위한 스레드 풀을 관리합니다. 이를 설정하는 방법은 아래와 같습니다:
    @Bean
    public TaskScheduler messageRelayPublishPendingEventExecutor() {
       ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
       scheduler.setPoolSize(1);
       scheduler.setThreadNamePrefix("task-scheduler-");
       scheduler.initialize();
       return scheduler;
    }
    
  2. 스케줄링 활성화:

    • 스프링 애플리케이션에서 스케줄링을 활성화하려면 @EnableScheduling 어노테이션을 추가해야 합니다. 이는 아래와 같이 ArticleApplication 클래스에 적용할 수 있습니다:
    @EntityScan(basePackages = "kuke.board")
    @SpringBootApplication
    @EnableJpaRepositories(basePackages = "kuke.board")
    @EnableScheduling
    public class ArticleApplication {
       public static void main(String[] args) {
           SpringApplication.run(ArticleApplication.class, args);
       }
    }
    

이러한 설정을 통해 스케줄링 태스크를 효과적으로 처리하고, 스프링 애플리케이션 내에서 이벤트 폴링을 정상적으로 수행할 수 있게 됩니다.

관련 질문으로 유사한 구현 방법이나 추가적인 팁을 찾으실 수 있습니다. 아래 는 추가적인 자료를 제공하는 링크입니다:

저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다. 현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏 추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.