Come recuperare i messaggi in Akka Actors ora che le cassette postali durevoli vengono rimosse?

Question

Stavo lavorando con l'ultima versione di Akka quando ho notato che le cassette postali durevoli ora vengono rimosse da Akka.

Ho bisogno di assicurarmi che i miei messaggi vengano ripristinati al riavvio dopo l'arresto. Esiste un modo alternativo di lavorare senza cassette postali durevoli o un'implementazione personalizzata da parte di qualcun altro.

Ho provato anche Akka Persistence ma esso riproduce i messaggi e non voglio inviare gli stessi messaggi due volte in caso di crash, dato che tutti i messaggi sono costosi da eseguire.

Answer 1

Sebbene questa soluzione non rappresenti esattamente una soluzione con Akka Actors, risolve il problema originale qui in questione.

Invece di usare Akka qui, credo che sia un'idea migliore usare qualcosa come Kafka insieme a flussi reattivi con qualcosa come akka/reactive-kafka.

Un sistema come questo è molto buono per la persistenza e offre una semantica molto buona per preservare la coda dei messaggi in caso di arresto anomalo. Questo è molto meglio di memorizzare il messaggio da qualche parte che deve essere elaborato, e in generale funziona meglio.

Non deve essere Kafka, ma qualsiasi back-end che può essere collegato a un flusso reattivo (implementazione di Akka o altro).

Answer 2

Akka Persistence riproduce gli eventi creati in base ai comandi ricevuti. Gli eventi vengono generati dai messaggi di comando dopo la convalida e non dovrebbero essere in grado di creare stati di attori non validi.

Ciò significa che non vengono riprodotti i messaggi iniziali ricevuti (comandi), ma è possibile mantenere gli eventi meno costosi da applicare per ricostruire lo stato di un attore dopo l'arresto. Inoltre, è possibile utilizzare snapshots per ripristinare direttamente lo stato.

Modifica: Come menzionato i commenti è vero che solo lo stato dell'attore è persistente e sopravvive all'incidente. Questo stato riflette solo i messaggi consumati e non quelli che risiedono ancora nella cassetta degli attori.

Tuttavia, invece di inviare messaggi a un attore che verrebbe quindi archiviato in una cassetta postale duratura, un'alternativa potrebbe essere per il "destinatario" di estrarre messaggi da un attore persistente che memorizza l'elenco di messaggi come parte del suo stato.

UntypedPersistentActorWithAtLeastOnceDelivery come parte della persistenza akka offre un'altra possibilità in cui il mittente si prende cura dei messaggi persistenti.

Mi rendo conto che non si tratta di sostituzioni drop-in per cassette postali durevoli poiché richiedono un ripensamento del sistema. Tirare il lavoro dai consumatori ha funzionato per me finora. Inizialmente abbiamo considerato anche i prodotti Message Queue (RabbitMQ con code resistenti) ma dal momento che i nostri elementi di lavoro iniziali provengono da un db, possiamo occuparci di un crash di akka senza messaggi durevoli.