akka-persistence

1열

1답변

많은 메시지를받는 영구 액터가 있습니다. 주먹 메시지는 CREATE (사례 클래스)이고 다음 메시지는 UPDATE (사례 클래스)입니다. 따라서 CREATE를 받으면 저장소가이 액터에 대해 비어 있기 때문에 복구를 실행하기 위해 지속성 모드로 넘어 가지 않아야합니다. 그것은 나의 관점에서 낭비하는 성과입니다. 특정 입력 메시지 (CREATE의 첫 번째 메시

0열

1답변

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

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

1열

1답변

카프카 이벤트 소싱을 구현하는 Akka - 지속성 저널 쓰기 저널의 다른 옵션 중

로, 카프카는 "외부"에서 매우 합리적인 선택 보인다 그것은 좋은 생태계가를 그것을 잘 을 설명하는 그것은 자연적으로 스트리밍 및 청취자가 그러나, Akka 지속성에 찾고, 카프카 저널 커뮤니티가 packag 기여를 통해서만 지원되는 것 같습니다 지원 e는 지난 2 년간 수정되지 않았습니다. 카프카는 좋은 옵션이 아니며 옵션이 더 좋으며 최선의 선택이라면

1열

1답변

Google Protobuf, .proto 파일 쿼리

다음 CRMData 케이스 클래스에 대해 .proto 파일을 만들어야합니다. 나는 다음과 같은 데이터 유형과 혼란을 겪고 당신이 할 겁니다 가장 큰 문제는 GUID를 (나는 그 UUID이 무엇인지 가정) 아니라는 것이다 case class CRMData( var customerShipToGroups : Map[String, Map[UUID, Shi

0열

1답변

Akka.NET에서 전체 액터 시스템의 상태를 저장할 수 있습니까?

나는 Akka.NET을 읽고 숙련 된 인물이며, 내가 개발할 매우 기본적인 온라인 멀티 플레이어 게임에 적합하다고 생각한다. 저는 Akka.NET 내의 Persistence 모듈에 특히 관심이있었습니다. 내가 할 수있는 일이라면 언제든지 내 전체 액터 시스템의 스냅 샷을 가져 와서 선택한 시점에 스냅 샷을 복원하는 것입니다 (본질적으로 게임 상태의 저장 /

0열

2답변

akka 영구적 인 액터 테스트 이벤트가 생성되었습니다

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 - 게시/구독 패턴으로 AtLeastOnceDeliveryReceiveActor를 혼합 할 수 있습니까?

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

0열

1답변

akka sharded 액터 상태를 외부화하거나 발화시키는 방법?

저는 Akka 클러스터링과 개념 증명 작업에 새로운 경험이 있습니다. 제 경우에는 클러스터에서 실행중인 액터가 있고 액터의 상태는 Map [String, Any]입니다. 따라서 요청에 대해 액터는 들어오는 메시지를 기반으로 액터에게 새로운 엔터티 액터와 데이터 맵을 생성합니다. 여기서 문제는지도가 바로 지금 메모리에 있다는 것입니다. redis 또는 ign

1열

1답변

Akka 지속성 : 그것은 그들을 읽고, 내가 IntelliJ에 그것을 실행하면</p> <pre><code>cassandra-journal { contact-points = [${?CASSANDRA_HOST}] } </code></pre> <p>되어 내 <code>/src/main/resources/application.conf</code> 파일에서 application.conf

에서 카산드라의 설정을 읽을 수 없습니다, 나는 같은 카산드라 호스트의 값을 덮어 쓰기하고 벌금. 그러나 항아리를 만들고 Docker 컨테이너에서 실행하면 CASSANDRA_HOST의 값은 항상 127.0.0.1이고 포트는 9042입니다. 다른 값을 하드 코드하려고했으나 application.conf 파일을 읽지 않는 것으로 보입니다. 는 (필자는 .jar