[김이준] Sprint11 #149

lkim0402 · 2025-10-24T08:11:38Z

기본 요구사항

Spring Event - 파일 업로드 로직 분리하기

BinaryContentStorage.put을 직접 호출하는 대신 BinaryContentCreatedEvent를 발행하세요.
- BinaryContentCreatedEvent를 정의하세요.
  - BinaryContent 메타 정보가 DB에 잘 저장되었다는 사실을 의미하는 이벤트입니다.
- 다음의 메소드에서 BinaryContentStorage를 호출하는 대신 BinaryContentCreatedEvent를 발행하세요.
  - UserService.create/update
  - MessageService.create
  - BinaryContentService.create
- ApplicationEventPublisher를 활용하세요.
이벤트를 받아 실제 바이너리 데이터를 저장하는 리스너를 구현하세요.
- 이벤트를 발행한 메인 서비스의 트랜잭션이 커밋되었을 때 리스너가 실행되도록 설정하세요.
- BinaryContentStorage를 통해 바이너리 데이터를 저장하세요.
바이너리 데이터 저장 성공 여부를 알 수 있도록 메타 데이터를 리팩토링하세요.
- BinaryContent에 바이너리 데이터 업로드 상태 속성(status)을 추가하세요.
- BinaryContent의 상태를 업데이트하는 메소드를 정의하세요.
  - 트랜잭션 전파 범위에 유의하세요.
바이너리 데이터 저장 성공 여부를 메타 데이터에 반영하세요.
- 성공 시 BinaryContent의 status를 SUCCESS로 업데이트하세요.
- 실패 시 BinaryContent의 status를 FAIL로 업데이트하세요.

Spring Event - 알림 기능 추가하기

채널에 새로운 메시지가 등록되거나 2)권한이 변경된 경우 이벤트를 발행해 알림을 받을 수 있도록 구현합니다.
채널에 새로운 메시지가 등록된 경우 알림을 받을 수 있도록 리팩토링하세요.
- MessageCreatedEvent를 정의하고 새로운 메시지가 등록되면 이벤트를 발행하세요.
- 사용자 별로 관심있는 채널의 알림만 받을 수 있도록 ReadStatus 엔티티에 채널 알림 여부 속성(notificationEnabled)을 추가하세요.
  - PRIVATE 채널은 알림 여부를 true로 초기화합니다.
  - PUBLIC 채널은 알림 여부를 false로 초기화합니다.
- 알림 여부를 수정할 수 있게 ReadStatusUpdateRequest를 수정하세요.
  - 알림이 활성화 되어 있는 경우
  - 알림이 활성화 되어 있지 않은 경우
사용자의 권한(Role)이 변경된 경우 알림을 받을 수 있도록 리팩토링하세요.
- RoleUpdatedEvent를 정의하고 권한이 변경되면 이벤트를 발행하세요.
알림 API를 구현하세요.
- NotificationDto를 정의하세요.
  - receiverId: 알림을 수신할 User의 id입니다.
- 알림 조회
  - 엔드포인트: GET /api/notifications
  - 요청
    - 헤더: 엑세스 토큰
  - 응답
    - 200 List
    - 401 ErrorResponse
  - 알림 확인
    - 엔드포인트: DELETE /api/notifications/{notificationId}
    - 요청
      - 헤더: 엑세스 토큰
    - 응답
      - 204 Void
      - 인증되지 않은 요청: 401 ErrorResponse
      - 인가되지 않은 요청: 403 ErrorResponse
        
        요청자 본인의 알림에 대해서만 수행할 수 있습니다.
      - 알림이 없는 경우: 404 ErrorResponse
알림이 필요한 이벤트가 발행되었을 때 알림을 생성하세요.
- 이벤트를 처리할 리스너를 구현하세요.
  - on(MessageCreatedEvent)
    - 해당 채널의 알림 여부를 활성화한 ReadStatus를 조회합니다.
    - 해당 ReadStatus의 사용자들에게 알림을 생성합니다.
    - 단, 해당 메시지를 보낸 사람은 알림 대상에서 제외합니다.
  - on(RoleUpdatedEvent)
    - 권한이 변경된 당사자에게 알림을 생성합니다.

비동기 적용하기

비동기를 적용하기 위한 설정(AsyncConfig) 클래스를 구현하세요.
- @EnableAsync 어노테이션을 활용하세요.
- TaskExecutor를 Bean으로 등록하세요.
- TaskDecorator를 활용해 MDC의 Request ID, SecurityContext의 인정 정보가 비동기 스레드에서도 유지되도록 구현하세요.
앞서 구현한 Event Listener를 비동기적으로 처리하세요.
- @async 어노테이션을 활용하세요.
동기 처리와 비동기 처리 간 성능 차이를 비교해보세요.
- 파일 업로드 로직에 의도적인 지연(Thread.sleep(…))을 발생시키세요.
- 메시지 생성 API의 실행 시간을 측정해보세요.
  - @timed 어노테이션을 메소드에 추가합니다.
  - Actuator 설정을 추가합니다.
  - /actuator/metrics/message.create.async 에서 측정된 시간을 확인할 수 있습니다.
- @EnableAsync를 활성화 / 비활성화 해보면서 동기 / 비동기 처리 간 응답 속도의 차이를 확인해보세요.

비동기 실패 처리하기

S3를 활용해 바이너리 데이터 저장 시 자동 재시도 매커니즘을 구축하세요.
- Spring Retry를 위한 환경을 구성하세요.
  - org.springframework.retry:spring-retry 의존성을 추가하세요.
  - @EnableRetry 어노테이션을 활용해 Spring Retry를 활성화 하세요.
- 바이너리 데이터를 저장하는 메소드에 @retryable 어노테이션을 사용해 재시도 정책(횟수, 대기 시간 등)을 설정하세요.
재시도가 모두 실패했을 때 대응 전략을 구축하세요.
- @recover 어노테이션을 활용하세요.
- 실패 정보를 관리자에게 통지하세요.
  - 실패 정보에는 추후 디버깅을 위해 필요한 정보를 포함하세요.
    - 실패한 작업 이름
    - MDC의 Request ID
    - 실패 이유 (예외 메시지)

캐시 적용하기

Caffeine 캐시를 위한 환경을 구성하세요.
- org.springframework.boot:spring-boot-starter-cache 의존성을 추가하세요.
- com.github.ben-manes.caffeine:caffeine 의존성을 추가하세요.
- application.yaml 설정 또는 Bean을 통해 캐시 Caffeine 캐시를 설정하세요.
@Cacheable 어노테이션을 활용해 캐시가 필요한 메소드에 적용하세요.
- 사용자별 채널 목록 조회
- 사용자별 알림 목록 조회
- 사용자 목록 조회
데이터 변경 시, 캐시를 갱신 또는 무효화하는 로직을 구현하세요.
- @CacheEvict, @cACHEpUT, CacheManager 등을 활용하세요.
- 예시:
  - 새로운 채널 추가/수정/삭제 → 채널 목록 캐시 무효화
  - 알림 추가/삭제 → 알림 목록 캐시 무효화
  - 사용자 추가/로그인/로그아웃 → 사용자 목록 캐시 무효화
캐시 적용 전후의 차이를 비교해보세요.
- 로그를 통해 SQL 실행 여부를 확인해보세요.
Spring Actuator를 활용해 캐시 관련 통계 지표를 확인해보세요.
- Caffein Spec에 recordStats 옵션을 추가하세요.
- /actuator/caches, /actuator/metrics/cache.* 를 통해 캐시 관련 데이터를 확인해보세요.

심화 요구사항

Spring Kafka 도입하기

Kafka 환경을 구성하세요.
- Docker Compose를 활용해 Kafka를 구동하세요.
- Spring Kafka 의존성을 추가하고, application.yml에 Kafka 설정을 추가하세요.
- Spring Event를 Kafka로 발행하는 리스너를 구현하세요.
  - NotificationRequiredEventListener는 비활성화하세요.
  - KafkaProduceRequiredEventListener를 구현하세요.
  - Spring Event를 Kafka 메시지로 변환해 전송하는 중계 구조입니다.
- Kafka Console을 통해 Kafka 이벤트가 잘 발행되는지 확인해보세요.
- Kafka 토픽을 구독해 알림을 생성하는 리스너를 구현하세요.

Redis Cache 도입하기

Redis 환경을 구성하세요.
- Docker Compose를 활용해 Redis를 구동하세요.
- Redis 의존성을 추가하고, application.yml에 Redis 설정을 추가하세요.
- 직렬화 설정을 위해 다음과 같이 Bean을 선언하세요.
DataGrip을 통해 Redis에 저장된 캐시 정보를 조회해보세요.

- repository 구현체를 application.yml 설정값을 통해 제어 - File*Repository 구현체의 파일을 저장할 디렉토리 경로를 application.yml 설정값을 통해 제어

This reverts commit 6e332e9.

This reverts commit 78cefb0.

This reverts commit 6284518.

This reverts commit 884162f.

This reverts commit 3d124ad.

This reverts commit e0752c4.

joonfluence · 2025-11-04T18:04:41Z

src/main/java/com/sprint/mission/discodeit/service/basic/BasicChannelService.java

+        .orElseThrow(() -> ChannelNotFoundException.withId(channelId));
+  }
+
+  @Cacheable(value = "userChannelsCache", key = "#userId")


캐시 설정

joonfluence · 2025-11-04T18:05:01Z

...main/java/com/sprint/mission/discodeit/event/Listener/NotificationRequiredTopicListener.java

+  private final ObjectMapper objectMapper;
+
+  @KafkaListener(topics = "discodeit.MessageCreatedEvent")
+  @CacheEvict(value = "userNotificationsCache", allEntries = true)


캐시 eviction 설정

joonfluence · 2025-11-04T18:05:20Z

src/main/java/com/sprint/mission/discodeit/service/basic/BasicBinaryContentService.java

+    );
+    binaryContentRepository.save(binaryContent);
+
+    publisher.publishEvent(new BinaryContentCreatedEvent(binaryContent.getId(), bytes));


이벤트 발행

joonfluence · 2025-11-04T18:05:29Z

src/main/java/com/sprint/mission/discodeit/event/Listener/BinaryContentListener.java

+  private final BinaryContentStorage binaryContentStorage;
+
+  @Async
+  @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)


이벤트 소비

joonfluence · 2025-11-04T18:05:39Z

src/main/java/com/sprint/mission/discodeit/event/Listener/BinaryContentListener.java

+      binaryContentStorage.put(event.id(), event.bytes());
+      binaryContentService.updateStatus(event.id(), BinaryContentStatus.SUCCESS);
+    } catch (Exception e) {
+      log.error("Binary Content 저장 실패: ", e);
+      binaryContentService.updateStatus(event.id(), BinaryContentStatus.FAIL);


상태 변경 처리

joonfluence · 2025-11-04T18:06:28Z

src/main/java/com/sprint/mission/discodeit/service/basic/BasicAuthService.java

+    jwtRegistry.invalidateJwtInformationByUserId(userId);
+
+    if (!pastRole.equals(newRole)) {
+      publisher.publishEvent(new RoleUpdatedEvent(pastRole, user));


이벤트 발행

joonfluence · 2025-11-04T18:06:53Z

...main/java/com/sprint/mission/discodeit/event/Listener/KafkaProduceRequiredEventListener.java

+  @Async
+  @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+  public void on(MessageCreatedEvent event) throws JsonProcessingException {
+    String payload = objectMapper.writeValueAsString(event);
+    kafkaTemplate.send("discodeit.MessageCreatedEvent", payload);
+  }
+
+  @Async
+  @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+  public void on(RoleUpdatedEvent event) throws JsonProcessingException {
+    String payload = objectMapper.writeValueAsString(event);
+    kafkaTemplate.send("discodeit.RoleUpdatedEvent", payload);
+
+  }
+
+  @Async
+  @EventListener
+  public void on(BinaryContentRecoverEvent event) throws JsonProcessingException {
+    String requestId = MDC.get("REQUEST_ID");
+    String payload = objectMapper.writeValueAsString(event);


카프카 이벤트 소비

joonfluence · 2025-11-04T18:07:24Z

src/main/java/com/sprint/mission/discodeit/config/AppConfig.java

+@Configuration
+@EnableJpaAuditing
+@EnableScheduling
+@EnableCaching
+@EnableRetry


Retry 설정은 됐으나 누락

joonfluence · 2025-11-04T18:08:12Z

src/main/java/com/sprint/mission/discodeit/controller/MessageController.java

+  @Timed("message.create.async")
+  @PostMapping(consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
+  public ResponseEntity<MessageDto> create(
+      @RequestPart("messageCreateRequest") @Valid MessageCreateRequest messageCreateRequest,
+      @RequestPart(value = "attachments", required = false) List<MultipartFile> attachments
+  ) {
+    log.info("메시지 생성 요청: request={}, attachmentCount={}",
+        messageCreateRequest, attachments != null ? attachments.size() : 0);
+
+    List<BinaryContentCreateRequest> attachmentRequests = Optional.ofNullable(attachments)


Timed 설정됨

joonfluence · 2025-11-04T18:08:58Z

src/main/java/com/sprint/mission/discodeit/config/CacheConfig.java

+
+  // CacheConfig
+  @Bean
+  public RedisCacheConfiguration redisCacheConfiguration(ObjectMapper objectMapper) {


레디스 캐시 설정

lkim0402 added 30 commits June 26, 2025 15:11

추가 기능 요구사항 완료 - 모든 Service DTO 응답 변환 완료, 테스팅 완료

8023d28

심화 기능 완료

8379cb9

- repository 구현체를 application.yml 설정값을 통해 제어 - File*Repository 구현체의 파일을 저장할 디렉토리 경로를 application.yml 설정값을 통해 제어

심화 기능 완료

b3f6eae

- repository 구현체를 application.yml 설정값을 통해 제어 - File*Repository 구현체의 파일을 저장할 디렉토리 경로를 application.yml 설정값을 통해 제어

심화 코드 버그 수정

499449b

심화 코드 버그 수정

96b9880

마지막 코드, 버그 수정

5e8be41

마지막 코드, 버그 수정

801a1cc

@value 대신 @ConfigurationProperties으로 리팩토링

7f3d498

@value 대신 @ConfigurationProperties으로 리팩토링

a84a75a

멘토님 피드백 반영

2878417

멘토님 피드백 반영

687a5da

File*Repository 리소스 누수 버그 고침

6e332e9

File*Repository 리소스 누수 버그 고침

78cefb0

Merge branch '김이준' into leejun/sprint3

0a2f744

Merge branch '김이준' into leejun/sprint3

b5dee1e

Merge branch '김이준' into leejun/sprint3

17cac6f

웹 API 요구사항 완료

1f97eeb

웹 API 요구사항 완료

a72d2be

웹 API 요구사항 완료

818eb31

Revert "File*Repository 리소스 누수 버그 고침"

6284518

This reverts commit 6e332e9.

Revert "File*Repository 리소스 누수 버그 고침"

884162f

This reverts commit 6e332e9.

Revert "File*Repository 리소스 누수 버그 고침"

3d124ad

This reverts commit 78cefb0.

Reapply "File*Repository 리소스 누수 버그 고침"

cf4eb61

This reverts commit 6284518.

Reapply "File*Repository 리소스 누수 버그 고침"

d6b1a28

This reverts commit 884162f.

Reapply "File*Repository 리소스 누수 버그 고침"

befbd93

This reverts commit 3d124ad.

인덴트, 주석 수정

73c931d

인덴트, 주석 수정

93819ae

인덴트, 주석 수정

85d99a1

주석 처리

f104ddc

주석 처리

f6b987a

lkim0402 added 20 commits October 22, 2025 15:19

완료 binarycontent 고도화

1cb5f81

추가 sendNotification endpoint

16617ad

추가 알람 이벤트 리스너

9b65eb9

완료 알림

d8e1893

구현 권한 변경 알람

bac6325

async 구현

099270a

버그 고침 binary content

ca78b4f

오류 고침 시도

e42a979

Async 어노테이션 추가

468c790

코드정리

2ea29fb

추가 cacheable

a10aefb

추가 cacheEvict 어노테이션

e51eac7

캐시 적용 완료

f832101

구현 비동기 실패 처리

966c9c4

추가 mdc request id

7b41d5d

추가 kafka

c4744d1

추가 redis

9f26f68

코드 정리

269d582

추가 base code

e0752c4

Revert "추가 base code"

373bcc5

This reverts commit e0752c4.

joonfluence reviewed Nov 4, 2025

View reviewed changes

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

[김이준] Sprint11 #149

[김이준] Sprint11 #149

Uh oh!

lkim0402 commented Oct 24, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

joonfluence Nov 4, 2025

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

[김이준] Sprint11 #149

Are you sure you want to change the base?

[김이준] Sprint11 #149

Uh oh!

Conversation

lkim0402 commented Oct 24, 2025

기본 요구사항

Spring Event - 파일 업로드 로직 분리하기

Spring Event - 알림 기능 추가하기

비동기 적용하기

비동기 실패 처리하기

캐시 적용하기

심화 요구사항

Spring Kafka 도입하기

Redis Cache 도입하기

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants