[java] Akka를 활용한 데이터 스트리밍 처리

30 Nov 2023

java

Akka는 경량 액터 모델 프레임워크로서, 데이터 처리와 스트리밍 애플리케이션 개발에 매우 적합합니다. 이번 포스트에서는 Akka를 사용하여 데이터 스트리밍을 처리하는 방법에 대해 알아보겠습니다.

액터 모델과 Akka

액터 모델은 동시성 및 분산 시스템에서 메시지를 교환하며 독립적인 개체인 액터들이 상호 작용하는 프로그래밍 모델입니다. Akka는 액터 모델을 구현하는 자바 및 스칼라 기반의 오픈 소스 라이브러리입니다.

Akka 액터 정의하기

데이터 스트리밍 처리를 위해 먼저 액터를 정의해야 합니다. Akka에서 액터는 Actor 클래스를 상속하여 작성됩니다. 아래는 간단한 액터의 예시입니다.

import akka.actor.AbstractActor;

public class MyActor extends AbstractActor {
    @Override
    public Receive createReceive() {
        return receiveBuilder()
            .match(String.class, message -> {
                // 데이터 처리 로직 작성
            })
            .build();
    }
}

액터 내에서는 createReceive() 메소드를 오버라이딩하고, receiveBuilder()를 통해 메시지 처리 동작을 정의합니다. 위의 예시에서는 String 형식의 메시지를 처리하는 로직을 작성하였습니다.

스트림 생성하기

Akka 스트림은 데이터의 흐름을 처리하는데 사용되며, 입력, 출력 및 중간처리 등 다양한 스트림 연산을 제공합니다. 아래는 스트림을 생성하는 간단한 예시입니다.

import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import akka.stream.javadsl.Source;
import akka.stream.javadsl.Sink;

public class StreamProcessing {
    public static void main(String[] args) {
        ActorSystem system = ActorSystem.create("MySystem");
        Materializer materializer = ActorMaterializer.create(system);

        // 입력 데이터 스트림 생성
        Source<String, NotUsed> input = Source.single("Hello, World!");

        // 액터로 데이터 스트림 전달
        input.runWith(Sink.actorRef(myActor, "done"), materializer);
    }
}

Source 클래스는 입력 데이터 스트림을 생성하며, Sink 클래스는 출력 데이터 스트림을 생성합니다. runWith() 메소드를 사용하여 입력 스트림을 액터로 전달하고, materializer를 통해 스트림을 실행합니다.

결과 처리하기

액터가 처리한 결과를 받으려면 액터 내에서 결과를 메시지로 보내고, 결과를 수신하는 액터를 정의해야 합니다. 아래는 결과를 처리하는 액터의 예시입니다.

import akka.actor.AbstractActor;

public class ResultActor extends AbstractActor {
    @Override
    public Receive createReceive() {
        return receiveBuilder()
            .match(String.class, result -> {
                // 결과 처리 로직 작성
            })
            .build();
    }
}

이제 결과를 처리하는 액터를 생성하고, 이전에 생성한 액터로부터 결과를 전달받아 처리할 수 있습니다.

결론

Akka를 사용하여 데이터 스트리밍을 처리하는 방법에 대해 알아보았습니다. Akka의 액터 모델을 활용하면 분산 시스템이나 복잡한 데이터 처리 환경에서도 효율적이고 견고한 애플리케이션을 개발할 수 있습니다.

더 많은 자세한 내용은 Akka 공식 문서를 참고하시기 바랍니다.

Happy streaming!