Serializing data between client/server

Author: empire

client/pom.xml

@@ -12,5 +12,12 @@
 
     <artifactId>client</artifactId>
 
+    <dependencies>
+        <dependency>
+            <groupId>com.fanavard.challenge</groupId>
+            <artifactId>core</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
 
 </project>

client/src/main/java/com/fanavard/challenge/client/ClientApplication.java

@@ -3,6 +3,7 @@
 import com.fanavard.challenge.client.socket.SocketClient;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 /**
@@ -11,10 +12,14 @@
 @Component
 public class ClientApplication implements Runnable {
     private static final Logger logger = LoggerFactory.getLogger(ClientApplication.class);
+
+    @Autowired
+    SocketClient socketClient;
+
     public void run() {
         logger.debug("Starting client");
         try {
-            SocketClient.main(new String[]{});
+            socketClient.run();
         } catch (Exception e) {
             e.printStackTrace();
         }

client/src/main/java/com/fanavard/challenge/client/socket/SocketClient.java

@@ -8,35 +8,68 @@
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.serialization.ObjectEncoder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
+import org.springframework.stereotype.Component;
 
 /**
  * Created by ocean on 11/23/15.
  */
+@Component
 public class SocketClient {
-    public static void main(String[] args) throws Exception {
-        String host = "127.0.0.1";
-        int port = 8080;
-        EventLoopGroup workerGroup = new NioEventLoopGroup();
+    private final String host = "127.0.0.1";
+    private final int port = 8080;
+    private Bootstrap b;
+    private NioEventLoopGroup workerGroup;
+
+    @Autowired
+    ApplicationContext context;
+
+    public void run() throws Exception {
+        initialize();
 
         try {
-            Bootstrap b = new Bootstrap(); // (1)
-            b.group(workerGroup); // (2)
-            b.channel(NioSocketChannel.class); // (3)
-            b.option(ChannelOption.SO_KEEPALIVE, true); // (4)
-            b.handler(new ChannelInitializer<SocketChannel>() {
-                @Override
-                public void initChannel(SocketChannel ch) throws Exception {
-                    ch.pipeline().addLast(new SocketDecoder(), new SocketClientHandler());
-                }
-            });
-
-            // Start the client.
-            ChannelFuture f = b.connect(host, port).sync(); // (5)
-
-            // Wait until the connection is closed.
-            f.channel().closeFuture().sync();
+            configureAndStartServer();
         } finally {
-            workerGroup.shutdownGracefully();
+            shutdownClient(workerGroup);
         }
     }
+
+    private void configureAndStartServer() throws InterruptedException {
+        configureServer();
+        startServer();
+    }
+
+    private void startServer() throws InterruptedException {
+        // Start the client.
+        ChannelFuture f = b.connect(host, port).sync(); // (5)
+
+        // Wait until the connection is closed.
+        f.channel().closeFuture().sync();
+    }
+
+    private void configureServer() {
+        b.group(workerGroup); // (2)
+        b.channel(NioSocketChannel.class); // (3)
+        b.option(ChannelOption.SO_KEEPALIVE, true); // (4)
+        b.handler(new ChannelInitializer<SocketChannel>() {
+            @Override
+            public void initChannel(SocketChannel ch) throws Exception {
+                ch.pipeline().addLast(
+                        new ObjectEncoder(),
+                        context.getBean(SocketClientHandler.class)
+                        );
+            }
+        });
+    }
+
+    private void initialize() {
+        workerGroup = new NioEventLoopGroup();
+        b = new Bootstrap(); // (1)
+    }
+
+    private void shutdownClient(EventLoopGroup workerGroup) {
+        workerGroup.shutdownGracefully();
+    }
 }

client/src/main/java/com/fanavard/challenge/client/socket/SocketClientHandler.java

@@ -3,37 +3,58 @@
 /**
  * Created by ocean on 11/23/15.
  */
+import com.fanavard.challenge.core.model.UnixTime;
 import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.buffer.WrappedByteBuf;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerAdapter;
 import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Component;
 
+import java.io.BufferedOutputStream;
+import java.io.ByteArrayOutputStream;
+import java.nio.charset.Charset;
 import java.util.Date;
+import java.util.Scanner;
 
+@Component
 public class SocketClientHandler extends ChannelHandlerAdapter {
-    private ByteBuf buf;
+//    private ByteBuf buf;
 
     @Override
     public void handlerAdded(ChannelHandlerContext ctx) {
-        buf = ctx.alloc().buffer(4); // (1)
-    }
+//        buf = ctx.alloc().buffer(4); // (1)
+
+      }
 
     @Override
     public void handlerRemoved(ChannelHandlerContext ctx) {
-        buf.release(); // (1)
-        buf = null;
+//        buf.release(); // (1)
+//        buf = null;
+    }
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+
     }
 
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) {
-        ByteBuf m = (ByteBuf) msg;
-        buf.writeBytes(m); // (2)
-        m.release();
-
-        if (buf.readableBytes() >= 4) { // (3)
-            long currentTimeMillis = (buf.readUnsignedInt() - 2208988800L) * 1000L;
-            System.out.println(new Date(currentTimeMillis));
-            ctx.close();
-        }
+//        ByteBuf m = (ByteBuf) msg;
+//        System.out.println(m.toString(CharsetUtil.UTF_8));
+//
+        ctx.write(msg);
+
+//        ByteBuf buffer = Unpooled.copiedBuffer("[3]", CharsetUtil.UTF_8);
+//        ctx.writeAndFlush(buffer);
+    }
+
+    @Override
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+        ctx.flush();
     }
 
     @Override

client/src/main/java/com/fanavard/challenge/client/socket/SocketDecoder.java

@@ -0,0 +1,7 @@
+package com.fanavard.challenge.core.model;
+
+/**
+ * Created by ocean on 11/24/15.
+ */
+public interface Command {
+}

core/src/main/java/com/fanavard/challenge/core/model/Command.java

@@ -0,0 +1,12 @@
+package com.fanavard.challenge.core.model;
+
+/**
+ * Created by ocean on 11/24/15.
+ */
+public class InitGameCommand implements Command {
+    private final int playersCount;
+
+    public InitGameCommand(int playersCount) {
+        this.playersCount = playersCount;
+    }
+}

core/src/main/java/com/fanavard/challenge/core/model/InitGameCommand.java

@@ -0,0 +1,28 @@
+package com.fanavard.challenge.core.model;
+
+/**
+ * Created by ocean on 11/24/15.
+ */
+import java.util.Date;
+
+public class UnixTime {
+
+    private final long value;
+
+    public UnixTime() {
+        this(System.currentTimeMillis() / 1000L + 2208988800L);
+    }
+
+    public UnixTime(long value) {
+        this.value = value;
+    }
+
+    public long value() {
+        return value;
+    }
+
+    @Override
+    public String toString() {
+        return new Date((value() - 2208988800L) * 1000L).toString();
+    }
+}

core/src/main/java/com/fanavard/challenge/core/model/UnixTime.java

@@ -18,6 +18,12 @@
             <version>1.0-SNAPSHOT</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.fanavard.challenge</groupId>
+            <artifactId>core</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
         <dependency>
             <groupId>com.fanavard.challenge</groupId>
             <artifactId>namefamily</artifactId>

server/pom.xml

@@ -12,7 +12,11 @@
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.handler.codec.serialization.ClassResolver;
+import io.netty.handler.codec.serialization.ClassResolvers;
+import io.netty.handler.codec.serialization.ObjectDecoder;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Component;
 
 @Component
@@ -23,6 +27,9 @@ public class SocketServer {
     private EventLoopGroup workerGroup;
     private ServerBootstrap serverBootstrap;
 
+    @Autowired
+    ApplicationContext context;
+
 //    @Autowired
 //    SocketServerHandler socketServerHandler;
 //
@@ -46,7 +53,9 @@ private void configureServerBootstrap() {
                 .childHandler(new ChannelInitializer<SocketChannel>() { // (4)
                     @Override
                     public void initChannel(SocketChannel ch) throws Exception {
-                        ch.pipeline().addLast(new SocketServerHandler());
+                        ch.pipeline().addLast(
+                                new ObjectDecoder(ClassResolvers.weakCachingConcurrentResolver(null)),
+                                new SocketServerHandler());
                     }
                 })
                 .option(ChannelOption.SO_BACKLOG, 128)          // (5)

server/src/main/java/com/fanavard/challenge/server/socket/SocketServer.java

@@ -5,10 +5,12 @@
  */
 import io.netty.buffer.ByteBuf;
 
+import io.netty.buffer.Unpooled;
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelHandlerAdapter;
+import io.netty.util.CharsetUtil;
 import io.netty.util.ReferenceCountUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -22,22 +24,19 @@ public class SocketServerHandler extends ChannelHandlerAdapter { // (1)
     private static Logger logger = LoggerFactory.getLogger(SocketServer.class);
 
     @Override
-    public void channelActive(final ChannelHandlerContext ctx) { // (1)
-        logger.debug("write time");
-        final ByteBuf time = ctx.alloc().buffer(4); // (2)
-        time.writeInt((int) (System.currentTimeMillis() / 1000L + 2208988800L));
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        logger.debug("channelActive");
+    }
 
-        final ChannelFuture f = ctx.writeAndFlush(time); // (3)
-        f.addListener(new ChannelFutureListener() {
-            public void operationComplete(ChannelFuture future) {
-                assert f == future;
-                ctx.close();
-            }
-        }); // (4)
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) {
+        logger.debug("channelRead");
+        logger.debug("Server read: {}", msg.getClass());
     }
 
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
         cause.printStackTrace();
         ctx.close();
-    }}
+    }
+}