HAMA 블로그

- Scala 2.11.8 기반 - Akka 2.4.11 기반 - Java 8 (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) 여러개의 ActorSystem 사용 하나의 호스트에서 액터시스템 여러개를 사용하는것에 관해 생각해보면 관심사의 분리라고 해야하나? 액터군도 여러개가 될 수 도 있을 것이다. 따라서 액터시스템도 그에 맞게 여러개를 사용 할 수 도 있다. (Play2 에 내 자신의 액터시스템을 임베디드 시키는것도 마찬가지) 이 부분에 대해서는 아직 나도 정확하게 이렇게 해야한다라고 말하기 어렵기 때문에 사실만 짚고 넘어가자면 액터 시스템 사이의 통신은 안된다. 이게 가능하려면 둘을 remote 로 연결해야 한다. 그리고 많은 수의 액터 시스템을 하나의..

- Scala 2.11.8 기반 - Akka 2.4.11 기반 - Java 8 (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) 참고 : http://queirozf.com/entries/scala-slick-simple-example-on-connecting-to-a-postgresql-database http://slick.lightbend.com/doc/2.1.0/sql-to-slick.html#insert https://github.com/lucperkins/spray-akka-slick-postgresAkka 에서 PostgreSQL 사용하기1. Scala 로 PostgreSQL 사용하기 (with Slick) 의존성 추가 libraryDepende..

- Scala 2.11.8 기반 - Akka 2.4.11 기반 - Java 8 (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) Akka TCP 와 데이터의 끝 서론 Akka TCP 서버를 만들때 데이터를 받는 부분의 대부분의 예는 그냥 Received(data) 이다. 즉 아래 형태.def writing: Receive = { case Received(data) => log.info(s"fromGW - '${data.utf8String}'") ruleEngine ! fromTGH(data.utf8String) data 는 ByteString 형 이기 때문에 Json문자열을 보낼 경우 utf8String 으로 변경해서 처리하는데 여기서 문제가 하나 있다. 다..

- Scala 2.11.8 기반 - Akka 2.4.11 기반 - Java 8 (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) - Akka 공식 문서 : http://doc.akka.io/docs/akka/snapshot/general/addressing.html 액터 찾기 & 참조하기액터시스템에 여러개의 액터가 활동 할 때 , A 액터는 메세지에 따라서 B,C,D 액터에게 메세지를 따로 보내야 할때가 있다. 이때 A 액터는 B,C,D 액터에 대한 참조를 어떻게 알 수 있을까? 일단 보통 객체 코딩 했었을 때 를 생각하면서 A 액터에 setActor 같은 메소드를 만들어서 B,C,D 액터의 참조를 주입시키는 방법으로 손가락이 먼저 반응 했는데 다른 방법이 ..

왜 우리는 Vert.x 보다 아카(akka) 를 우리의 클라우드 시스템을 위해 선택했나? 원문 > https://techblog.king.com/why-we-choose-akka-for-our-cloud-device-solution/ 번역의 질에 대해선 참아주세요 OTL 전체를 번역하진 않았고 Vert.x 와 Akka비교에 관한 부분만 번역하였다. 우린 자동화 테스트를 반복적으로 실행 했다. 동일한 시간에 한 두개의 디바이스를 가지고 말이지..이런 진행과정은 꽤나 간단하다. 맘에드는 디바이스를 집어들고 게임 및 테스트로 빌드를 만들고 플레이를 누르고 커피잔을 집어들고.. 이런 작업은 꽤 잘 되었지만 최대한 많은 수의 디바이스로 작업을 해서 우리의 게임이 잘 작동하는지 확인해야했다. 버그 없는 게임을 유저..

Akka 공식문서 번역 - 개념 참고- 예제 참고 Akka Cluster 이전에 원격 액터에 접속하는 방식을 배웠었다. 원격 액터에 접근 하기위해서는 그 액터에 대한 특정위치를 액터 셀렉션을 통해서 얻어서 메세지를 보냈지만 이 포스트를 통해 알게 될 아카 클라우드는 액터들이 구름상에 어디 있는지 중요하지 않고 어딘가의 액터에게 메세지를 보낼 때 필요하다. 실행시간에 그런 노드들은 자연스럽게 참여 했다가 빠질 수 도 있다. 즉 확장성과 탄력성을 보장한다. 역할을 구분해서 그룹핑 할 수 도 있지만 주로 동일한 작업을 분산시켜서 사용 할 때 필요하다. 예를들어 맵/리듀스 (워드카운팅) 같은거 말이다. 개념 아카 클러스터는 단일지점 장애와 단일지점 병목을 없앤 중앙화 되지 않은 내구성 강한 peer to pee..

- Scala 2.11 기반 - Akka 2.4.11 기반 - Akka 공식문서 참고 InBox이전에 액터끼리의 통신하는 방법으로 (메세지를 전달하는 방법으로) tell (!) 과 ask (?) 를 배웠던 기억이 있을 것이다. tell 은 전형적인 보내고 잊기 방식이고 ask 는 비동기적으로 회신을 받을 수 있는 방식이었다. 그럼 InBox 는 무엇이냐면 또 다른 메세지를 전달 하는 방식인데, 임의의 액터를 하나 만들어서 이 놈이 대신 보내고 받는것이다. 중요한 포인트는 동기적으로 회신을 받는다는 점이다. 즉 타임아웃 시간동안은 멈춘다는것이며 따라서 절대로 receive 핸들러 안에서 사용하면 안된다. 이러한 성질을 이용하여 여러 액터들로 부터 다중 회신을 받거나 주로 watch 메소드 이용하여 다른 액..

- Scala 2.11 기반 - Akka 2.4.11 기반 - akka.io 공식문서 정리만약 Akka IO 를 사용하지 않고, 직접 로우레벨 도구(Selection, Channel, Event, Mutex, Completion Port 등) 를 사용하여 직접 기틀(프레임워크)를 만든다고 할 지라도 이 글은 도움이 될 것입니다. 자신의 통신모듈을 어떻게 조직화하고 ,어떤 것 을 포함해야 할 지에 대한 정보와 힌트를 얻을 수 있을 테니까요. 하지만 웬간하면 바퀴를 또 발명할 필요는 없을 것이고 akka 같은 도구를 이용해서 바퀴에 신경쓰기 보단 바퀴로 수레를 만들지, 기차를 만들지에 대한 상상력의 날개를 펼쳐보는게 어떨까요. 바퀴 만드는 사람에 대한 고마움은 마음 속에 간직하시고..이 글은 공식 문서를 이..

- Scala 2.11 기반 - Akka 2.4.11 기반 - Learning Concurrent Programming in Scala 참고 원격 액터 지금까지는 한 컴퓨터 안의 한 프로세스 안에서 실행되는 내용이었다. 여기서는 기존의 액터를 가지고 분산된 컴퓨터 상에 배치해서 실행해보자. Pingy 와 Pongy 라는 두개의 액터끼리 메세지를 보내고 받는 구현을 그대로 해볼것이다.Sbt 에 의존성 추가libraryDependencies += "com.typesafe.akka" %% "akka-remote" % "2.4.11"별게 없다 akka-remote 의존성만 양쪽에 추가하면 끝.A 컴퓨터 액터 생성 (Pingy)import akka.actor._ import akka.event.Logging im..

- Scala 2.11 기반 - Akka 2.4.11 기반 - Learning Concurrent Programming in Scala 참고 상태머신 (상태에 따른 행동변화 )- 액터가 자신의 상태를 바꿈에 따라 메세지를 처리하는 방식도 달라 진다. - 아카 액터에서 receive 메소드 안에 상태에 따른 여러 행위를 넣는것은 바람직 하지 않다.class CountdownActor extends Actor { var n = 10 def receive = if (n > 0 ) { case "count" => ...do somthing .. n -=1 } else PartialFunction.empty }- n 이 0 보다 클 경우에는 어떤 행동을 하고 - n 이 0 일때는 아무것도 안한다. - receiv..