Page History
...
"hello"메시지를 받으면sender() ! "world"로 응답을 보냄ask패턴(?)을 사용하여 응답을 Future로 받음Await.result로 블로킹 방식으로 응답을 출력
자바
| Info |
|---|
자바7의 java.util.concurrent.Future에 익숙하다면 scala.concurrent.Future가 자바 클래스를 감싼것으로 생각할수도 있지만 실제로는 그렇지 않다. java.util.concurrent.Future 클래스는 폴링을 필요로하며 결과를 얻기위해 블로킹 get 메서드를 사용해야만 한다. 하지만 스칼라의 퓨쳐는 블로킹이나 풀링을 사용하지 않고 함수결과를 조합할수 있으며 JAVA8의 CompletetableFuture<T>가 오히려 여기서 설명하는 퓨쳐와 유사하다. Erik Meijer의 한마디~ "이보게, 브라이언 괴츠, C#,파이선,자바스크립트는 물론 심지어 PHP도 async, await를 지원하고 있다네. 그런 기능이 없는 언어는 자바일뿐이야. 람다를 이용해서 콜백함수를 사용하면 된다고? 천만에 콜백은 최악이야. 도움이 안된다고. 자바 9 버전에 담으려고 하는 걸 다 내려놓고 지금당장 asymc, await부터 넣으라고. 그래야 모두가 행복해질수 있어" 제대로된 비동기 동시성처리는 Java8부터 지원하기 시작했으며 Java언어 순수스펙에서는 await를 프로그래밍 모델을 지원하지 않기때문에 액터모델의 Ask패턴은 비동기처리 완료인 CompelteableFuture를 이용합니다. |
| Code Block | ||
|---|---|---|
| ||
public class HelloActor extends AbstractActor {
// 액터 생성 팩토리
public static Props props() {
return Props.create(HelloActor.class);
}
@Override
public Receive createReceive() {
return receiveBuilder()
.matchEquals("hello", msg -> {
getSender().tell("world", getSelf());
})
.matchAny(msg -> {
System.out.println("Unknown message: " + msg);
})
.build();
}
}
public class HelloActorApp {
public static void main(String[] args) throws Exception {
ActorSystem system = ActorSystem.create("HelloSystem");
ActorRef helloActor = system.actorOf(HelloActor.props(), "helloActor");
// 메시지 보내고 응답 기다리기
Future<Object> future = Patterns.ask(helloActor, "hello", 5000);
String result = (String) Await.result(future, Duration.create(5, TimeUnit.SECONDS));
System.out.println("응답: " + result); // "world"
system.terminate();
}
}
|
...
| Code Block | ||
|---|---|---|
| ||
fun main() {
val system = ActorSystem.create("RoundRobinSystem")
// RoundRobinPool로 HelloActor 3개 구성
val router = system.actorOf(
RoundRobinPool(3).props(HelloActor.props()),
"helloRouter"
)
println("=== 메시지 전송 시작 ===")
for (i in 1..9) {
val future = Patterns.ask(router, "hello $i", 1000)
val result = Await.result(future, Duration.create(1, TimeUnit.SECONDS))
println("응답 $i: $result")
}
system.terminate()
}
// Output
[helloRouter/$a] received: hello 1
응답 1: world
[helloRouter/$b] received: hello 2
응답 2: world
[helloRouter/$c] received: hello 3
응답 3: world
[helloRouter/$a] received: hello 4
응답 4: world
...
|
테스트 가능한 다양한 액터 장치들
| Info |
|---|
테스트 코드를 통해 작동방법을 설명하고 수행합니다. 액터모델을 통해 다양한 장치를 이용해 작동하는 유용한 샘플코드를 살펴볼수 있습니다. 최근 코틀린과 AKKA오픈버전은 Pekko를 조합하여 코프링내에서 액터모델 탑재를 시도하고 있습니다. |
🎯 Akka의 분산처리 단순화 전략
1. ✅ 액터 모델 기반 격리 (Actor Isolation)
모든 상태와 처리를 액터 단위로 캡슐화
동시성과 병렬성을 락(lock) 없이 처리
분산에서도 동일한 추론 모델 사용 → 코드를 분산으로 쉽게 확장 가능
...
2. ✅ 클러스터링 지원 (Akka Cluster)
여러 노드를 하나의 논리적인 ActorSystem처럼 구성
노드 간 자동 등록, 탈퇴, 장애 감지, 재할당 등 제공
메시지를 보내는 방식은 단일 노드와 거의 동일
| Code Block | ||
|---|---|---|
| ||
[Node1] ↔ [Node2] ↔ [Node3]
│ │ │
HelloActor HelloActor HelloActor
|
3. ✅ Cluster Sharding
수천~수백만 개의 액터를 자동으로 클러스터 노드에 분산 배치
액터 위치를 몰라도 메시지 전송 가능 (
shardRegion ! msg)데이터/처리를 분산하고, 장애 복구 시 자동 재배치
...
4. ✅ Cluster Singleton
클러스터 전체에서 단 하나의 액터 인스턴스만 유지
중요한 상태나 리더 역할을 담당하는 서비스 구성에 사용
...
5. ✅ 메시지 기반 통신 (Location Transparency)
actorSelection이나ActorRef를 통해 위치를 몰라도 메시지 전송 가능지역(local)과 원격(remote)의 코드 차이를 최소화
...
6. ✅ Supervision & Fault Tolerance
각 액터가 자식 액터의 실패를 감시 (let it crash)
장애 격리와 자동 복구, 특히 분산 환경에서 안정성 확보에 강함
...
7. ✅ Persistence + Event Sourcing (선택적)
상태를 이벤트 로그로 저장하여 분산 시스템의 상태 일관성 확보
스냅샷, 이벤트 재생 등으로 빠른 복원 가능
...
🧠 한 줄 요약
"Akka는 복잡한 분산 처리 시스템을 액터라는 추상화된 단위로 나누고, 이들을 클러스터로 자동 연결하여 단일 시스템처럼 작동하게 만든다."
액터프로그래밍 활용사례
1. Scala: Akka 프레임워크
...