Notice
Recent Posts
Recent Comments
Link
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | ||
6 | 7 | 8 | 9 | 10 | 11 | 12 |
13 | 14 | 15 | 16 | 17 | 18 | 19 |
20 | 21 | 22 | 23 | 24 | 25 | 26 |
27 | 28 | 29 | 30 | 31 |
Tags
- Actor
- 파이썬 데이터분석
- 엔터프라이즈 블록체인
- 스칼라 동시성
- 파이썬 동시성
- Play2 로 웹 개발
- 안드로이드 웹뷰
- play2 강좌
- hyperledger fabric
- 그라파나
- 파이썬 머신러닝
- Hyperledger fabric gossip protocol
- play 강좌
- 플레이프레임워크
- 하이브리드앱
- 블록체인
- 스칼라
- Adapter 패턴
- akka 강좌
- 파이썬
- Akka
- Play2
- 이더리움
- Golang
- 주키퍼
- 스위프트
- 스칼라 강좌
- 파이썬 강좌
- 하이퍼레저 패브릭
- CORDA
Archives
- Today
- Total
HAMA 블로그
예제로 보는 아카(akka) - 10. Inbox 본문
- Scala 2.11 기반
- Akka 2.4.11 기반
- Akka 공식문서 참고
InBox
이전에 액터끼리의 통신하는 방법으로 (메세지를 전달하는 방법으로) tell (!) 과 ask (?) 를 배웠던 기억이 있을 것이다. tell 은 전형적인 보내고 잊기 방식이고 ask 는 비동기적으로 회신을 받을 수 있는 방식이었다. 그럼 InBox 는 무엇이냐면 또 다른 메세지를 전달 하는 방식인데, 임의의 액터를 하나 만들어서 이 놈이 대신 보내고 받는것이다. 중요한 포인트는 동기적으로 회신을 받는다는 점이다. 즉 타임아웃 시간동안은 멈춘다는것이며 따라서 절대로 receive 핸들러 안에서 사용하면 안된다. 이러한 성질을 이용하여 여러 액터들로 부터 다중 회신을 받거나 주로 watch 메소드 이용하여 다른 액터들을 감시하기 위해 사용된다.
다음 예를 보자.
import akka.actor.{ ActorRef, ActorSystem, Props, Actor, Inbox }
import scala.concurrent.duration._
case object Greet
case class WhoToGreet(who: String)
case class Greeting(message: String)
class Greeter extends Actor {
var greeting = ""
def receive = {
case WhoToGreet(who) => greeting = s"hello, $who"
case Greet => sender ! Greeting(greeting) // Send the current greeting back to the sender
}
}
object HelloAkkaScala extends App {
val system = ActorSystem("helloakka")
val greeter = system.actorOf(Props[Greeter], "greeter")
val inbox = Inbox.create(system)
greeter.tell(WhoToGreet("akka"), ActorRef.noSender)
inbox.send(greeter, Greet)
val Greeting(message1) = inbox.receive(5.seconds)
println(s"Greeting: $message1")
val greetPrinter = system.actorOf(Props[GreetPrinter])
system.scheduler.schedule(0.seconds, 1.second, greeter, Greet)(system.dispatcher, greetPrinter)
}
class GreetPrinter extends Actor {
def receive = {
case Greeting(message) => println(message)
}
}
val inbox = Inbox.create(system)
임의로 액터를 하나 만들었다.
inbox.send(greeter, Greet)
greeter 액터에게 Greet 메세지를 보낸다. (tell 이나 ask 가 아니라 send 이다)
val Greeting(message2) = inbox.receive(5.seconds)
타임아웃을 5초로 설정하고 수신을 받는다.
공식문서
The Inbox
액터들과 통신하려고 할때 ask 패턴을 사용할 수 도 있을 것이다. 근데 ask 로 할 수 없는 2가지가 있는데 다중회신을 받는것과 (ActorRef 를 알려주어) 다른 액터의 라이프싸이클을 감시하는것이다.
- final Inbox inbox = Inbox.create(system);
- inbox.send(target, "hello");
- try {
- assert inbox.receive(Duration.create(1, TimeUnit.SECONDS)).equals("world");
- } catch (java.util.concurrent.TimeoutException e) {
- // timeout
- }
watch 메소드를 이용하여 다른 액터를 감시하는 감시하다가 그 액터가 종료되면 메세지를 수신한다.
- final Inbox inbox = Inbox.create(system);
- inbox.watch(target);
- target.tell(PoisonPill.getInstance(), ActorRef.noSender());
- try {
- assert inbox.receive(Duration.create(1, TimeUnit.SECONDS)) instanceof Terminated;
- } catch (java.util.concurrent.TimeoutException e) {
- // timeout
- }
'Akka' 카테고리의 다른 글
왜 우리는 Vert.x 보다 아카(akka) 를 우리의 클라우드 시스템을 위해 선택했나? (번역) (0) | 2016.10.13 |
---|---|
예제로 보는 아카(akka) - 11. 클러스터 (분산컴퓨팅) (0) | 2016.10.11 |
예제로 보는 아카(akka) - 9. akka I/O (TCP 통신) (0) | 2016.10.07 |
예제로 보는 아카(akka) - 8. 원격 액터 (0) | 2016.10.07 |
예제로 보는 아카(akka) - 7. 상태머신 ( 상태에 따른 행동변화 ) (0) | 2016.10.06 |
Comments