akka

-1열

1답변

이의 내가 소스가 있다고 가정하자 : val source = Source(List(1,2,3)) 어떻게 할 수 있습니까 메시지 배우 같은 소스? sourceActor ! 4

0열

1답변

akka-http를 사용하면 에 설명 된 바와 같이 typesafe 구성을 제공 할 수 있습니다.이 설정은 application.conf입니다. 그래서 축소 된 설정은 다음과 같이 할 수 있습니다 : 나는 응용 프로그램에서 다른 외부 서비스를 호출해야하는 경우 akka.http { client { connecting-timeout = 10

0열

1답변

alpakka 슬릭 커넥터를 사용하여 mysql에 case 객체를 삽입하는 방법

MySQL에 데이터를 삽입하는 코드를 작성 중입니다. 나는 Alpakka Slick Connector를 사용하기로 결정했습니다. 해당 예제 사용 : https://developer.lightbend.com/docs/alpakka/latest/slick.html#using-a-slick-flow-or-sink DB에 데이터를 성공적으로 추가했지만 SQL 명령

0열

1답변

Akka의 EventStream에서 서버 측 이벤트를 어떻게 만들 수 있습니까?

I 시도 : EventStream -> 소스 -> Akka HTTP (SSE) 내가 그것을보고,이 소스가 Akka의 HTTP complete(Source, ...) 에 의해 구체화되기 때문에, 작동하지 않을 수 있고, 구체화에 EventStream에서 메시지를 보낼 수 소스 나 (ActorRef 것을 얻을 수있는 방법이 있나요?)을 ActorRef 필요 내

0열

1답변

맵 (T => Future [U])과 flatMapConcat (T => Source.fromFuture (Future [U])) 사이의 Akka 스트림 차이

싱크를 정의하는 두 가지 방법의 차이점은 무엇인가요? [RandomCdr, Future 하는 Future에 Flow[RandomCdr] .grouped(bulkSize) .flatMapConcat{ (bulk : Seq[RandomCdr]) => Source.fromFuture(collection.flatMap(_.inser

0열

1답변

모든 영구 액터가 메모리에 있습니까?

Akka의 영구 주문 액터가 나타내는 주문이 있습니다 (카산드라에서 말함). 내 시스템에 수많은 주문이 있습니다. 모든 주문 액터는 언제든지 메모리에 상주합니까? 또는 ** 주문 행위자 중 일부는 필요에 따라 카산드라로부터 회수 될 것인가? 어떻게 내부적으로 작동합니까? * 거의 필요하지 않은 엔티티

0열

1답변

Akka SourceQueue가 목록 요소를 보내려면

나는 List[String]과 Source.queue을 가지고 있습니다. 나는이 대기열 문자열 요소를 일정 시간 간격 후에 제공하려고합니다. 다음과 같이 입력하십시오 : val data : List[String] = "" val tick = Source.tick(0 second, 1 second, "tick") tick.runForeach(t => qu

0열

1답변

Akka.Net PreRestart 실행하지 않을 경우 비동기 처리기에서 예외

I가 내가 다시 시작하고 다시 배우로 실패 메시지를 다시 시도하고 다음과 배우 : public class BuildActor : ReceivePersistentActor { public override string PersistenceId => "asdad3333"; private readonly IActorRef _nextActorR

1열

1답변

Akka Stream - Pausable GraphStage (Akka 2.5.7)

다른 액터에서 메시지를 보내 일시 중지/일시 중지 해제 할 수있는 GraphStage를 작성하고 싶습니다. 아래 코드는 임의 번호를 생성하는 간단한 GraphStage을 보여줍니다. 무대가 구체화되면 GraphStageLogic은 StageActor이 포함 된 메시지 (preStart())를 감독자에게 보냅니다. 감독자는 무대의 ActorRef을 유지하므로

0열

2답변

왜이 akka-http 경로 테스트가 성공적으로 완료되지 않습니까?

나는 단순한 경로를 가졌지 만 일부는 개별적으로 성공을 테스트했지만 시간 초과로는 전체적으로 실패합니다. 왜 그런가? val route = (requestHandler: ActorRef @@ Web) => { get { pathPrefix("apps") { pathEndOrSingleSlash { completeWit