저는 Akka 액터를 기반으로 한 이벤트 처리 파이프 라인을 만들고 있습니다. FilterWorker, EnrichWorker 및 ProcessWorker와 같이 파이프 라인의 각 단계마다 3 명의 액터가 있습니다. 이벤트가 파이프 라인의 한 단계에서 다음 단계로 전송되도록 감독자 액터가 추가되었습니다. 풍부한 데이터를 얻기 위해 일부 외부 데이터베이스를
안녕하세요. 문제가 올바르게 해결되지 않아서 제 질문에 맞는 제목이 아닐 수도 있습니다. 액터 A는 액터 B1을 만들고 액터 B1은 임무 수행을 담당하는 "n"액터를 만듭니다. 그래서 A는 B1의 부모이고 B1은 부모가 b1, b2, b3, ...이라고 말하면됩니다. 있음 A 새 B가 생성되면 A가 매 10 초마다 검사하도록 예약했습니다. . Duratio
Play! 프레임 워크가 잠시 동안, 나는 Spray를 처음 보게됩니다. 내가 GitHub에서 찾은 샘플부터 시작 했으니, 이제는 수정하고 싶지만 어떻게 작동하는지 알기가 쉽지 않습니다. 아래 코드에서 액터의 메시지를 어떻게 기다릴 수 있습니까? 그냥 배우 응답 경로를 완료하려면 package api
import akka.actor.ActorRef
i
우리는 Erlang 프로세스에서 실행할 수있는 프롤로그 인 Erlog 1.0 릴리스를 빌드하는 중입니다. 지금은 일반적인 오류 메커니즘을 통해 메시지를 보내고받을 수있는 기능을 구현했습니다. 그러나 erlang의 메시지 전달 위에 구축 된 Erlog에 다른 동시성 추상화를 추가하고 싶습니다. 그렇다면 Prolog 또는 LP 프로그래밍 환경에서 다른 동시
액터가 차단 입력 스트림에서 아웃 스트림 및 읽기 스트림에 데이터를 쓸 필요가있는 시스템에서 Akka/Play (Java)를 사용하고 있습니다. 현재 구현에서는 스트림에 /에서 실제 쓰기/읽기를 수행하는 자바 스레드를 사용하고 있습니다. 스레드는 자체 참조를 전달하는 액터에 의해 생성됩니다. 데이터를 쓸 때 배우 단순히 스레드를 스트리밍 차단 입력에서 wo
내가 A --> B --> C
배우 A를 같은 akka 배우의 사슬을 요청 차례로 배우 C. 배우 A는 기다릴 필요 '요청'배우 B를 '요청' 배우 C가 처리를 마칠 때까지 B는 기본적으로 B 단지 무엇을지고하는 것은 미래 [모든]입니다 따라서 { case msgFromA => sender ! C ? msgFromA }
을 얇은 층이며, C에 메시
큰 과제가 있습니다. 작은 과제로 나누어 분석합니다. 나는 기본 모델을 가지고있다. 마스터, 작업자 및 수신기. 마스터는 작업을 생성하여 작업자에게줍니다. 작업자가 완료되면 마스터에서 다른 작업을 요청합니다. 모든 작업이 완료되면 청취자에게 알립니다. 보통 1000 개의 작업을 완료하는 데 약 2 분이 걸리지 않습니다. 이제 일부 작업에 소요되는 시간은 다
이미 만든 하나의 액터를 선택하려고합니다. 여기 코드 : myActor path - akka.tcp://[email protected]:46635/user/myActorName#1444872428
Selection from spec akka://unit-test/user/myActorName None
Selection from spec /user/myA
스프레이에 REST 끝점을 구현 중입니다. 아래의 각 단계를 담당하는 액터의 이름과 흐름이 있습니다. 나머지의 API를 호출하고, 필요한 매개 변수 (ActorSupervisor) 유효성을 전달하는 파라미터 (ValidateActor) 호출 파라미터 값 (DataStoreActor) (3A)에 기초하여 데이터를 얻을 수있는 외부 저장소. 외부 데이터 저장소
나는 기본 생성자와 배우를 만드는 구문을 이해하려는 , 위의에서 object Main extends App {
val system = ActorSystem("MySystem")
val myActor = system.actorOf(Props[MyActor], name = "myactor")
, 우리는 먼저 ActorSystem를 작성하고