94 lines
3 KiB
ReStructuredText
94 lines
3 KiB
ReStructuredText
Routing (Java)
|
|
==============
|
|
|
|
UntypedDispatcher
|
|
-----------------
|
|
|
|
An UntypedDispatcher is an actor that routes incoming messages to outbound actors.
|
|
|
|
.. code-block:: java
|
|
|
|
import static akka.actor.Actors.*;
|
|
import akka.actor.*;
|
|
import akka.routing.*;
|
|
|
|
//A Pinger is an UntypedActor that prints "Pinger: <message>"
|
|
class Pinger extends UntypedActor {
|
|
public void onReceive(Object message) throws Exception {
|
|
System.out.println("Pinger: " + message);
|
|
}
|
|
}
|
|
|
|
//A Ponger is an UntypedActor that prints "Ponger: <message>"
|
|
class Ponger extends UntypedActor {
|
|
public void onReceive(Object message) throws Exception {
|
|
System.out.println("Ponger: " + message);
|
|
}
|
|
}
|
|
|
|
public class MyDispatcher extends UntypedDispatcher {
|
|
private ActorRef pinger = actorOf(Pinger.class).start();
|
|
private ActorRef ponger = actorOf(Ponger.class).start();
|
|
|
|
//Route Ping-messages to the pinger, and Pong-messages to the ponger
|
|
public ActorRef route(Object message) {
|
|
if("Ping".equals(message)) return pinger;
|
|
else if("Pong".equals(message)) return ponger;
|
|
else throw new IllegalArgumentException("I do not understand " + message);
|
|
}
|
|
}
|
|
|
|
ActorRef dispatcher = actorOf(MyDispatcher.class).start();
|
|
dispatcher.sendOneWay("Ping"); //Prints "Pinger: Ping"
|
|
dispatcher.sendOneWay("Pong"); //Prints "Ponger: Pong"
|
|
|
|
UntypedLoadBalancer
|
|
-------------------
|
|
|
|
An UntypedLoadBalancer is an actor that forwards messages it receives to a boundless sequence of destination actors.
|
|
|
|
.. code-block:: java
|
|
|
|
import static akka.actor.Actors.*;
|
|
import akka.actor.*;
|
|
import akka.routing.*;
|
|
import static java.util.Arrays.asList;
|
|
|
|
//A Pinger is an UntypedActor that prints "Pinger: <message>"
|
|
class Pinger extends UntypedActor {
|
|
public void onReceive(Object message) throws Exception {
|
|
System.out.println("Pinger: " + message);
|
|
}
|
|
}
|
|
|
|
//A Ponger is an UntypedActor that prints "Ponger: <message>"
|
|
class Ponger extends UntypedActor {
|
|
public void onReceive(Object message) throws Exception {
|
|
System.out.println("Ponger: " + message);
|
|
}
|
|
}
|
|
|
|
//Our load balancer, sends messages to a pinger, then a ponger, rinse and repeat.
|
|
public class MyLoadBalancer extends UntypedLoadBalancer {
|
|
private InfiniteIterator<ActorRef> actors = new CyclicIterator<ActorRef>(asList(
|
|
actorOf(Pinger.class).start(),
|
|
actorOf(Ponger.class).start()
|
|
));
|
|
|
|
public InfiniteIterator<ActorRef> seq() {
|
|
return actors;
|
|
}
|
|
}
|
|
|
|
ActorRef dispatcher = actorOf(MyLoadBalancer.class).start();
|
|
dispatcher.sendOneWay("Pong"); //Prints "Pinger: Pong"
|
|
dispatcher.sendOneWay("Ping"); //Prints "Ponger: Ping"
|
|
dispatcher.sendOneWay("Ping"); //Prints "Pinger: Ping"
|
|
dispatcher.sendOneWay("Pong"); //Prints "Ponger: Pong
|
|
|
|
You can also send a 'new Routing.Broadcast(msg)' message to the router to have it be broadcasted out to all the actors it represents.
|
|
|
|
.. code-block:: java
|
|
|
|
router.sendOneWay(new Routing.Broadcast(new PoisonPill()));
|
|
|