Scala’s PingPong with GridGain using Java and Scala

Anyone who’s looked at Scala’s Actor framework is familiar with PingPong example… Essentially, two actors exchange request/response messages (PING and PONG) demonstrating basic of inter-Actor communication. In GridGain we have similar functionality – but it is, of course, distributed.

Distributed version of PingPong example will configure two grid nodes and let one node send PING message to another, and receive corresponding PONG response from remote node. Essentially, we’ll have two nodes engaged in a simple request/response protocol.

Here’s how a full source code would look in Java using GridGain 3.0:

import org.gridgain.grid.*;
import org.gridgain.grid.typedef.*;
import java.util.*;
import java.util.concurrent.*;

public class GridMessagingPingPongExample {
    public static void main(String[] args) throws GridException { == 0 ? null : args[0], new CIX1<Grid>() {
            @Override public void applyx(Grid g) throws GridException {
                if (g.nodes().size() < 2) {
                    System.err.println("I need a partner to play a ping pong!");


                // Pick random remote node as a partner.
                GridRichNode nodeA = g.localNode();
                GridRichNode nodeB = F.rand(g.remoteNodes());

                // Set up remote player.
                nodeB.remoteListenAsync(nodeA, new GridListenActor<String>() {
                    @Override public void receive(UUID nodeId, String msg) throws GridException {

                        if ("PING".equals(msg)) {
                        else if ("STOP".equals(msg)) {

                int MAX_PLAYS = 10;

                final CountDownLatch cnt = new CountDownLatch(MAX_PLAYS);

                // Set up local player.
                nodeB.listen(new GridListenActor<String>() {
                    @Override protected void receive(UUID nodeId, String msg) throws GridException {

                        if (cnt.getCount() == 1) {
                        else if ("PONG".equals(msg)) {


                // Serve!

                // Wait til the game is over.
                try {
                catch (InterruptedException e) {
                    System.err.println("Hm... let us finish the game!\n" + e);

If you run this program it will join the grid upon its start, pick randomly some remote node out of existing grid topology, configure both (local and remote) message listeners and exchange 10 PING/PONG messages.

Sounds innocent, isn’t it? The most striking part for anyone who’s seeing this code for the first time is the fact that there is only… one program that configures both local and remote nodes. In fact, take a look at the line marked by “Setup the remote player” comment. You essentially supplying an actor (i.e. a closure) as a listener that will only be executed on the remote node (nodeB) when it received the message from this, local, node (nodeA).

This technique nicely demonstrates our drive for Cloud-as-a-VM virtualization technology that essentially removes the boundaries of a single VM and allows you to develop/test/deploy Java code that runs anywhere on the grid or cloud in pretty much the same way as locally.

And if you like Scala – here’s the same application written using our ScalaR – Scala-based DSL for cloud computing:

import org.gridgain.scalar.scalar
import scalar._
import java.util.UUID
import java.util.concurrent.CountDownLatch
import org.gridgain.grid._

object ScalarPingPongExample {
    def main(args: Array[String]) {
        scalar {
            if (grid.nodes().size < 2) {
                error("I need a partner to play a ping pong!")


            // Pick first remote node as a partner.
            val loc = grid.localNode
            val rmt = grid.remoteNodes()

            // Set up remote player.
            rmt.remoteListenAsync(loc, new GridListenActor[String]() {
                def receive(nodeId: UUID, msg: String) {

                    msg match {
                        case "PING" => respond("PONG")
                        case "STOP" => stop

            val MAX_PLAYS = 10

            val cnt = new CountDownLatch(MAX_PLAYS)

            // Set up local player.
            rmt listen new GridListenActor[String]() {
                def receive(nodeId: UUID, msg: String) {

                    if (cnt.getCount() == 1)


            // Serve!
            rmt !< "PING"

            // Wait til the match is over.
            cnt await

As you can see the difference between Java and Scala code is insignificant – but Scala obviously looks a bit more elegant.


5 responses

    • No, it’s defined properly: listen for messages from “rmt” node and invoke actor for each message received.

      “loc” is the node this application is executing… so this is implied.

      • Ok, I see. Both listeners are hard-wired to the other. This is not quite how scala/akka actors behave (specifically in the ping/pong example but also in general).

        How would one define listeners/actors that are not aware of the sending node?

Leave a Reply

Fill in your details below or click an icon to log in: Logo

You are commenting using your account. Log Out /  Change )

Google+ photo

You are commenting using your Google+ account. Log Out /  Change )

Twitter picture

You are commenting using your Twitter account. Log Out /  Change )

Facebook photo

You are commenting using your Facebook account. Log Out /  Change )


Connecting to %s

%d bloggers like this: