I have a use case which is million clients data processed by individual actor.And all the actors created on across multiple nodes and formed as a cluster.
When i receive a message i have to send it to the particular actor in the cluster which is responsible for.How can i map to that actor with AKKA cluster.I don't want it to send to other actors.
Can this use case achievable With Akka - Cluster?
How failure handling will happen here?
I cant understand what cluster singleton is,saying in doc that it will only created on oldest node. In my case i only want all million actors as singleton.
How particular actor in cluster mapped with message?
How can i create actors like this in cluster?
How to handle million individual actors with AKKA Cluster setup?
362 Views Asked by Arun At
1
There are 1 best solutions below
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
- Suspending AKKA actor
- Spray Client (i.e. AKKA) within Tomcat, cause Threading issue
- Can I use Akka scheduler to schedule multiple things from a single actor context?
- akka: pattern for combining messages from multiple children
- Akka: multiple dispatcher vs multiple actor system
Related Questions in AKKA.NET
- How to use TestKit in Akka.NET
- Testing Akka.NET's Context.Parent with TestKit
- Service Fabric, Akka.net and Persistent actor integration
- HOCON format for cluster router group?
- Akka design for Scraping
- Akka.NET + Photon Server
- Akka.Net Sending huge messages (maximum-frame-size)
- How to make Akka.NET's ClusterClient work?
- How to distinguish actor termination reason
- How to test DistributedPubSub with the TestKit in Akka.net?
- How to handle a stale akka.net remote iactorref
- AKKA.NET - Queuing and Retry
- Akka.net vs Orleans performance
- Is there any way to wait for actor to be completely stopped?
- How to connect a Xamarin Client to Akka.net
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
- Akka - router supervisorStrategy- how to send message to router on event
- How to run an Akka-HTTP server inside an Akka cluster?
- Akka - cluster aware router doesn't starts nodes
- akka simple cluster with two seed nodes
- Router supervisor strategy in config
Related Questions in AKKA-REMOTE-ACTOR
- Listening to a remote akka ActorSystem's log stream
- akka remote actor running on local actor
- How to watch remote Akka Actor?
- Akka Remote Performance issue
- Can we avoid creating of internal actor when doing ask re
- Unable to start Activity:No configuration setting found for key 'akka.version'
- No response from remote for outbound association. Associate timed out after [15000 ms]
- How to handle million individual actors with AKKA Cluster setup?
- Any blogs,articals or docs to learn AKKA Remote internals?
- How to use Cluster singlton or Cluster sharding in Akka-Cluster for million individual Actors?
- Why does Akka not return address/host info?
- Akka.NET: Dead Letters to Remote Actor
- Dropping message [Akka.Actor.ActorSelectionMessage] for non-local recipient
- Deserialization and classloading in Akka - NoClassDefFoundError
- AKKA Remote Actor Error
Related Questions in AKKA-DISPATCHER
- Akka Balancing Pool with variable-size Thread-Pool-Executor
- How to handle million individual actors with AKKA Cluster setup?
- Why the actorSystem is not creating the actor to run with custom dispatcher
- When to use more instances of same Akka actor?
- Which dispatcher configuration in AKKA is efficient for more no of actor processing in parallel?
- What does the "throughput-deadline-time" configuration option do?
- Akka Dispatcher Thread creation
- How to create BalancingDispatcher using Akka in Java?
- Akka Streams Reactive Kafka - OutOfMemoryError under high load
- Using Akka Dispatchers for Handling Futures
- Make Akka guardian actor use custom dispatcher
- Why are Futures within Futures running sequentially when started on Akka Dispatcher
- How to configure dispatcher correctly in asp.net core akka
- Why Akka shutdowns dispatcher, when there is no tasks?
- Actor message allocation to dispatcher thread
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)
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?
Assuming that each actor is responsible for some uniquely identifiable part of state, it sounds like you want to use cluster sharding to balance the actors across the cluster, and route messages by ID.
Note that since the overhead of an actor is fairly small, it's not implausible to host millions of actors on a single node.
See the Akka JVM or Akka.Net docs.