akka

0열

2답변

CQRS 명령의 정의에 따라 유효성을 검사 할 수 있고 마지막에 유효성 검사가 통과하지 않으면 거부됩니다. 내 명령 유효성 검사의 일환으로 상태 전환이 실제로 필요한지 확인합니다. 따라서 간단한 예제를 보겠습니다. 액터가 상태 A에 있습니다. 명령이 액터로 보내져 상태 B로 이동합니다. 명령이 유효화되고 끝 이벤트가 생성됩니다 StateBUpdated. 그

0열

1답변

Akka 지속성 : ReadJournal.runFold never returns

처음으로 Akka, 특히 Akka 지속성을 실험하고 있습니다. 궁극적으로 이벤트 소스 애플리케이션에서 Akka의 사용법을 재현 할 수있는 작은 장난감 프로그램을 구현하려고합니다. ReadJournal을 사용하여 내 이벤트 스트림을 내 도메인으로 투영하려고 시도 할 때까지 성공했습니다. def main(args: Array[String]): Unit = {

0열

1답변

큰 개체가있는 메시지

Akka.Net에서 올바르게 작동하는 방법에 대한 장단점을 고려하고 있습니다. 기본 OS가 중요하지 않으므로 Akka 태그를 추가했습니다. 비교적 간단한 유형의 10.000 ~ 100.000 개의 개체 목록이 있다고 가정합니다. 각 개체에는 문자열, 2 개의 정수 및 10 개의 double이 있습니다. 제 생각에 각 개체는 100 바이트입니다. 그래서 전체

4열

1답변

Akka 스트림 - 실패 후 브로드 캐스트 및 지퍼가있는 그래프 다시 시작

브로드 캐스트 및 지퍼가있는 흐름 그래프가 있습니다. 무언가 (그것이 무엇이든 상관없이)가이 흐름에서 실패하면, 문제가되는 요소를 전달하고 다시 시작하고 싶습니다. (1,1) (2,2) (3,3) (4,4) 우리는 어떤 일을했습니다에만 인쇄, 그것은 교착, (1,1) (2,2) (3,3) (4,4) (5,5) (6,6) (7,7) (8

0열

2답변

알 수없는 액터의 처리 결과가 단일 타임 아웃

다음 코드를 확장하여 액터 요청 요청에 대해 알 수없는 액티비티로 작동하도록했습니다. implicit val timeout = Timeout(100 millis) val sendRequestActor = context.actorOf(Props(new SendRequest(request)), "Send_Request_".concat(getActorNumbe

0열

2답변

실행 가능한 그래프를 중지하는 방법

akka 스트림으로 내 첫 번째 단계를 얻으십시오. 내가 g.run() 하지만 난 그게 어떻게 중지 할 수 있습니다를 사용하여 그래프를 실행할 수 있습니다 val topHeadSink = Sink.head[Int] val bottomHeadSink = Sink.head[Int] val sharedDoubler = Flow[Int].map(_ * 2)

1열

1답변

Akka : 새로운 HttpRequests를 만들기위한 HttpResponse의 미래

내 목표는 최종 Map [id, Result]를 만드는 것입니다. case class Result(id: String, descr: String) 문제 : 다음 Result은 다음과 같은 경우 클래스는 내가 JSON을 반환하는 API를 치고 싶다. 이 JSON을 구문 분석하고 전체 JSON에서 모든 member_id 필드를 검색 할 것입니다. 1) : me

1열

1답변

복수 메시지 유형 - 스칼라가있는 프레임 워크의 websocket에 대한 액터

스케이프 2.5의 플레이 프레임 워크 2.5에서 websocket을 사용하려고했습니다. 이제 여러 메시지 유형을 교환하고 싶습니다. 그러나 클라이언트가 websocket을 통해 json을 보내면 다음과 같은 오류가 발생합니다. 여러 메시지 유형을 교환하려면 다른 방법을 선택해야합니까? 누락되었거나 더 쉬운 방법이 있습니까? [error] a.a.OneFor

0열

1답변

Akka 클러스터 노드 버전 호환성

akka 클러스터 버전 호환성 사이에 어떤 결함이 있습니까? 예. akka verions가 다른 클러스터의 다른 노드를 시작하는 것이 안전합니까?

4열

1답변

Akka 스트림은 예외를 throw하는 대신 유휴 상태를 유지합니다.

저는 Akka/Scala를 처음 사용하며 아래 코드를 디버그하려고합니다. resultSetParser에 예외가있는 경우 던지지 않습니다. 대신이 코드를 사용하는 서비스는 영원히 유휴 상태입니다. 스트림에서 영원히 기다리지 않고 예외를 throw하도록하려면 어떻게해야합니까? watchException()과 같은 기능이 있나요? watchTermination(