feat: Redis Stream 연동을 위한 기반 코드 작성 #294
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
- RedisStreamConsumer 소비자 클래스입니다.
- RedisStream에서 메시지를 읽고 pending 상태로 만듭니다.
- RedisOperator는 redis의 명령을 추상화하여 다른 클래스에서 쉽게 사용할 수 있도록합니다.
- RedisStreamConsumer에서의 streamkey, consumer group name을 application.yaml에서 관리하도록 변경합니다.
### LazyAuctioneer - 경매 입찰 과정을 비동기로 나중에 처리하는 작업을 실행하기 위한 클래스입니다. ### AuctionPurchaseRequestMessage 데이터 클래스 - 경매 입찰 프로세스에 필요한 최소한의 데이터를 가지고 있는 데이터 클래스입니다.
- RedisStreamConsumer로 부터 Stream에 필요한 정보를 조회하도록 변경하였습니다. - streamKey, consumerGroupName, consumerName이 config에 추가되었습니다.
- 1분 이상 미처리 상태인 메시지를 처리하는 스케줄러를 구현하였습니다.
…/292-redis-stream
chhs2131
reviewed
Aug 24, 2024
Comment on lines
+5
to
+12
| public record AuctionPurchaseRequestMessage( | ||
| String requestId, | ||
| Long buyerId, | ||
| Long auctionId, | ||
| Long price, | ||
| Long quantity, | ||
| LocalDateTime requestTime | ||
| ) { |
There was a problem hiding this comment.
스트림으로 보낼 구매 요청 메세지를 이곳에 담는군요..! requestId는 UUID! 좋습니다!
chhs2131
reviewed
Aug 24, 2024
Comment on lines
+28
to
+34
| @Override | ||
| public void onMessage(MapRecord<String, Object, Object> message) { | ||
| log.info("MessageId: {}", message.getId()); | ||
| log.info("Stream: {}", message.getStream()); | ||
| log.info("Body: {}", message.getValue()); | ||
| redisOperator.acknowledge(redisStreamConfig.getConsumerGroupName(), message); | ||
| } |
There was a problem hiding this comment.
해당 메서드에서 RedisStream을 통해 전달된 메세지를 확인하고,
메시지에 맞는 로직을 호출한 뒤 정상처리되면 redisOperator.ack를 보내는 식으로 동작하는 것인가요?!
- 테스트 환경에서만 적용되는 값만 치환해서 사용할 수 있도록 application.yaml을 application-test.yaml으로 변경 - ServiceTest, RepositoryTest 프로파일 test 적용
chhs2131
previously approved these changes
Aug 25, 2024
# Conflicts: # src/main/java/com/wootecam/luckyvickyauction/core/auction/service/auctioneer/BasicAuctioneer.java # src/main/java/com/wootecam/luckyvickyauction/core/auction/service/auctioneer/LettuceLockAuctioneerProxy.java # src/main/java/com/wootecam/luckyvickyauction/core/auction/service/auctioneer/RedissonLockAuctioneerProxy.java
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
📄 Summary
LazyAuctioneer생성RedisStreamConsumer생성PendingMessageConsumer생성📝 Reference
Spring data redis : stream 문서
누군가의 Spring boot 연동 블로그
Redis Stream 관련 공식 문서
close #292