actor

0열

1답변

스케이프 akka 배우 모델을 사용하여 인생 게임에서 이웃 배우를 호출합니다.

저는 초보자이지만 자바와 C++로 경험했습니다. 이제는 Conway의 평행 게임을 구현하기 위해 akka 배우 모델을 사용하고 싶습니다. 내 생각은 50 * 50 격자를 만들고, 각 셀은 배우이고, 배우에게 메시지를 전달하여 업데이트합니다. 액터를 만드는 방법은 다음과 같습니다. class World(row: Int, col: Int, step: Int)

0열

1답변

배우가 akka에서 "자체"를 묻는 올바른 접근 방법은 무엇입니까?

저는 현재 한 배우에게서 같은 종류의 다른 배우에게 메시지를 보내는 적절한 방법을 찾고 있습니다. 처음에는 "스스로"(자기) 물어 보려고했지만, 곧 나는 이것이 가능하지 않다는 것을 이해했습니다. 자신에게 메시지를 보내지 않고 "대기 중"프로세스를 처리하는 동안 응답을 기다립니다. 이제 내 질문 : 동일한 유형의 배우를 요청할 권리 방법은 무엇입니까? 내가

1열

1답변

액터가 공유 된 불변 읽기 전용 상태를 주기적으로 대체하도록 허용하는 것이 "ok"입니까?

나는 주기적으로 다른 곳에서 어떤 상태를 읽는 actor을 가지고있다. 이제 저는이 액터에게 "지금 업데이트하십시오.", "내 읽기 전용 상태를 새로 고침 해주십시오"또는 "다시 시작하십시오"와 같은 메시지를 보낼 수 있으며 akka가 제공하는대로 "스케줄러"를 내장 할 수 있다는 사실을 좋아합니다. 나를 위해 + 그받은 편지함. 이러한 모든 기능은 정말

1열

2답변

Akka 로깅 패턴을 변경할 수 없습니다

그냥 내 학사 학위 논문을위한 작은 배우 응용 프로그램을 구축하고 지금은 일부 로깅을 추가하려고합니다. 배우 시스템 내부에 로그인하려면 로깅을 사용하고 akka는 백그라운드에서 logback-classic을 제공합니다. 로깅은 잘 작동하지만 logback.xml에서 액터 시스템의 패턴을 변경하면 변경되지 않습니다. 누구나 slf4j를 통해 로깅하고 전역 패

1열

3답변

akka/scala의 특성에서 ActorSelection 검색

scala/akka를 처음 사용했습니다. 나는 형질을 만들고이 형질로부터 배우를 문맥에서 또는 actorSystem으로부터 직접 찾아야한다. 그러나 나는이 특성이 Actor를 확장하거나 Actor와 혼합되도록하지는 않습니다. 할 방법이 있습니까? 감사합니다.

1열

2답변

ActorSystem 내에서 스프레이 클라이언트를 사용하여 라우팅 구현

저는 REST 웹 서비스를 호출하는 데 사용되는 스프레이 클라이언트가 있습니다. 현재 (new GeoSprayWebClient 사용)이 클라이언트의 인스턴스를 만들고 (아래 코드 참조) 내 액터 내에서 REST 요청을 재사용하고 있습니다. 그러나 서비스의 단일 인스턴스는 모든로드를 처리 할 수 없습니다. 따라서 REST 서비스의 복제본을 소개하고자합니다

4열

1답변

디자인 패턴 : 하나의 논리적 메시지를 처리하는 액터 체인을 구현하는 방법

저는 Akka를보기 시작했습니다. 배우들을 파이프 라인으로 구현하고 메시지를 처리하기 위해 협력하는 적절한 방법에 대해 궁금합니다. 내 질문을 설명하기 위해 사용 사례를 보자 나는 협력 배우로 만들 수있는 "결정"을 나타내는 메시지가 있습니다. 여러 "유권자"를 만들 수 있기를 원합니다. 모든 유권자는 (자신의 전략과 규칙에 따라) 결정을 내릴 때 의견을

0열

1답변

비 활동적인 사용자 및 비 기능적 사용자를위한 사용자 이야기

주 응용 프로그램이 있습니다. 필자에게는 주 애플리케이션에 대해 두 가지 전형적인 인간 행위자가 있으며 많은 사용자 스토리가 작성되었습니다. 그러나 주요 응용 프로그램은 작업하기 위해 크롤러, 스케줄러 및 관리 응용 프로그램이 필요합니다. 논문은 배우로 간주됩니까? 나는 그들이 주 앱의 외부에 있으며 목표를 달성하기 위해 직접 상호 작용하지만, 비 개발 팀

7열

1답변

수신 메서드 내에서 미래를 호출하고 그 후에 액터를 중지합니다.

저는 어떤 작업을 수행하는 액터들을 생성하고 있습니다. 이러한 액터 중 일부에서는 Future을 반환하는 타사 API를 호출합니다. MyActor extends Actor { .... def receive = { case MsgA => { ... //this evaluates to a Future val p :

12열

1답변

액자 간 Akka 회로 차단기

액터 풀이 사용하는 공유 외부 리소스 (파일 저장소)가 있습니다. 파일 저장소에 대한 새로운 요청이있을 때마다 전달 된 외부 시스템에 대한 참조로 요청을 채우기 위해 새 액터가 만들어집니다. 액터 당 회로 차단기를 만드는 현재 접근 방식은 이 외부 리소스에 대한 일련의 작업을 수행하는 각 '요청'에 대해 새 액터가 만들어집니다. CB 인스턴스가 너무 많습니