akka

0열

1답변

AskTimeoutException : [5000 ms] 후에 시간 초과 요청

REST API에 akka-http를 사용하고 AccountActors에 akka 액터를 사용하여 통화 거래 시스템을 구축하려고합니다. post { (path("accounts"/"move-money") & entity(as[MoveMoneyRequest])) { moveMoneyRequest => complete( (bankA

1열

1답변

Akka 액터의 수신 기능을 두 개 이상 작성하십시오.

저는 Find, Query과 같은 일부 메시지를 관리하는 Akka 액터를 가지고 있으며, 다른 메시지 유형으로 액터를 전달합니다. 이러한 액터는 새로운 유형의 메시지로 응답합니다. 위의 예에서 class Actorbase extends Actor { override def receive = { /* The two message below

1열

1답변

높은 처리량에 대한 Akka http 예외 예외 - java.io.IOException : 시스템에 열린 파일이 너무 많습니다.

akka-http에 200k 개의 메시지를 보내려고합니다. protected val someRouts: Route = pathPrefix("foo") { pathEndOrSingleSlash { put { entity(as[Foo]) { foo => log.debug(s"/foo update $foo")

0열

1답변

Akka/플레이 설정 파일

I가 작동 다음 예제 설정 나 blocking-io-dispatcher { db-backup-context { thread-pool-executor { core-pool-size-factor = 3 core-pool-size-max = 10 } } } 내가 코어 풀 크기에 읽기, 핵심 풀 크기 최대 않았다 어떻게

0열

1답변

ClusterSharding을 사용하여 Akka 클러스터에 엔티티 ID 저장

클러스터의 노드에서 엔티티 (액터)를 분할하기 위해 ClusterSharding을 사용할 akka.net 클러스터가 있습니다. 클러스터 위에 앉아 있으면 엔티티를 만들고 검색하기위한 엔드 포인트를 제공하는 표준 REST 스타일 API가 될 레이어가있다. 이 API를 통해 현재 클러스터에있는 모든 엔티티의 ID를 반환 할 수 있기를 원합니다 (일반적으로 RE

0열

1답변

TTL

내가 akka 스트림을 사용 SQS을 들으려고 를 사용 akka 스트림과 상태를 관리하고이 코드를 사용 Q 의에서 내가 메시지를 얻을하는 방법 : 나는 이미 댓글을 달았습니다 implicit val system = ActorSystem() implicit val mat = ActorMaterializer() implicit val ec = Executi

2열

1답변

Akka에서 패턴을 묻습니다.

Akka에서 물어보기 패턴과 관련하여 질문이 있습니다. 내 응용 프로그램의 ask 패턴을 사용하여 액터를 호출합니다. 위라고 배우가 같은 두 번째 배우 호출 그러나 (actor1Ref ? msg) mapTo[ResponseMsg] : 내 응용 프로그램은 일반 클래스 (안 배우 자체)이다 secondActor ! msg(sender) 을 그리고 실제

2열

1답변

Akka 페이로드 예외 캐치

akka가 던진 예외를 초과해야하는 페이로드를 잡아야합니다. 이는 페이로드가 설정 파일에 설정된 허용량을 초과하는 경우 응답이 시간 초과로 끝나기 때문입니다. 이 시나리오 대신, 시간 초과를 기다리지 않고 페이로드가 초과 될 경우 예외 akka throw를 catch하고 싶습니다. 누구든지이 문제를 어떻게 해결할 수 있습니까?

1열

1답변

Akka 스트림에서 Kafka Zookeeper 끝점을 지정하는 방법 Kafka ConsumerSettings

나는 구름이있는 곳에서 실행되는 Kafka Broker를 가지고 있으며, 명령 줄 소비자 도구를 통해이를 소비하려고 할 때 메시지를 소비 할 수 있습니다. 그러나 내가 akka-stream kafka ConsumerSettings에 동일한 끝점을 넣을 때 작동하지 않습니다. 예 : - bin/kafka-console-consumer.sh - 사육자 호스트

1열

1답변

Groovy에서 Akka AbstractActor를 구현하면 컴파일러 오류가 발생합니다.

Groovy 2.4.7은 Akka Java API (예 : com.typesafe.akka:akka-actor_2.11:2.5.4)를 사용합니다. 내가 AbstractActor을 구현하기 위해 노력하고 Java/Akka API와 그루비 자체 사이의 잠재적 인 충돌로 실행 해요 : class MyActor extends AbstractActor {