분류 전체보기

카프카를 알아야 하는 이유?카프카 말고도 분산 메세징 시스템은 AWS의 키네시스 등 비숫한 게 많다. 하지만 보편적으로 사용되는 시스템이기에 알아두면 다른 시스템도 이해하기 쉬워진다다음과 같은 효과를 기대할 수 있음대용량 처리고가용성메세지 유실 방지 등 다양한 기능메세지를 받는 서비스가 가용하지 않을 때 카프카가 그 메시지를 가지고 있다가 가용할 때 메세지를 다시 전송하는 매커니즘을 가지고 있음카프카의 구성 요소프로듀서와 컨슈머프로듀서는 메세지를 카프카 시스템에 발행하는 서비스컨슈머는 카프카 시스템에 발행된 메세지를 읽어오는 서비스오프셋은 컨슈머가 어디까지 메세지를 읽었는지를 기록해둔 데이터주문 서비스, 결제 서비스가 있고 주문을 완료하면 결제가 일어나야 한다고 할 때 카프카가 중간에서 메세지를 중계하면..

이번 과제는 Mock을 사용해서 실시간 예약정보를 데이터 플랫폼에 전송한다고 치고, 트랜잭션 내의 로직을 이벤트로 분리하는 것이다또한 MSA 설계로 전환할 때, 어떤 문제가 예상되고 해결할 수 있을지 보고서도 써야함과제일단 이 다음 과제가 kafka 사용이니까, 그걸 고려해서 구현하자현재 구현체에서는 ApplicationEventPublisher 를 사용해서 하면 될 것 같다일단 추상화를 위한 인터페이스부터 만들자interface DomainEventPublisher { fun publish(event: DomainEvent) fun publishAll(events: List)}abstract class DomainEvent ( val eventId: String = UUID.random..

애플리케이션이 커지고 복잡해질수록 '어디까지를 하나의 작업으로 묶어야 하는가'에 대한 고민이 깊어진다. 오늘은 트랜잭션의 범위를 좁히고, 시스템 간의 결합도를 낮추는 이벤트 기반 아키텍처의 핵심 개념을 정리해본다.1. 트랜잭션의 범위는 최소한으로트랜잭션은 데이터의 무결성이 보장되는 선에서 최대한 작게 가져가는 것이 원칙이다. 하나의 트랜잭션이 너무 많은 작업을 물고 있으면 여러 문제가 발생한다.성능 저하와 데드락: 트랜잭션 내에서 너무 많은 행을 수정하거나 느린 조회를 수행하면, DB Lock이 길게 유지된다. 이는 다른 요청의 대기 시간을 늘리고 결국 데드락(Deadlock) 상황을 초래할 수 있다.관심사의 혼재: DB 작업과 상관없는 외부 API 호출이나 알림 발송 로직이 트랜잭션 안에 섞여 있으면,..

이번 step은 redis에 중점적으로 맞추어져 있다redis를 어떻게 사용하고, 자료구조가 어떻게 이루어져 있는지에 대한 강의였다그래서 이번 스텝 요약은 이 포스팅으로 대체하고, 바로 과제 리뷰로 넘어가겠다과제 리뷰이번 과제는 대기열을 redis 기반으로 리팩토링해보고, 매진 순위를 redis의 sorted set으로 만들어보는 것이었다대기열은 이미 예전에 redis 기반으로 만들어둬서 손댈 부분은 없었다 먼저 Redisson과 직접적으로 통신할 어댑터를 하나 만들었다interface ConcertSoldOutPort { fun markSoldOut(concertId: Long, timestamp: Long) fun isSoldOut(concertId: Long): Boolean fun..

이전 포스팅에서 이어진다 개발일지 자동화는 했는데...문제가 하나 있었다내가 작성한 모든 커밋을 개발일지에 추가하고 싶었지만, 그럴수가 없었다는 것왜냐하면 github mcp는 각 레포지토리의 디폴트 브랜치에서만 커밋을 읽을 수 있었다하지만 난 여러 브랜치를 만들어서 작업하고 있고, 이 브랜치에서도 커밋을 읽어오기를 원했다다른 브랜치에서 mcp가 커밋을 읽으려면 정확한 레포 이름과 브랜치명을 알아야 했다각 레포마다 모든 브랜치 리스트를 읽어올수 있는 기능이 있으면 참 좋겠지만 그런건 없었다아 이걸 어떻게 할까... 하다가 git hook을 이용하기로 했다git hookgit hook은 git에서 특정 이벤트가 발생할 떄 자동으로 실행되는 스크립트이다그래서 이걸 어떻게 쓸 거냐?로컬에서 push가 발생하면..

문득 이런 생각이 들었다이렇게 열심히 코딩을 해두는데남는건 커밋과 코드밖에 없네 내가 피땀흘려 한 코딩을 요약해서 개발일지를 만들어두면 어떨까?그런데 내가 이걸 매일 하기는 너무 귀찮았다그래서 최근에 결제한 클로드 max... 이 넘쳐나는 토큰을 사용해보기로 했다 어떻게 만들까개발일지를 노션이나 옵시디언 둘중 어디에 쓸까 하다가 노션은 협업 시에 쓰는게 낫겠다 해서 옵시디언을 선택했다내가 생각해둔 flow는 다음과 같다github에서 오늘의 커밋들을 가져온다미리 준비해둔 템플릿에 맞춰 클로드 코드가 요약한다이를 저장한다그러면 대강 github mcp와 내 파일시스템에 접근할수 있는 filesystem mcp를 주면 될것이다이렇게 보면 간단하다. 처음에는 배치 파일을 써서 클로드 데스크탑 + mcp로 내가..

프로젝트 마이그레이션을 하면서, Spring AI를 도입해보기로 했다. Langchain과 Spring AI 둘중에 하나를 써야해서 고민했는데 이전 프로젝트에 만들어져있는 RAG가 그렇게 복잡하지 않아서 Langchain 보다는 간단하게 Spring AI로 만들기로 했다. 추후에 교체가 가능하도록 아키텍처를 구성하면 될거같다.참고하기이번에 스프링부트가 4.x.x 버전으로 업데이트 되어서 처음에 써보려고 했는데... Spring AI에서 지원을 안하는것 같았다. 내가 잘못 설정해서 그런건지 모르겠는데 3.5.x 버전으로 다운그레이드하니까 해결됐다.라이브러리 설치 및 환경변수 설정Spring AI는 LLM 모델에 따라 다르게 라이브러리를 설치해줘야 한다.우리는 Bedrock을 사용할 것이기 때문에implem..

이번 과제는 분산락과 캐싱을 적용해보고, 보고서를 쓰는 것이었다.이번에 처음 jmeter를 써 봤는데 생각보다 직관적이고 쓰기 편해서 놀랬다.그럼 바로 리뷰해보자캐싱일단 내가 만든 프로젝트에서 캐싱을 적용할 부분이 거의 없었다. 조회하는 API 자체가 딱 두개밖에 없었다. 회원의 포인트 조회랑, 예약 가능 좌석 조회.포인트 조회는... 캐싱되어야 할 이유가 없을것 같다. 그냥 RDB에서 컬럼 하나 가져오면 되는 문제다예약 가능 좌석 조회는 먼저 생각해보자. 예약 가능 좌석 조회에서 캐싱을 조회해두면 어떻게 될까? 만약 인기있는 콘서트가 열려서 한순간에 트래픽이 몰린다면... 캐시의 기능이 제대로 동작할까? 이런 생각이 계속 떠올랐지만 어쩌겠는가. 캐싱을 적용하라고 과제가 내려왔고, 나는 그걸 해야만 하는..