The Nirsa Way

Spring Boot와 연동하여 간단한 주문 시스템 만들기 - (요청/응답 받기)이제 스프링부트와 연동하여 아주 간단한(요청/응답 받기 수준) 주문 시스템을 만들 예정입니다. html, css, js 파일은 올려두었으니 혹시 필요하신분이 계시다면 다운로드 받아 스프링 부트 환경에 셋팅해주시면 됩니다. 참고로 현재 셋팅은 타임리프 기준입니다. 현재 저는 스프링 부트 3.5.3 버전을 사용중이며 아래와 build.gradle에 개발 시 필요한 web, devtool, lombok, thymeleaf 의존성을 주입 받고 카프카를 사용할 예정이기에 spring-kafka도 추가하여 주세요.dependencies { implementation 'org.springframework.boot:spring-boo..

리눅스에 카프카 설치하기현재 저는 VMware에 리눅스 서버(Rocky 9.6)를 준비해두었으며 테스트를 위한 서버이므로 selinux, firewalld를 모두 disabled 해두었습니다. 우선 kafka의 바이너리를 다운로드 받기 위해 vim, wget, tar을 설치해두겠습니다.dnf -y install vim wget tar※ 만약 자바가 설치되어 있지 않은 경우 설치 진행저의 경우 dnf -y install java-17-openjdk java-17-openjdk-devel -y 을 입력하여 jdk 17을 설치해두었습니다. 이후 https://downloads.apache.org/kafka/ 으로 이동하여 원하는 버전의 폴더를 클릭합니다. (저는 3.9.0으로 진행하겠습니다) 소스 다운로드와 ..

카프카의 핵심 요소카프카의 핵심 요소는 크게 Topic, Partition, Offset, Consumer Group, KRaft, Replication, Durability으로 구성되어 있습니다. 1. Topic메시지를 분류하는 논리적 단위입니다. 생산자는 Topic에 메시지를 발행(Publish) 하고, 소비자는 Topic을 구독(Subscribe)하여 메시지를 가져갑니다. 2. Parttion, Offset각각의 Topic은 여러 개의 Partition으로 분할되어 병렬 처리가 가능합니다. Partition은 메시지를 물리적으로 저장하는 단위로써 메시지는 파티션 내에서 Offset을 기준으로 정렬됩니다.또한 Offset은 파티션 내 메시지의 고유한 순번으로써 Consumer는 각 partition에..

Apache Kafka란?실시간의 스트리밍 데이터를 수집하고 처리하는 분산형 스트리밍 플랫폼 입니다. 이미 많은 기업에서 도입하여 사용되고 있으며 대용량 트래픽을 처리하기 위한 해결 방안으로써 많이 주목을 받고 있습니다.이번 포스팅에서는 Kafka를 공부하기 전 밑바탕이 되는 개념인 메시지 브로커와 Pub/Sub & 스트리밍에 대한 내용을 다룹니다.메시지 브로커(Message Broker)메시지 브로커는 송신자(Producer)와 수신자(Consumer)간에 메시지를 중계하며 비동기적으로 데이터를 주고받게 하는 시스템입니다. 시스템간 직접 통신을 대신하여 중간에서 메시지를 효율적으로 전달해주는 역할을 수행합니다.메시지 브로커의 구성요소는 아래와 같으며 Topic은 Pub/Sub 패턴으로써 여러 수신자(C..

영속성 컨텍스트(Persistence Context)란?JPA에서 엔티티 객체를 보관하는 저장소로써 EntityManager를 통해 엔티티를 관리하는 1차 캐시라고 볼 수 있습니다. 영속성 컨텍스트를 사용함으로써 아래와 같은 특징을 가지게 됩니다.1차 캐시 (First-Level Cache) : 동일한 엔티티를 여러 번 조회하면 DB에 재접근 하지 않고 캐시에서 반환동일성 보장 (Write-behind SQL Store) : 동일한 식별자를 가진 엔티티에 대해 항상 같은 인스턴스 반환 (== 비교 연산자로도 동일한 인스턴스로 인식함)쓰기 지연 (SQL 저장소) : 엔티티의 필드 변경 시 SQL이 즉시 실행되지 않고 트랜잭션 커밋 시 한번이 실행변경 감지 (Dirty Checking) : 엔티티의 값이 변..

Eager Loading vs Lazy LoadingEager Loading(이하 즉시 로딩)과 Lazy Loading(이하 지연 로딩)은 연관된 엔티티를 언제 불러올 것인지에 대해 결정하게 됩니다. 각각 연관 관계에 따라 기본값을 가지는게 다릅니다. 즉시 로딩(Eager Loading)즉시 로딩은 EAGER를 사용 합니다. ManyToOne은 즉시 로딩을 기본값을 가지기 때문에 fetch를 설정하지 않아도 되지만, 예시 코드임으로 명시적으로 하기 위해 작성하였습니다.@Entitypublic class Member { @Id @GeneratedValue private Long id; private String name; @ManyToOne(fetch = FetchType.EAGER..

기타 관계 (@OneToOne, @ManyToMany)ManyToOne, OneToMany 보다 상대적으로 사용 빈도가 낮은 OneToOne, ManyToMany를 기타 관계라고 표현하기도 합니다. 네이밍 그대로 1:1, N:N 관계를 가지는 어노테이션이며 특히 ManyToMany의 경우 중간 매핑 테이블을 따로 분리하는 것이 좀 더 좋은 케이스인 경우가 많으므로 거의 사용되지 않습니다. 1. @OneToOne한 명의 학생(student)은 하나의 사물함(rocker)만 사용해야하는 경우와 같이 1:1로 매핑되어야 하는 상황에서 사용되는 어노테이션 입니다. 단방향을 기준으로 작성된 엔티티는 다음과 같습니다.@Entitypublic class Student { @Id @GeneratedValue ..

양방향 매핑이란?양쪽의 엔티티가 서로를 참조하도록 설계하는 방식으로써 단방향 매핑과는 객체 그래프 탐색 및 DB 외래키 소유와의 매핑 표현 방식 차이가 있습니다. 무한 루프 주의의 경우 JSON 직렬화 시 발생하는 경우가 대부분인데, 일반적으로 MVC 패턴에서 요청/응답 DTO를 따로 사용하므로 해당 내용은 생략합니다. 아래의 코드를 보면 "연관 관계의 주인" 이라는 주석이 있는데 이는 외래키를 관리하는 주체입니다. 즉 insert/update 등이 발생하는 위치를 뜻합니다. member가 ManyToOne으로 team에 매핑하였으므로 당연히 team에서는 반대로 OneToMany가 됩니다.연관 관계의 주인이 되는쪽은 JoinColumn으로 FK를 지정하고 주인이 아닌쪽은 mappedBy를 통해 "주인이..

연관 관계 매핑이란?엔티티간의 관계를 DB의 FK와 매핑하여 연결하는 형태를 가질 수 있습니다. 즉 객체 간의 참조 방식을 DB의 외래키(FK)와 연결하여 사용할 수 있습니다. 이번에 살펴볼 어노테이션은 크게 2가지 인데, 아래와 같은 의미를 지닙니다. 1. @ManyToOne일반적으로 단방향 매핑에서 가장 권장하는 방식입니다. 두 개의 엔티티를 만들어 관리하고 여러 명인 쪽에서 @ManyToOne과 @JoinColumn을 사용하여 단방향 매핑을 가집니다. fetch는 추후 연관관계 매핑 포스팅이 끝날 때 쯤 작성할 예정입니다.@Entitypublic class Member { @Id @GeneratedValue private Long id; private String name; ..

JPA에서의 Entity란?데이터베이스 테이블과 매핑되는 자바 클래스를 의미합니다. 아래의 클래스를 예로 들었을 때 member의 테이블을 가르키며 객체는 테이블의 한 행(row)를 표현할 수있습니다.@Entitypublic class Member { @Id private Long id; private String name;}엔티티는 ORM에서 핵심 단위로 볼 수 있으며 자바와 관계형 데이터베이스간의 변환을 담당하고, 도메인 모델로써 역할을 수행하게 되며 영속성 컨텍스트의 관리 대상이 되며 일반적으로 아래와 같은 조건들을 가집니다. (영속성 컨텍스트의 라이프 싸이클 등 자세한 내용은 추후 포스팅 예정)기본 생성자 필수 : JPA 내부에서 리플렉션으로 사용final 클래스 불가 : fina..