inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

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

Transactional Outbox 테스트

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

해결된 질문

168

gudwlszz

작성한 질문수 1

1

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

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

java mysql spring-boot kafka redis

답변 2

1

쿠케

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

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

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

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

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

@Version 어노테이션이 붙은 필드는 낙관적 락이든 비관적 락이든 업데이트가 됩니다.

0

31

1

consumer에서 에러가 발생할 경우 데이터 유실 문의

0

49

2

게시글 테스트 데이터 삽입

0

51

2

정렬, 필터, 검색 등의 조건이 붙을 경우 최적화할 수 있는 방법이 무엇이 있을까요?

0

104

2

좋아요 기능 정합성 보장 방법

0

98

2

좋아요 동시성처리 최적의 선택?

1

137

2

프론트엔드 msa 환경 api 주소 통합? 과 서버끼리 통신 방식에대해

0

92

2

안녕하세요 무한스크롤 강의듣다가 질문이 있습니다.

0

61

1

조회수 조회 로직 질문

1

67

2

비로그인 유저도 어뷰징 방지 정책

1

73

2

CommentServiceTest의 테스트 로직 질문

0

54

2

무한 스크롤 방식에서 페이지 번호 방식 쿼리의 문제점 의문

1

74

2

path 쿼리 관련 질문드립니다!

0

60

2

antigravity 에디터를 쓰신다면 종료해주세요

1

123

0

프로젝트 구조

0

88

2

article_like_count api test

0

79

2

이벤트 페이로드 객체의 생성 방식이 팩토리 메서드 패턴이 아닌 빌더 패턴인 이유가 궁금합니다!.

0

104

2

[33. 좋아요 수 구현] 에서 테스트 하는 화면 동시성 문제

0

92

2

findByPath에서 articleId로도 검색을 해야 할 것 같아요.

0

94

3

jpa ddl-auto none을 하는 이유와 join 방법

0

97

2

팩터리 메소드와 response 객체 사용 이유가 궁금합니다!

0

91

2

커서 기반 페이지네이션 과 무한 스크롤링

0

111

2

게시글 생성 로직에서 오류 발생시 redis 게시글 수 되돌리기

0

97

2

멀티 모듈이 아닌 MSA 환경에서 common

0

158

2