akka

3열

2답변

대기열에서 작업을 공급 받고있는 작업자 그룹이있는 전형적인 상황에 처해 있습니다. 작업자 실패는 일시적이거나 환경으로 인한 것이거나 영구적 인 것이거나 부당한 작업으로 인한 것일 수 있습니다. 작업자의 내부에서 영구적 인 실패 사례를 처리하고 있지만 임시 사례에 대한 재 시도를 어떻게 구현할 수 있습니까? 감독자와 함께 작업자를 다시 시작할 수있게 할 수

1열

1답변

Akka 관리자로부터 예외 세부 정보를 얻으려면 어떻게해야합니까?

새 메시지 Actor이 예상치 못한 메시지를 처리하는 방법을 테스트하고 있습니다. 이 경우에는 GibberishException을 던집니다. 다음은 테스트 지금까지 구현의 : 테스트 : """throw a GibberishException for unrecognized messages""" in { //define a service that cre

2열

2답변

Akka TypedActor의 'Unit'메서드가 시간 초과되었지만 비동기이어야합니다.

Akka TypedActors (1.1.2)를 사용하려고합니다. 나는 같은 인터페이스를 가지고있다. trait Namespace { def cellCount: Int def isEmpty: Boolean def cell(key: String): Option[CellOperations[_]] def cellsLike(key

7열

1답변

Akka는 Scala와 마찬가지로 반응이 있습니까? 또는 디스패처가 처리합니까?

내 이해에 따르면 Actor 클래스를 확장하고 receive를 구현하거나 액터 메서드 중 하나를 사용하여 익명 Actor를 만드는 두 가지 방법으로 액터를 만들 수 있습니다. 여태까지는 그런대로 잘됐다. Akka는 dispatchers (http://akka.io/docs/akka/1.1.3/scala/dispatchers.html)의 개념을 가지고 있으므

8열

2답변

액터 액터 폴트 톨러런스는 어떻게 설정합니까?

나는 Akk Actors에서 내결함성을 얻으려고하고있다. 시스템의 액터가 장기간 처리 할 수 있는지에 따라 달라지는 코드를 작성 중입니다. 나는 두 시간이 지나면 내 처리가 멈추고 (약 10 시간이 걸릴 것입니다) 많은 일이 일어나지 않는다는 것을 알게됩니다. 내 배우가 예외에서 회복하지 못한다고 생각합니다. 액터를 1 대 1로 영구적으로 다시 시작하려

9열

1답변

Akka, Spray 및 내장 된 Jetty 결합

Akka, Spray 및 Jetty가 포함 된 독립 실행 형 JAR을 만들려고합니다. 이상적으로는 외부 파일 없이는 전체 파일을 하나의 파일로 배포하는 것이 이상적입니다. 나는 임베디드 부두 서버 인스턴스 def main(args: Array[String]): Unit = { val server = new Server(9012); serv

3열

1답변

Akka 프레임 워크 (스칼라) - 대규모 복합 상태를 저장하는 에이전트

최근에 akka 프레임 워크를 발견하고 내 프로젝트 중 하나와 잘 어울린다고 느꼈습니다. 나는 지금까지 그것에 매우 감명 받았다고 말해야 만합니다. 내 프로젝트에서 1M + 엔티티에 상태 업데이트를 매우 빠르게 받아야합니다. 당연히, akka 배우가 첫 번째 선택 인 것 같습니다. 그러나 나는 상태 업데이트를 저장하는 에이전트를 사용하는 것이 더 좋지 않을

2열

1답변

Akka REST 서비스 + 파견

나는 here의 예를 따랐다. 잘 됐네. 하지만 이제는 비즈니스 로직을 수행해야합니다. case get:Get => 필요한 비즈니스 로직에는 dispatch 라이브러리가 포함됩니다. 간단히 말해서, 나는 어떤 페이지에 대한 요청을하고, 데이터를 얻고, 어떤 클래스에서 그것을 감싸고 그것을 반환한다. case get:Get => { get.respo

9열

2답변

Akka의 분산 액터

저는 Akka를 처음 접했고 일반적으로 분산 프로그래밍에 익숙하지 않았습니다. Akka의 Mist 구성 요소를 사용하여 HTTP 요청을 비동기 적으로 처리 할 감독 된 액터를 만들었습니다. 모든 것은 현재 로컬 액터가있는 하나의 실제 시스템에서 실행 중입니다. 내가 이해할 수없는 것은 하나 이상의 상자로 진정으로 결함 허용 시스템을 구축하는 방법입니다. A

0열

1답변

AKKA에서 사용되는이 CCAS locking machanizion을 이해하는 방법은 무엇입니까?

방금 akka에서 코드 조각을 발견했습니다. https://codereview.scala-lang.org/fisheye/browse/~raw,r=25521/scala-svn/scala/trunk/test/files/presentation/akka/src/akka/util/LockUtil.scala 내가 아래에 나열된에 관심이 핵심 방법. /** * A