Grid Ops examples brought up-to-date with version 0.7.0 of Grid Ops - which had quite some changes since 0.4.0

Author: jjenkov

pom.xml

@@ -13,7 +13,7 @@
         <dependency>
             <groupId>com.nanosai</groupId>
             <artifactId>grid-ops</artifactId>
-            <version>0.2.0</version>
+            <version>0.7.0</version>
             <scope>compile</scope>
         </dependency>
 

src/main/java/com/nanosai/gridops/examples/iap/IapMessageFieldsWriterExample.java

@@ -0,0 +1,20 @@
+package com.nanosai.gridops.examples.ion;
+
+import com.nanosai.gridops.GridOps;
+import com.nanosai.gridops.ion.read.IonObjectReader;
+
+/**
+ * Created by jjenkov on 18/03/2017.
+ */
+public class IonObjectReaderExample {
+
+    public static void main(String[] args) {
+        IonObjectReader ionObjectReader = GridOps.ionObjectReader(Pojo.class);
+
+        byte[] source = new byte[1024];
+
+        Pojo pojo = (Pojo) ionObjectReader.read(source, 0);
+    }
+
+
+}

src/main/java/com/nanosai/gridops/examples/ion/IonObjectReaderExample.java

@@ -0,0 +1,24 @@
+package com.nanosai.gridops.examples.ion;
+
+import com.nanosai.gridops.GridOps;
+import com.nanosai.gridops.ion.write.IonObjectWriter;
+
+/**
+ * Created by jjenkov on 18/03/2017.
+ */
+public class IonObjectWriterExample {
+
+    public static void main(String[] args) {
+        IonObjectWriter ionObjectWriter = GridOps.ionObjectWriter(Pojo.class);
+
+        Pojo pojo = new Pojo();
+        pojo.setFirstName("Jakob");
+        pojo.setLastName("Jenkov");
+
+        byte[] destination = new byte[1024];
+        int length = ionObjectWriter.writeObject(pojo, 1, destination, 0);
+
+
+
+    }
+}

src/main/java/com/nanosai/gridops/examples/ion/IonObjectWriterExample.java

@@ -20,7 +20,7 @@ public static void main(String[] args) {
         ionWriter.writeBytes(new byte[]{ 12, 11, 122, 1, 27});
 
         //obtain length of written ION data
-        int dataLength = ionWriter.destIndex;
+        int dataLength = ionWriter.index;
 
         System.out.println("Total length of ION data: " + dataLength);
 

src/main/java/com/nanosai/gridops/examples/ion/IonWriterExample.java

@@ -0,0 +1,26 @@
+package com.nanosai.gridops.examples.ion;
+
+/**
+ * Created by jjenkov on 18/03/2017.
+ */
+public class Pojo {
+
+    private String firstName = null;
+    private String lastName = null;
+
+    public String getFirstName() {
+        return firstName;
+    }
+
+    public void setFirstName(String firstName) {
+        this.firstName = firstName;
+    }
+
+    public String getLastName() {
+        return lastName;
+    }
+
+    public void setLastName(String lastName) {
+        this.lastName = lastName;
+    }
+}

src/main/java/com/nanosai/gridops/examples/ion/Pojo.java

@@ -1,12 +1,14 @@
 package com.nanosai.gridops.examples.node;
 
 import com.nanosai.gridops.GridOps;
-import com.nanosai.gridops.iap.IapMessage;
+import com.nanosai.gridops.iap.IapMessageBase;
 import com.nanosai.gridops.ion.read.IonReader;
+import com.nanosai.gridops.mem.MemoryBlock;
 import com.nanosai.gridops.node.MessageReactor;
 import com.nanosai.gridops.node.NodeContainer;
 import com.nanosai.gridops.node.NodeReactor;
 import com.nanosai.gridops.node.ProtocolReactor;
+import com.nanosai.gridops.tcp.TcpMessagePort;
 
 /**
  * Created by jjenkov on 15-10-2016.
@@ -18,13 +20,14 @@ public static void main(String[] args) {
         byte[] messageId = new byte[]{11};
         MessageReactor messageReactor = new MessageReactor(messageId) {
             @Override
-            public void react(IonReader ionReader, IapMessage iapMessage) {
+            public void react(MemoryBlock message, IonReader reader, IapMessageBase messageBase, TcpMessagePort tcpMessagePort) throws Exception {
                 System.out.println("Reacting to message");
             }
         };
 
         byte[] protocolId = new byte[]{99};
-        ProtocolReactor protocolReactor = new ProtocolReactor(protocolId, messageReactor);
+        byte[] protocolVersion = new byte[]{0};
+        ProtocolReactor protocolReactor = new ProtocolReactor(protocolId, protocolVersion, messageReactor);
 
         byte[] nodeId =  new byte[]{123};
         NodeReactor nodeReactor = GridOps.nodeReactor(nodeId, protocolReactor);

src/main/java/com/nanosai/gridops/examples/node/NodeContainerExample.java

@@ -4,7 +4,7 @@
 import com.nanosai.gridops.ion.write.IonWriter;
 import com.nanosai.gridops.tcp.TcpMessage;
 import com.nanosai.gridops.tcp.TcpSocket;
-import com.nanosai.gridops.tcp.TcpSocketsPort;
+import com.nanosai.gridops.tcp.TcpMessagePort;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -19,7 +19,7 @@ public static void main(String[] args) throws IOException {
 
         SocketChannel socketChannel  = SocketChannel.open(new InetSocketAddress("localhost", 1111));
 
-        final TcpSocketsPort socketsPort = GridOps.tcpSocketsPortBuilder().build();
+        final TcpMessagePort socketsPort = GridOps.tcpMessagePortBuilder().build();
 
         TcpSocket tcpSocket = socketsPort.addSocket(socketChannel);
 
@@ -31,7 +31,7 @@ public static void main(String[] args) throws IOException {
         //todo convenience method for MemoryBlock's as destination
         ionWriter.setDestination(request.memoryAllocator.data, request.startIndex);
 
-        int ionObjectStartIndex = ionWriter.destIndex;
+        int ionObjectStartIndex = ionWriter.index;
         ionWriter.writeObjectBegin(1);
 
         ionWriter.writeKeyShort("field1");
@@ -40,19 +40,19 @@ public static void main(String[] args) throws IOException {
         ionWriter.writeKeyShort("field2");
         ionWriter.writeInt64(456);
 
-        int ionObjectBodyLength = ionWriter.destIndex - ionObjectStartIndex - 1 -1; // -1 for lead byte, -1 for length byte.
+        int ionObjectBodyLength = ionWriter.index - ionObjectStartIndex - 1 -1; // -1 for lead byte, -1 for length byte.
         ionWriter.writeObjectEnd(ionObjectStartIndex, 1, ionObjectBodyLength);
 
-        request.writeIndex = ionWriter.destIndex;
+        request.writeIndex = ionWriter.index;
 
         //todo missing what socket the message should be sent to. Must be a TCPSocket - not a SocketChannel.
         request.tcpSocket = tcpSocket;
 
-        socketsPort.enqueue(request);
+        socketsPort.writeNowOrEnqueue(request);
 
         // make sure all written messages are flushed out - although a single call to writeToSockets()
         // does not guarantee that.
-        socketsPort.writeToSockets();
+        socketsPort.writeNow();
 
 
 

src/main/java/com/nanosai/gridops/examples/tcp/TcpClientExample.java

@@ -2,20 +2,20 @@
 
 import com.nanosai.gridops.GridOps;
 import com.nanosai.gridops.tcp.TcpServer;
-import com.nanosai.gridops.tcp.TcpSocketsPort;
+import com.nanosai.gridops.tcp.TcpMessagePort;
 
 import java.io.IOException;
 
 /**
  * Created by jjenkov on 07-10-2016.
  */
-public class TcpSocketsPortCreate {
+public class TcpMessagePortCreate {
 
 
     public static void main(String[] args) throws IOException {
         TcpServer tcpServer = GridOps.tcpServerBuilder().buildAndStart();
 
-        TcpSocketsPort tcpSocketsPort =
-                GridOps.tcpSocketsPortBuilder().tcpServer(tcpServer).build();
+        TcpMessagePort tcpMessagePort =
+                GridOps.tcpMessagePortBuilder().tcpServer(tcpServer).build();
     }
 }

src/main/java/com/nanosai/gridops/examples/tcp/TcpSocketsPortCreate.java src/main/java/com/nanosai/gridops/examples/tcp/TcpMessagePortCreate.java

@@ -0,0 +1,37 @@
+package com.nanosai.gridops.examples.tcp;
+
+import com.nanosai.gridops.GridOps;
+import com.nanosai.gridops.mem.MemoryBlock;
+import com.nanosai.gridops.mem.MemoryBlockBatch;
+import com.nanosai.gridops.tcp.TcpServer;
+import com.nanosai.gridops.tcp.TcpMessagePort;
+
+import java.io.IOException;
+
+/**
+ * Created by jjenkov on 07-10-2016.
+ */
+public class TcpMessagePortRead {
+
+    public static void main(String[] args) throws IOException {
+        TcpServer tcpServer = GridOps.tcpServerBuilder().buildAndStart();
+
+        TcpMessagePort tcpMessagePort =
+                GridOps.tcpMessagePortBuilder().tcpServer(tcpServer).build();
+
+        MemoryBlockBatch memoryBlockBatch = new MemoryBlockBatch(64);
+
+        int messageCount = tcpMessagePort.readNow(memoryBlockBatch);
+
+        for(int i=0; i<messageCount; i++){
+            MemoryBlock message = memoryBlockBatch.blocks[i];
+        }
+
+        /* shorter version of reading and looping messages */
+        for(int i=0, n=tcpMessagePort.readNow(memoryBlockBatch); i<n; i++){
+            MemoryBlock message = memoryBlockBatch.blocks[i];
+        }
+
+
+    }
+}

src/main/java/com/nanosai/gridops/examples/tcp/TcpMessagePortRead.java

@@ -2,9 +2,10 @@
 
 import com.nanosai.gridops.GridOps;
 import com.nanosai.gridops.mem.MemoryBlock;
+import com.nanosai.gridops.mem.MemoryBlockBatch;
 import com.nanosai.gridops.tcp.TcpMessage;
 import com.nanosai.gridops.tcp.TcpServer;
-import com.nanosai.gridops.tcp.TcpSocketsPort;
+import com.nanosai.gridops.tcp.TcpMessagePort;
 
 import java.io.IOException;
 
@@ -19,34 +20,33 @@ public static void main(String[] args) throws IOException {
 
         TcpServer tcpServer1 = GridOps.tcpServerBuilder().buildAndStart();
 
-        final TcpSocketsPort socketsProxy =
-                GridOps.tcpSocketsPortBuilder().tcpServer(tcpServer1).build();
-
-        MemoryBlock[] requests  = new MemoryBlock[1024];
+        final TcpMessagePort tcpMessagePort =
+                GridOps.tcpMessagePortBuilder().tcpServer(tcpServer1).build();
 
+        MemoryBlockBatch memoryBlockBatch = new MemoryBlockBatch(1024);
 
         System.out.println("Server started");
 
         while(true){
             try {
-                socketsProxy.addSocketsFromSocketQueue();
+                tcpMessagePort.addSocketsFromSocketQueue();
 
                 //process inbound messages.
-                int requestCount = socketsProxy.read(requests);
+                int requestCount = tcpMessagePort.readNow(memoryBlockBatch);
                 for(int i=0; i < requestCount; i++){
-                    TcpMessage request = (TcpMessage) requests[i];
+                    TcpMessage request = (TcpMessage) memoryBlockBatch.blocks[i];
 
                     System.out.println("Processing message");
 
-                    TcpMessage response = socketsProxy.allocateWriteMemoryBlock(1024);
+                    TcpMessage response = tcpMessagePort.allocateWriteMemoryBlock(1024);
                     response.copyFrom(request);
 
                     response.tcpSocket   = request.tcpSocket;
 
-                    socketsProxy.enqueue(response);
+                    tcpMessagePort.writeNowOrEnqueue(response);
                 }
 
-                socketsProxy.writeToSockets();
+                tcpMessagePort.writeNow();
 
 
                 try {