akka-persistence

0열

1답변

API에서 주기적으로 작성하여 보내야하는 일부 오브젝트를 생성하기위한 간단한 REST API를 빌드하고 있습니다. 객체의 특성은 중요하지 않으며 REST 인터페이스 (Spray, Play Framework 등)를 지원하는 프레임 워크도 중요하지 않습니다. 내 질문은, Akka를 사용하는이 시스템에 대해 확장 가능한 액터 디자인이 무엇이겠습니까? 서비스가 중

1열

1답변

높은 비율의 메시지로 액터 상태를 유지하는 방법

과도한 속도의 메시지가있는 액터를 사용하고 싶습니다. 배우의 마지막 상태는 내가 셧다운 제가 전에이 val receiveCommand: Receive = { case Cmd(data) => persistAsync(Evt(s"${data}-${numEvents}"))(updateState) case "snap" => saveSna

1열

1답변

정상적으로 시스템을 종료하기 위해 지속성 프로세스가 완료되었는지 어떻게 확인할 수 있습니까? akka 배우를 사용

는 - 나는 상태 for (i <-0 to 100000){ persistentActor ! Cmd("foo"+i) } 의 업데이트 배우에 메시지의 무거운 속도를 보내고 난 지속성 프로세스가 완료되었는지 확인 할 수있는 방법이 val receiveCommand: Receive = { case Cmd(data) => persi

2열

1답변

모든 이벤트가 지속 된 후에 액터 상태를 업데이트하십시오.

영속 액터의 수신 메소드에서 유지하려는 이벤트를 묶음으로 받고, 모든 이벤트가 지속 된 후에 만 내 상태를 다시 업데이트하십시오. 어떻게해야합니까? def receive: Receive = { ... case NewEvents(events) => persist(events) { singleEvent => // Upd

7열

1답변

확인 된 전송을 사용한 Akka 지속성이 일관성없는 결과를 나타냅니다.

저는 Akka 지속성을 가지고 놀았으며 이해를 테스트하기 위해 다음 프로그램을 작성했습니다. 문제는이 프로그램을 실행할 때마다 결과가 달라진다는 것입니다. 정답은 49995000이지만 항상 그런 것은 아닙니다. 각 실행 사이에 업무 일지 디렉토리를 정리했지만 아무런 차이가 없습니다. 누가 잘못되었는지 알 수 있습니까? 이 프로그램은 1에서 n까지의 모든 숫

0열

2답변

Akka의 컨텍스트. 이상한 동작으로

PersistentActor에서 컨텍스트를 사용할 때 이상한 동작이 발생합니다 (지속성이 문제의 원인과 관련이 있는지 확실하지 않음). 내 코드는 다음과 같습니다. class MyActor extends PersistentActor { import context._ // Messages case object Start

1열

1답변

akka 지속성 여부

현재 응용 프로그램은 Akka eventstream 및 해당 게시/구독을 사용하여 많은 양의 데이터를 가져오고 게시 및 이벤트에 대한 데이터를 수신 할 때 구독자가 있습니다. 이 설계는 게시자/구독자와 같이 문제가 발생하면 이벤트를 잃을 위험이 있습니다. Akka 지속성을 사용하여 여기에 의미가있는 경우 나는 몇 가지 이유 1) 공유가없는 노트 스냅 샷 이

0열

1답변

akka 이벤트 소싱 (akka-persistence)에서 병렬 저널 배우를 사용하는 방법

이벤트 소싱 (akka-persistence)을 테스트하고 필자 자신의 필기장 플러그인을 작성했습니다. 그러나 성능 테스트를 수행 할 때 모든 CPU 리소스가 사용되는 것은 아니라는 사실을 금방 알 수있었습니다. 저널에 메시지를 쓰는 클래스는 배우입니다 (예 : 모든 쓰기 작업을 연속적으로 실행 함). 이 저널 액터의 여러 인스턴스를 사용하여 저널 백엔드에

0열

1답변

부트 스트랩 데이터 재생 프레임 워크 2.3.3

나는 ('액티베이터 실행'을 실행 한 후) 애플리케이션이 처음 생성 될 때 데이터가 미리로드되기를 원하는 플레이 프레임 워크의 프로젝트를 가지고 있습니다. 그러나 import play.*; import play.jobs.*; import play.test.*; import models.*; @OnApplicationStart public cla

1열

1답변

스냅 샷 플러그인과 이벤트 저장소의 메모리와 CPU가 가장 가벼운 조합은 무엇 일 수 있습니까?

내부 메트릭 수집 서버 솔루션을 위해 POC 용 Akka 지속성을 사용하고 있습니다. 우리는 가능한 한 빛 (메모리 및 CPU 단위)을 유지하려고합니다. 우리는 inmemory 저널과 파일 스냅 샷을 사용하고 있습니다. 모든 것이 작동하지만 유일한 문제는 우리가 가지고있는 스냅 샷의 수입니다. 우리는 이미 마지막 스냅 샷 (퍼시스턴스 액터 당 당연히)을 제