Skip to content
Find file
Fetching contributors…
Cannot retrieve contributors at this time
15 lines (8 sloc) 2.15 KB
Akka Essentials
(refer http://akka-essentials.blogspot.com/ for more details)
You will find examples of Akka in Java here talking of one concept along with a problem solved
tutorial-first-akka : This example has 2 demonstrations. First file HelloWorld.java introduces the simple concept of actor and how to send your first message. The second set HelloWorldClient and HelloWorldServer introduces the Remote Actor concept with the similar hello world message
ClientServerExample : This example demonstrates how the remote actors works in a client / server mode. The client sends the message to the server and server replies back to the client. The example also demonstrates various methods of creating remote actor references on the client side.
LoadGeneratorExample : This example generates 10 million messages and calculates the time it takes to process them. The program demonstrated the Routing concept where a roundrobinrouter is used to distribute the load on to a set of workers
WordCountMapReduce : This examples implements the Word Count Map Reduce model. The client system reads a text file and sends each line of text as a message to the Server. The server reads the line, maps the words, reduces the words and finally does an inmemory aggregation of the result. The example also implemented a prioritymailbox, which is used to segregate the message requests between the mapreduce requests and getting the list of results from the aggregate actor
GridPatternExample : Grid Computing pattern is where a control node distributes the work to other nodes. Idea is to make use of the nodes on the network for their computing power. It is analogous to Master Slave Pattern with certain differences. The idea behind the Master Slave pattern is to partition the work into identical sub tasks which are then delegated to Slaves. The example demonstrates how an WorkerActor system sends a request for registration. The RegisterRemoteWorker recieves the request and forwards the same to JobController where the RoundRobinRouter is updated for the new worker information. The WorkScheduler sends a periodic request to JobController, who then sends packets to all the registered worker actors.
Something went wrong with that request. Please try again.