[java] Akka를 사용한 확장 가능한 비동기 프로세싱

30 Nov 2023

java

반응 좋은 애플리케이션을 만들기 위해서는 비동기 프로세싱이 필요합니다. 그리고 비동기 프로세싱은 대량의 작업을 동시에 처리할 수 있는 확장 가능한 아키텍처를 제공합니다. 이를 위해 Akka를 사용할 수 있습니다.

Akka는 Java와 Scala용으로 개발된 액터 기반 프레임워크입니다. 액터는 경량 스레드와 비슷한 개념으로, 독립적으로 동작하는 작은 유닛입니다. 각 액터는 메시지를 주고 받으면서 작업을 처리하며, 자신의 내부 상태를 유지하고 다른 액터와 상호작용합니다.

Akka 액터 생성하기

Akka 액터는 ActorSystem을 통해 생성됩니다. 액터 시스템은 액터들의 관리와 메시지 처리를 담당합니다. 다음은 간단한 예제 코드입니다.

import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;

public class MyActor extends AbstractActor {
    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(String.class, message -> {
                    System.out.println("Received message: " + message);
                })
                .build();
    }
}

public class Main {
    public static void main(String[] args) {
        ActorSystem system = ActorSystem.create("my-actor-system");

        ActorRef myActor = system.actorOf(Props.create(MyActor.class), "my-actor");

        myActor.tell("Hello, Akka!", ActorRef.noSender());

        system.terminate();
    }
}

위의 예제에서는 MyActor 클래스를 정의하여 AbstractActor를 상속하고, createReceive() 메서드를 구현했습니다. createReceive() 메서드는 액터가 받을 수 있는 메시지 유형에 대한 처리를 정의합니다. 예제에서는 String 유형의 메시지를 처리하는 코드를 작성했습니다.

Akka 액터 간 메시지 전송하기

Akka 액터는 tell() 메서드를 사용하여 다른 액터에게 메시지를 전송할 수 있습니다. 이 메서드는 비동기적으로 메시지를 보내고 반환하지 않습니다. 다음은 액터 간 메시지 전송의 예제 코드입니다.

import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;

public class MyActor extends AbstractActor {
    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(String.class, message -> {
                    System.out.println("Received message: " + message);
                })
                .match(Integer.class, value -> {
                    System.out.println("Received value: " + value);
                })
                .build();
    }
}

public class Main {
    public static void main(String[] args) {
        ActorSystem system = ActorSystem.create("my-actor-system");

        ActorRef actor1 = system.actorOf(Props.create(MyActor.class), "actor1");
        ActorRef actor2 = system.actorOf(Props.create(MyActor.class), "actor2");

        actor1.tell("Hello, Akka!", ActorRef.noSender());
        actor2.tell(42, ActorRef.noSender());

        system.terminate();
    }
}

위의 예제에서는 MyActor 클래스를 두 개 생성하여 actor1과 actor2라는 이름으로 액터를 생성하고 있습니다. 그리고 actor1에는 String 유형의 메시지를 전송하고, actor2에는 Integer 유형의 메시지를 전송하고 있습니다.

결론

Akka를 사용하면 확장 가능한 비동기 프로세싱을 구현할 수 있습니다. 액터 기반 아키텍처를 사용하여 동시에 많은 작업을 처리할 수 있고, 액터 간 메시지 전송을 통해 상호작용할 수 있습니다. Akka는 자바와 스칼라에서 사용할 수 있으며, 간단한 API를 사용하여 액터를 생성하고 메시지를 전송할 수 있습니다.

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