actor

1열

1답변

신참 .. akka 버전 사용 : 자바 API를 통해 akka-actor_2.11 (2.4.8 참조). PDF 문서를 생성하기위한 액터를 개발하려고합니다. 이러한 PDF 문서는 크기가 클 수 있으므로 배우가 요청을 처리하는 속도를 조절하고 싶습니다. 또한 측면 요구 사항으로, PDF 생성 요청을 기본 액터의 우선 순위에 따라 처리 할 수있는 "우선 순위 지

3열

1답변

신뢰할 수있는 액터가 아무런 문제없이 얼마나 많은 읽기 작업을 처리 할 수 있습니까?

목표 : 필자는 Azure Service Fabric 기반 웹 응용 프로그램에서 매우 인기있는 페이지 (5 분에 1 백만 명)를 사용합니다. 데이터 영역과 프론트 엔드 API 계층 사이에 일종의 캐시 계층을 만들고 싶습니다. 솔루션 :이 목적을 위해 읽기 전용 작업에 대해 하나의 메서드 인 GetFrequentlyAskedPage()만을 수행하는 신뢰할 수

0열

1답변

분산 전자 메일 사서함 용 Akka 배우 시스템 디자인

Akka를 기반으로 분산 전자 메일 사서함 시스템을 만들고 싶습니다. 내 앱이 시작될 때 모든받은 편지함 액터를 만들고 싶습니다. 10 초 간격으로 메일을 받도록 스케줄러를 시작합니다. 하지만 이러한받은 편지함 액터를 만드는 방법에 문제가 있습니까? 클러스터에 액터를 만들거나 액터가 있으면 참조 할 수 있습니까? 액터 이름은 데이터베이스의 사서함 UUID

0열

1답변

일부 속성

에 의해 버전/Akka 메시지를 고유하게 나는 다음과 같은 사용 사례가 있습니다 배우가 key:value 쌍으로 구성 외부 소스에서 데이터를 소비합니다. 그런 다음 그들은 이전의 것들을 건너 뛰고 key과 최신 value에서 몇 가지 작업을 수행해야하는 배우에게 전달됩니다. 기본적으로 사서함을 1의 용량을 가진 "하위 주제"로 분할하려고합니다. Akka에서

4열

1답변

Akka Actor Test : TestProbe를 사용한 자동 응답

메시지를받을 때마다 응답으로 응답하도록 테스트 프로브를 얻으려고합니다. 나는 내 테스트에 다음 코드를 작성했지만 작동하지 않습니다 val chgtWriter = new TestProbe(system) { def receive: Receive = { case m => println("receive messagereplying wi

0열

2답변

상위 공급 업체 액터에서 액터 처리를 다시 시작하지 마십시오

우선, 저는 Akka와 배우 모델을 처음 접했기 때문에 모든 것을 잘못하고 있습니다. 나는 스트림 소스로부터 데이터를 가져 와서 내부 상태를 가진 하위 프로세서 액터로 전달하는 입력 액터가 있습니다. 연결이 끊어지면 입력 액터가 중단되어 다시 시작됩니다. 문제는 추가로 자녀를 다시 시작하게하여 자녀를 상태를 잃게하는 것입니다. 입력 스트림이 복구 될 수 있

2열

1답변

Akka 액터가 데이터베이스에서 상태를 읽습니다.

데이터베이스에서 액터 상태를 초기화해야 할 때 패턴을 물어보고 싶습니다. 나는 Future [...]를 반환하는 DAO를 가지고 있으며, nonblocking 메시지가 될 normaly는 미래의 완성에 대해 배우에게 보내야한다. 그러나이 경우는 다릅니다. 초기화가 완료되기 전에 액터 사서함에서 메시지를받을 수 없습니다. 데이터베이스가 완료 될 때까지 기다리

8열

2답변

은행 모델링을 통한 액터 모델 이해

은행을 모델링하여 actor model이 어떻게 작동하는지 이해하려고합니다. import time from threading import Thread bank = {'joe': 100} class Withdrawal(Thread): """ Models a concurrent withdrawal for 'joe'. In this

0열

1답변

Akka : Java를 사용하여 등록되지 않은 사용자 정의 akka 감독 전략

Akka 수명주기와 Akka 액터 감독 전략을 탐색 할 것입니다. 나는 내 자신의 예외를 만들고 있으며, akka의 수명주기와 복구 전략을 탐구하기위한 public SupervisorStrategy supervisorStrategy() 메서드를 재정의합니다. 나는 계속 EsclateException 로그를 던져 배우를 종료하지 않을 경우 receive()

2열

1답변

깔끔한 방법으로 테스트해라. 스카치가 어색해진다.

나는 수신 방법의 상태 전환을 시험하려고하고있다. 발견 this stackoverflow 게시물,하지만 또한 명확하게 솔루션을 제공하지 않습니다. 아래의 단순화 된 코드를 찾아주세요 : - package become_unbecome_basics import akka.actor.{Actor, ActorSystem} import akka.testkit.{