나는 (MongoDB의에) 데이터베이스 쿼리의 수를하고 다음 해당 데이터베이스 쿼리에 의해 반환 된 기록에 대한 처리의 적지 않은 금액을 수행하는 웹 서비스가 있습니다. 각 웹 요청은 이러한 요청 중 약 15-45 개를 실행해야하며 이는 각 쿼리 + 처리가 약 20ms가 걸릴 때 허용 할 수없는 페이지 응답 시간을 초래합니다. 캐쉬 미스 비율이 높고 데이터
나는 akka 배우에게 stdin으로부터 메시지를받을 수 있는지 (그리고 어떻게 할 수 있는지) 알고 싶다. 본질적으로, 아이디어는 입력의 모든 라인이 행위자에게 메시지로 보내질 것입니다. > myprogram
DO X
DO Y
...
다음 배우가 메시지를 수신해야하는 이 할 수있는 표준 용액이 있는가 등, "Y는 DO" "X는 DO"? ( spa
Akka 1.1.3 설명서에는 "become 메서드는 많은 다른 것들에 유용하지만 좋은 예는 Finite State를 구현하는 데 사용되는 예입니다 기계 (FSM). " 런타임시 Akka 액터의 구현을 핫 스와핑하는 다른 용도는 무엇입니까? ActorRef 특성에 actorClass 방법은 "become 및 unbecome의 얼굴이 어떤 이해가되지 않습니다
저는 현재 여러 개의 Future을 생성하고 BlockingQueue에 넣는 작업을 수행하기 위해 Akka (Java API/라이브러리)를 사용하려고합니다. 이제는 Callable에서 처리하는 일부 작업이 새 스레드를 만들거나 새 스레드를 사용할 수있게되기를 기다리는 대신 호출하는 스레드에서 빠르게 실행하는 것이 더 빠를 수도 있습니다. Future<Str
Iterator/Iterable의 결과를 반환하고 결과 노드를 List의 노드와 일치시키는 두 개의 데이터베이스 버전에서 두 개의 XPath- 표현식을 동시에 실행하려고합니다. 나는 가장 좋은 것은 다른 스레드가 BlockingQueue의 결과를 정렬하는 것입니다 반면, ExecutorService를에서 두 개의 스레드에서 두 쿼리를 실행하고 Blockin
Java API를 사용하여 Akka Camel 통합 모듈을 사용하는 예를 보여줄 수 있습니까? 요청을 처리하기 위해 일부 Akka 액터를 병렬로 시작한 다음 각각이 부분 결과를 웹 브라우저 (Comet 스타일)로 푸시하는 REST 서비스가 호출되는 유스 케이스가 있습니다. 한 예를 보았습니다 here하지만 불행히도 저는 스칼라를 알지 못합니다. 자바에서 이
발신자가 n 초마다 메시지를 보내는 발신자와 함께 2 명의 Akka 액터를 실행하려면 어떻게해야합니까? 아니오 Scala.Actors 라이브러리로 방법을 루프 - 반응하지 있기 때문에 나는 어떻게 든, 다음은 컴파일되지 않습니다 붙어이고 생산 : 메소드를 오버라이드 (override) 유형 => Caller.this의 특성 배우에 나타납니다 .받다; 방법은
Akka 1.0 사용 올바르게 읽히고있는 akka.conf에서 이벤트 처리기 수준을 ERROR로 설정했지만 stdout-debug-output을 중지 할 수 없습니다. 내 SYS-아웃 이러한 메시지로 오염되어있다 : 당신은 당신의 logback의 설정을 변경해야 https://github.com/jboner/akka/blob/v1.0/config/akka-
2.0-SNAPSHOT Akka 클러스터 기능을 테스트하는 데 관심이 많았지 만, Java에서이 작업을 수행하고 싶습니다. 내가 여기에 예제를 읽고 : http://letitcrash.posterous.com/clustered-actors-with-cloudy-akka 그러나 API는 (? Cluster.startLocalCluster()가 더 이상 존재하