You could implement your own router actor and protocol for routing messages
but why bother. Cluster sharding has already done that for you. Look into
that.
On Wednesday, August 30, 2017 at 4:47:44 AM UTC-5, Wei Guo (SH-LTS) wrote:
>
> Hi everyone,
>
> I'm a newbie for Akka, for load balance consideration, I created 5 actors
> to handle the incoming requests, but one important requirement is that
> different types of objects with same key(Symbol of Quote/Trade/RefData in
> my code below) should be routed to same actor, after searching Akka
> doc, ConsistentHashingRoutingLogic is a choice
>
> After running code with testing data, same type of objects were routed to
> same actor, but for different types of objects(Quote,Trade, RefData with
> same Symbol), it doesn't work as i expected, they were routed to different
> actors
> eg:
> Quote quote1,quote2;
> quote1.setSymbol("001"); // quote1 & quote2 were routed to same
> actor(h0) -- no issue
> quote2.setSymbol("001");
>
> Trade trade;
> trade.setSymbol("001"); // trade was sent to different actor (h1)
> -- problem
>
> RefData refData;
> refData.setSymbol("001"); // refData was sent to different actor (h2)
> -- problem
>
> Can anyone provide any suggestion to route them into same actor ? Thanks a
> lot.
>
> int nOfHisActor = 5;
>
> actorSystem = ActorSystem.create("lunar");
> String[] pathArray = new String[nOfHisActor];
> for (int i = 0; i < nOfHisActor; i++) {
> String path = "h" + i;
> pathArray[i] = "/user/" + path;
> actorSystem.actorOf(Props.create(HisMarketDataActor.class), path);
> }
> List<String> paths = Arrays.asList(pathArray);
> hisInfoActor = actorSystem.actorOf(new
> ConsistentHashingGroup(paths).withHashMapper(o -> {
> if (o instanceof Quote) {
> return ((Quote) o).getSymbol();
> } else if (o instanceof Trade) {
> return ((Trade) o).getSymbol();
> } else if (o instanceof RefData) {
> return ((RefData) o).getSymbol();
> }
> return null;
> }).props(), "price");
>
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
