SpringBoot와 Kafka를 활용한 마이크로서비스 예제
스프링 부트와 카프카 소개
스프링 부트(Spring Boot)는 개발자가 빠르게 애플리케이션을 구축할 수 있도록 도와주는 프레임워크입니다. 이는 다양한 '스타터' 종속성을 제공하여, 개발자가 필요한 라이브러리를 쉽게 추가할 수 있습니다. 특히 마이크로서비스 아키텍처를 구현하는데 매우 유용하며, 여기에는 REST API, 데이터베이스 연결, 보안 등 다양한 기능이 포함됩니다.
카프카(Kafka)는 분산 스트리밍 플랫폼으로서 실시간 데이터 파이프라인과 애플리케이션을 처리합니다. 이를 사용하면 대규모 메시지 스트림을 안정적으로 처리할 수 있으며, 이러한 기능은 실시간 분석 및 시스템 간 통신에 필수적입니다.
본 가이드에서는 'springboot kafka' 와 'apache kafka spring boot microservices example'라는 키워드를 중심으로 진행됩니다. 즉, 스프링 부트와 카프카를 활용해 마이크로서비스 아키텍처의 한 예제를 구현하는 방법에 대해 설명합니다.
Spring Boot란?
Spring Boot는 Java 기반의 오픈 소스 프레임워크로서 개발자가 서버 사이드 애플리케이션을 빠르고 쉽게 만들 수 있도록 돕습니다. Spring Boot의 핵심 목적은 Spring의 복잡성을 줄여 개발 과정에서 발생하는 문제 해결에 집중할 수 있도록 하는 것입니다.
Kafka란?
Kafka는 LinkedIn에서 시작된 오픈 소스 프로젝트로 현재 Apache Software Foundation의 일부입니다. Kafka의 주요 사용 사례 중 하나는 실시간 스트리밍 데이터 파이프라인 구축입니다. 이를 통해 데이터를 수집하고 처리한 후 다른 시스템으로 전송할 수 있습니다.
다음 장에서는 스프링 부트에서 카프카를 설정하는 방법에 대해 설명하겠습니다.
목차로 돌아가기스프링 부트에서 카프카 설정하기
스프링 부트에서 카프카를 사용하려면 먼저 스프링 카프카 라이브러리를 프로젝트에 추가해야 합니다. 이는 'spring-kafka'라는 이름의 스타터 종속성을 통해 가능합니다.
스타터 종속성 추가하기
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
</dependencies>
위 코드는 Maven 프로젝트의 pom.xml 파일에 추가되어야 하는 종속성입니다. Gradle을 사용하는 경우, build.gradle 파일에 아래와 같이 추가하면 됩니다.
dependencies {
implementation 'org.springframework.boot:spring-boot-starter-web'
implementation 'org.springframework.kafka:spring-kafka'
}
카프카 설정하기
스타터 종속성을 추가한 후, 다음 단계는 카프카 브로커에 연결하는 설정을 application.properties 파일에 추가하는 것입니다.
spring.kafka.producer.bootstrap-servers=localhost:9092 spring.kafka.consumer.bootstrap-servers=localhost:9092 spring.kafka.consumer.group-id=myGroup
위 설정은 카프카가 로컬 호스트의 9092 포트에서 실행되고 있으며, 컨슈머 그룹 ID가 'myGroup'임을 가정합니다. 실제 사용 시에는 해당 환경에 맞게 변경해야 합니다.
다음 장에서는 이렇게 설정한 카프카를 활용하여 프로듀서와 컨슈머를 생성하는 방법을 설명하겠습니다.
목차로 돌아가기카프카 프로듀서 및 컨슈머 생성하기
카프카를 사용하는 애플리케이션에서는 메시지를 보내는 프로듀서(Producer)와 메시지를 받는 컨슈머(Consumer)가 필요합니다. 이번 장에서는 스프링 부트 애플리케이션에서 카프카 프로듀서와 컨슈머를 생성하는 방법을 설명하겠습니다.
카프카 프로듀서 생성하기
스프링 부트 애플리케이션에서 카프카 프로듀서를 생성하려면, KafkaTemplate 빈을 사용해야 합니다. KafkaTemplate은 스프링 카프카 라이브러리가 제공하는 클래스로, 메시지를 보내는 기능을 추상화합니다.
<KafkaTemplate<String, String> template;
public void sendMessage(String msg) {
template.send("myTopic", msg);
}
위 코드에서 KafkaTemplate의 send 메소드는 토픽 이름과 메시지 내용을 인자로 받습니다. 이 예제에서 "myTopic"은 카프카에 이미 존재하는 토픽 이름이어야 합니다.
카프카 컨슈머 생성하기
스프링 부트 애플리케이션에서 카프카 컨슈머를 만들려면 @KafkaListener 어노테이션을 사용해야 합니다. 이 어노테이션이 붙은 메소드는 지정된 토픽으로부터 메시지가 도착할 때 자동으로 호출됩니다.
@KafkaListener(topics = "myTopic", groupId = "myGroup")
public void listen(String message) {
System.out.println("Received Message: " + message);
}
위 코드의 listen 함수는 "myTopic" 토픽으로부터 메시지가 도착할 때 호출되며, 수신한 메시지 내용을 콘솔에 출력합니다.
목차로 돌아가기장: 마이크로서비스 예제 구현하기
이번 장에서는 실제로 스프링 부트와 카프카를 사용하여 간단한 마이크로서비스를 구현하는 방법을 살펴보겠습니다. 이 예제에서는 두 개의 서비스, 즉 메시지를 생성하고 보내는 프로듀서 서비스와 메시지를 수신하고 처리하는 컨슈머 서비스가 있습니다.
프로듀서 서비스
먼저 프로듀서 서비스의 Controller 클래스를 생성합니다. 이 클래스는 HTTP 요청을 받아 KafkaTemplate을 사용하여 카프카 토픽에 메시지를 보냅니다.
@RestController
public class ProducerController {
private final KafkaTemplate<String, String> template;
public ProducerController(KafkaTemplate<String, String> template) {
this.template = template;
}
@PostMapping("/publish/{message}")
public void publishMessage(@PathVariable String message) {
template.send("myTopic", message);
}
}
컨슈머 서비스
다음으로 컨슈머 서비스의 Listener 클래스를 생성합니다. 이 클래스는 카프카 토픽에서 메시지가 도착할 때마다 해당 메시지를 수신하고 처리합니다.
@Service
public class ConsumerService {
@KafkaListener(topics = "myTopic", groupId = "myGroup")
public void consume(String message) {
System.out.println("Consumed Message: " + message);
}
}
위 예제 코드들은 간단한 형태입니다. 실제 애플리케이션에서는 복잡한 비즈니스 로직에 따라 추가적인 처리 과정이 필요할 수 있습니다.
목차로 돌아가기결론
이 가이드에서는 스프링 부트와 카프카를 사용하여 마이크로서비스를 구현하는 방법에 대해 알아보았습니다. 스프링 부트에서 카프카 설정을 하는 방법, 프로듀서와 컨슈머를 생성하는 방법, 그리고 실제 서비스 예제를 구현하는 과정 등을 단계별로 설명하였습니다.
스프링 부트와 카프카는 분산 시스템과 마이크로서비스 아키텍처를 구현하기 위한 강력한 도구입니다. 이 두 기술을 활용하면 대규모 데이터 처리 및 실시간 분석 등 다양한 애플리케이션을 개발할 수 있습니다.
목차로 돌아가기