I am very new to Akka clustering and working on a proof of concept. In my case i have an actor which is running on a cluster and the actor has state as a Map[String,Any]. So, for any request the actor receives it based on the incoming message it create a new entity actor and the data map. The problem here is the map is in memory right now. Is it possible to store the sharded actor state somewhere in redis or ignite ?
How to externalize akka sharded actor state to redis or ignite?
180 views Asked by dks551 At
1
There are 1 answers
Related Questions in AKKA
- Akka actor invoked with a function delegate - is this bad practice?
- Akka supervisor on stop of subordinate
- Scala - TCP Packet frame using Akka
- Akka-http process requests with Stream
- Multiple dispatcher for spray
- Spray Dead Letter msg
- ActorNotFound Exception trying to run Spark 1.3.1 on windows 7
- What's the best way to get members of an Akka cluster?
- Is it possible to await for second response in Scala
- How to keep Akka running all the time in Play 2.3
Related Questions in AKKA-CLUSTER
- What's the best way to get members of an Akka cluster?
- How to broadcast message to all actors in an AKKA cluster in java?
- Combining Spray Routing + Actor Pattern Matching
- Akka member(actor) lookup in cluster
- Akka cluster sharding: recovering on journal corruption
- How to configure akkacluster using SSL support
- Sending Akka HttpEntity between actors
- How can I test a publisher to a DistributedPubSub in Akka Cluster?
- How can I test a Subscriber's receive method in Akka Cluster?
- AKKA- how to block the creation of an actor if its name is not uniqe in the cluster
Related Questions in AKKA-PERSISTENCE
- Akka persistence testing approaches
- Akka cluster sharding: recovering on journal corruption
- How to retrieve all journal events using Akka persistence queries?
- Who is in charge of re-create persistant actor instance after JVM crash?
- What could be the lightest memory- and CPU-wise combination of snapshot plugin and event store?
- How to recreate dynamically created persisted AKKA actors after crash
- Akka.NET - Is it possible to mix AtLeastOnceDeliveryReceiveActor with Publish/Subscribe pattern?
- Change to Persistent Query from deprecated PersistentView
- How to externalize akka sharded actor state to redis or ignite?
- Would storing a rich object as an actor with persistance be a good idea?
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Popular Tags
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
You should probably start by having a look at akka-persistence (the persistence module included in akka). The snapshotting part is meant to persist the state directly, but you have to start with the command/event-sourcing part, the snapshotting part being an optional enhancement.
Then you can combine this with automatic passivation of your sharded actors after a certain inactivity timeout.
With the above, you'll have a solution that persists the state of your actors in an external storage system to free up memory, restoring your actor's state whenever they come back to life.
Last step would be to see which storage backends are available for akka-persistence and match your requirements, you can implement your own of course.