akka-persistence

    0

    1답변

    저널 지속성 플러그인을 사용하는 Azure에 Akka 응용 프로그램을 배포하려고합니다. 내가 사용해야하는 지속성 플러그인과 관련하여 제대로 된 조합을 찾을 수 없습니다. 몽고 드라이버 akka - 지속성 - 몽고와 푸른 문서 저장 : 지금까지 내가 들여다 akka - 지속성 - 몽고는 SSL을 지원하는 최신 반응성 몽고 버전과 호환되지 않기 때문에이 작동하

    1

    1답변

    AtLeastOnceDelivery 영속 액터를 사용하고 있습니다. 우리는 엄청난 양의 확인되지 않은 메시지를 받고 있으며,이 수가 너무 클 경우 OutOfMemoryError가 발생합니다. 확인되지 않은 메시지가 확인 될 때까지 메모리에 보관하지 않고 디스크에 미확인 메시지를 보관하도록 AtLeastOnceDelivery 액터를 구성 할 수있는 방법이 있

    1

    1답변

    장비로 발생하는 이벤트 (시간당 1 백만)를 처리하는 응용 프로그램을 작성하고 있습니다. 일부 이벤트는 시작 이벤트, 상태 (x-times) - 이벤트 및 종료 이벤트가 포함 된 집계됩니다 (그리고 긴 기간 (예 : 48 시간)). 기타는 즉시 처리 할 수있는 단일 이벤트입니다. 적어도 한 번 이벤트가 처리 될 것이라는 보장을 받으려면 나는 akka-per

    1

    1답변

    나는 CQRS Akka 배우 앱의 질의면을하고 있습니다. 쿼리 배우는 클러스터 샤드로 설정되며 하나의 지속성 쿼리 스트림의 이벤트로 채워집니다. 내 질문은 : 클러스터 파편에있는 배우 중 하나가 그것을 복구하는 방법을 다시 시작하면? 전체 클러스터 샤드를 종료하고 모든 이벤트에 응답 하시겠습니까? 클러스터 샤드에있는 액터를 영속 액터로 만들고 쿼리 측에만

    7

    2답변

    내 ES-CQRS 아키텍처에서 읽기 측을 구현하려고합니다. 이제 나는이 같은 지속적인 배우 있다고 가정 해 봅시다 : 이벤트가 지속됩니다 때 object UserWrite { sealed trait UserEvent sealed trait State case object Uninitialized extends State

    3

    1답변

    저는 최근에 ES 및 CQRS 모델에 대한 여러 동영상을 보았을뿐 아니라 AKKA 영속성에 대한 몇 가지 이야기를 보았습니다. 나는 그들이 무엇에 관한 것인지 알지만 실행될 실제 코드를 작성하는 데 문제가 있습니다. 나는 몇 가지 질문이 있습니다. 보기 및 이벤트 스택을 어떻게 통신해야합니까? 동일한 지속성 ID의 영구적 액터와 뷰 사이에 이벤트가 전달됩니

    1

    1답변

    akka-persistence의 PersistenceQuery를 사용하여 물건을 관리하는 액터에 초기 상태를로드합니다. 시작시 정확히 한 번 재생하기를 원하지만 로그에 기록을 계속 보냅니다. 14:11:28.405 [rooms-akka.actor.default-dispatcher-4] DEBUG a.p.q.j.l.LiveEventsByPersistenceI

    2

    1답변

    Akka가 제공에서 - 최소 한 번 메시지와 함께 영구 배우를 제공합니다 (link) 영구 FSM (link) 둘을 혼합 할 수 있습니까? 영구 상태 머신을 유지할 수 있기를 원하지만 스테이지 변경으로 인해 적어도 한 번만 메시지 배달 보장을 사용하여 다른 액터에게 메시지를 전송하는 이벤트를 발생 시키십시오.

    3

    1답변

    CQRS에서 DB 호출이 필요한 명령의 유효성을 검사하는 가장 좋은 방법은 무엇입니까? 예를 들어, CommitOrder이라는 명령의 유효성을 검사하는 집계가 Order이고 충분한 재고가 없으면이 명령을 허용하고 싶지 않습니다. 이 경우 주문 처리 품목의 재고가 있는지 여부를 명령 처리기에서 어떻게 확인할 수 있습니까? 쓰기 측면에서 읽기 측면을 쿼리 할

    0

    1답변

    우리는 Akka를 메모리 내장 메시지와 함께 사용 중이며 노드 클러스터링을 사용하지 않습니다. 우리는 couchbase를 충분한 공간을두고 처리 백엔드로 사용합니다. 노드가 작동하는 한 모든 것이 잘 작동합니다. 그러나 노드가 다운되면 모든 메모리 내 메시지가 손실됩니다. 우리는 작업자가 이상적 일 때 작업자가 큐에 500 개의 메시지를 요청할 때 작업 디