Netty 4 and structure idea

pom.xml

@@ -21,11 +21,11 @@
 			<artifactId>tankernn-game-engine</artifactId>
 			<version>1.1</version>
 		</dependency>
-		<!-- https://mvnrepository.com/artifact/io.netty/netty -->
+		<!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
 		<dependency>
 			<groupId>io.netty</groupId>
-			<artifactId>netty</artifactId>
-			<version>3.10.6.Final</version>
+			<artifactId>netty-all</artifactId>
+			<version>4.0.4.Final</version>
 		</dependency>
 
 	</dependencies>

src/main/java/eu/tankernn/game/server/GameServer.java

@@ -0,0 +1,48 @@
+package eu.tankernn.game.server;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelOption;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+
+public class GameServer {
+	private int port;
+	
+	public GameServer(int port) {
+        this.port = port;
+    }
+	
+	public void run() throws Exception {
+        EventLoopGroup bossGroup = new NioEventLoopGroup(); // (1)
+        EventLoopGroup workerGroup = new NioEventLoopGroup();
+        try {
+            ServerBootstrap b = new ServerBootstrap(); // (2)
+            b.group(bossGroup, workerGroup)
+             .channel(NioServerSocketChannel.class) // (3)
+             .childHandler(new ChannelInitializer<SocketChannel>() { // (4)
+                 @Override
+                 public void initChannel(SocketChannel ch) throws Exception {
+                     ch.pipeline().addLast(new GameServerHandler());
+                 }
+             })
+             .option(ChannelOption.SO_BACKLOG, 128)          // (5)
+             .childOption(ChannelOption.SO_KEEPALIVE, true); // (6)
+
+            // Bind and start to accept incoming connections.
+            ChannelFuture f = b.bind(port).sync(); // (7)
+
+            // Wait until the server socket is closed.
+            // In this example, this does not happen, but you can do that to gracefully
+            // shut down your server.
+            f.channel().closeFuture().sync();
+        } finally {
+            workerGroup.shutdownGracefully();
+            bossGroup.shutdownGracefully();
+        }
+    }
+
+}

src/main/java/eu/tankernn/game/server/GameServerHandler.java

@@ -1,22 +1,19 @@
 package eu.tankernn.game.server;
 
-import org.jboss.netty.channel.Channel;
-import org.jboss.netty.channel.ChannelHandlerContext;
-import org.jboss.netty.channel.ExceptionEvent;
-import org.jboss.netty.channel.MessageEvent;
-import org.jboss.netty.channel.SimpleChannelHandler;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+public class GameServerHandler extends ChannelInboundHandlerAdapter {
 
-public class GameServerHandler extends SimpleChannelHandler {
-	
 	@Override
-	public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
-		
+	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+		ctx.write(msg);
+		ctx.flush();
 	}
-	
+
 	@Override
-	public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
-		e.getCause().printStackTrace();
-		Channel ch = e.getChannel();
-		ch.close();
+	public void exceptionCaught(ChannelHandlerContext ctx, Throwable e) throws Exception {
+		e.printStackTrace();
+		ctx.close();
 	}
 }

src/main/java/eu/tankernn/game/server/Launcher.java

@@ -1,35 +1,17 @@
 package eu.tankernn.game.server;
 
-import java.net.InetSocketAddress;
-import java.util.concurrent.Executors;
-
-import org.jboss.netty.bootstrap.ServerBootstrap;
-import org.jboss.netty.channel.ChannelFactory;
-import org.jboss.netty.channel.ChannelPipeline;
-import org.jboss.netty.channel.ChannelPipelineFactory;
-import org.jboss.netty.channel.Channels;
-import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
-
 public class Launcher {
 	public static void main(String[] args) {
-		listenForClients();
-	}
-
-	private static void listenForClients() {
-		ChannelFactory factory = new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),
-				Executors.newCachedThreadPool());
-
-		ServerBootstrap bootstrap = new ServerBootstrap(factory);
-
-		bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
-			public ChannelPipeline getPipeline() {
-				return Channels.pipeline(new GameServerHandler());
-			}
-		});
-
-		bootstrap.setOption("child.tcpNoDelay", true);
-		bootstrap.setOption("child.keepAlive", true);
-
-		bootstrap.bind(new InetSocketAddress(8080));
+		int port;
+        if (args.length > 0) {
+            port = Integer.parseInt(args[0]);
+        } else {
+            port = 8080;
+        }
+        try {
+			new GameServer(port).run();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
 	}
 }

src/main/java/eu/tankernn/game/server/World.java

@@ -0,0 +1,23 @@
+package eu.tankernn.game.server;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import eu.tankernn.game.server.entities.ServerEntity;
+import eu.tankernn.game.server.entities.player.ServerPlayer;
+import eu.tankernn.gameEngine.entities.Light;
+
+public class World {
+	int seed;
+	List<Light> lights;
+	List<ServerEntity> entities;
+	List<ServerPlayer> players;
+	
+	public World(List<Light> lights, List<ServerEntity> entities) {
+		this.lights = lights;
+		this.entities = entities;
+		this.players = new ArrayList<ServerPlayer>();
+	}
+	
+	
+}

src/main/java/eu/tankernn/game/server/entities/ServerEntity.java

@@ -0,0 +1,5 @@
+package eu.tankernn.game.server.entities;
+
+public class ServerEntity {
+
+}

src/main/java/eu/tankernn/game/server/entities/player/ServerPlayer.java

@@ -0,0 +1,7 @@
+package eu.tankernn.game.server.entities.player;
+
+import eu.tankernn.game.server.entities.ServerEntity;
+
+public class ServerPlayer extends ServerEntity {
+	private String username;
+}