akka

0열

1답변

작업자 노드에 작업을 배포하기 위해 Master-Worker Pattern과 함께 Akka 클러스터를 사용하고 있습니다. Kafka 및 JMS 메시징에는 대기열 또는 주제의 메시지를 찾아 볼 수있는 API가 있습니다. 모든 발신자와 수신자 중에서 Akka 시스템의 메시지를 추적하는 가장 좋은 방법은 무엇인지 알 수 있으므로 효과적으로 문제를 해결할 수 있습

1열

1답변

DTO를 Alpakka Cassandra에 저장하십시오.

안녕하세요 저는 datastax 드라이버를 사용하여 내 자신의 Cassandra 커넥터를 만듭니다. 하지만 메모리 누출 문제가 있으므로 Cassandra 커넥터가있는 Alpakka de lightbend와 같은 다른 솔루션을 고려하기 시작합니다. 하지만 가난한 문서를 확인한 후에는 CQLSH 쿼리와 함께 커넥터를 사용하고 있으므로 내 마음이 바뀌었고 제 경

1열

1답변

메시지가 Akka Streams Flow 또는 Sink에 도착하는 속도를 측정하십시오.

저는 Akka Streams 애플리케이션을 작성했으며 정상적으로 작동합니다. 내가하고 싶은 일은 Akka Streams 애플리케이션을 실행하는 JVM intance에 JMX 콘솔을 연결하고 내 싱크 및 플로우로 들어오는 메시지의 양을 조사하는 것입니다. 이것이 가능합니까? 나는 봤지만 구체적인 방법을 찾지 못했습니다. 내 응용 프로그램의 마지막 단계는 카산

0열

1답변

Akka 스트림은 내가 데이터 <pre><code>A A A B B C C C C ... (very long) </code></pre> <p></p>의 정렬 된 스트림이 작은 스트림

에 감소 그리고 난 형태로 집계 스트림으로 변환 할 : (A, 3) (B, 2) (C, 4) Akka Streams에서 어떤 연산자를 사용할 수 있습니까? Source.fromPublisher(publisher) .aggregateSomehow() // ? .runWith(sink) 나는 .groupBy으로 검토 한하지만 내가하지

0열

1답변

이 코드는 상태가 좋은 akka 스트림으로 변환 될 수 있습니까?

내가 akka 스트림을 사용하여 SQS를들을려고하고이 코드를 사용 Q 있어에서 내가 메시지를 얻을 : (다음을 ACK) 물론 이 코드는 메시지를 하나씩 얻을를 : implicit val system = ActorSystem() implicit val mat = ActorMaterializer() implicit val ec = ExecutionConte

0열

1답변

Akka.NET 스트림

웹 서비스 요청이 응답 할 때까지 10 초마다 10 초마다 웹 서비스 요청을 어떻게 재생합니까? 나는 RecoverWithRetries 및 InitialDelay을 시도했지만, 첫 번째 복구 즉시 웹 서비스 호출을 재생합니다 : FromThirdOfContract().RecoverWithRetries(e => { return Source.From

-1열

1답변

Akka 실행 컨텍스트 대 미래 글로벌 컨텍스트

Akka 디스패처 대 글로벌 실행 컨텍스트 간의 기본적인 차이점을 알고 있습니다. 는 I는 평균 103 밀리 주위에 평균 scala.concurrent.ExecutionContext.Implicits.global import scala.concurrent.ExecutionContext.Implicits.global val resultF = (0 t

0열

1답변

Akka.NET - 게시/구독 패턴으로 AtLeastOnceDeliveryReceiveActor를 혼합 할 수 있습니까?

나는 가입자가 AtLeastOnceDeliveryReceiveActor (http://getakka.net/articles/persistence/at-least-once-delivery.html) 나는 그것이 인해 사실로 작업을 할 수없는 곳 패턴을 가입/(http://getakka.net/articles/clustering/distributed-publi

0열

1답변

개체가 패키지 akka

의 구성원이 아닌 경우 Scala, sbt 및 akka로 첫 번째 단계를 수행하려고합니다. akka.actor_ 패키지를 내 스크립트로 가져오고 싶습니다. 내 build.sbt은 다음과 같습니다 name := "hello" version :="1.0" scalaVersion := "2.12.3" resolvers += "Typesafe Repos

10열

1답변

Akka 클러스터링 - 노드 당 하나의 관리자 액터

저는 매우 많은 수의 액터를 쿼리하여 매우 많은 수의 메시지를 보내거나받는 애플리케이션에서 작업하고 있습니다. 응용 프로그램이 단일 시스템에서 실행될 때 메시지가 단일 JVM의 경계 내에서 전송되기 때문에 이는 문제가되지 않습니다. 그러나 여러 노드 (akka 클러스터 사용)에서 응용 프로그램을 실행하면 각 노드가 이러한 액터의 일부를 호스팅하고 메시지가