新增server和client

pom.xml

@@ -33,6 +33,16 @@
 			<artifactId>spring-boot-starter-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>io.netty</groupId>
+			<artifactId>netty-all</artifactId>
+			<version>4.1.76.Final</version>
+		</dependency>
+		<dependency>
+			<groupId>com.baomidou</groupId>
+			<artifactId>mybatis-plus-boot-starter</artifactId>
+			<version>3.5.2</version>
+		</dependency>
 	</dependencies>
 
 	<build>

src/main/java/com/example/tankbattle/Main.java

@@ -4,12 +4,12 @@ public class Main {
     public static void main(String[] args) throws InterruptedException {
         TankFrame tf = new TankFrame();
 
-        int initTankCount = Integer.valueOf(PropertyMgr.get("initTankCount"));
-
-        // 初始化敌方坦克
-        for (int i = 0; i < initTankCount; i++) {
-            tf.tanks.add(new Tank(50 + i * 80, 200, Dir.DOWN, Group.BAD, tf));
-        }
+//        int initTankCount = Integer.valueOf(PropertyMgr.get("initTankCount"));
+//
+//        // 初始化敌方坦克
+//        for (int i = 0; i < initTankCount; i++) {
+//            tf.tanks.add(new Tank(50 + i * 80, 200, Dir.DOWN, Group.BAD, tf));
+//        }
 
         while (true) {
             Thread.sleep(50);

src/main/java/com/example/tankbattle/net/Client.java

@@ -0,0 +1,61 @@
+package com.example.tankbattle.net;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.Channel;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioSocketChannel;
+
+public class Client {
+    private Channel channel;
+    public void connect() {
+        EventLoopGroup group = new NioEventLoopGroup();
+        Bootstrap bootstrap = new Bootstrap();
+
+        try {
+            ChannelFuture channelFuture = bootstrap.group(group).channel(NioSocketChannel.class).handler(new ClientChannelInitializer())
+                    .connect("localhost", 8888);
+            channelFuture.addListener(new ChannelFutureListener() {
+                @Override
+                public void operationComplete(ChannelFuture future) throws Exception {
+                    if (!future.isSuccess()) {
+                        System.out.println("not conected");
+                    } else {
+                        System.out.println("connected");
+                        channel = future.channel();
+                    }
+                }
+            });
+            channelFuture.sync();
+            channelFuture.channel().closeFuture().sync();
+            System.out.println("channel closed");
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        } finally {
+            group.shutdownGracefully();
+        }
+    }
+
+    public void send(String message) {
+        ByteBuf buf = Unpooled.copiedBuffer(message.getBytes());
+        channel.writeAndFlush(buf);
+    }
+
+    public static void main(String[] args) {
+        Client client = new Client();
+        client.connect();
+        client.send("hello");
+        client.send("world");
+        client.send("hello world");
+        client.send("hello world hello");
+        client.send("hello world hello world");
+    }
+
+    public void closeConnect(){
+        this.send("_bye_");
+    }
+}

src/main/java/com/example/tankbattle/net/ClientChannelInitializer.java

@@ -0,0 +1,12 @@
+package com.example.tankbattle.net;
+
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.socket.SocketChannel;
+
+public class ClientChannelInitializer extends ChannelInitializer<SocketChannel> {
+
+    @Override
+    protected void initChannel(SocketChannel socketChannel) throws Exception {
+        socketChannel.pipeline().addLast(new TankMessageEncoder()).addLast(new ClientHandler());
+    }
+}

src/main/java/com/example/tankbattle/net/ClientHandler.java

@@ -0,0 +1,28 @@
+package com.example.tankbattle.net;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.util.ReferenceCountUtil;
+
+public class ClientHandler extends ChannelInboundHandlerAdapter {
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        ByteBuf buf = null;
+        try {
+            buf = (ByteBuf) msg;
+            byte[] bytes = new byte[buf.readableBytes()];
+//        buf.getByte(buf.readerIndex(), bytes);
+            String message = new String(bytes);
+        } finally {
+            if (buf!= null) {
+                ReferenceCountUtil.release(buf);
+            }
+        }
+    }
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        ctx.writeAndFlush(new TankMessage(5, 8));
+    }
+}

src/main/java/com/example/tankbattle/net/Server.java

@@ -0,0 +1,41 @@
+package com.example.tankbattle.net;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelPipeline;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.group.ChannelGroup;
+import io.netty.channel.group.DefaultChannelGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.util.concurrent.GlobalEventExecutor;
+
+public class Server {
+    public static ChannelGroup clients = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
+
+    public void serverStart() {
+        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
+        EventLoopGroup workerGroup = new NioEventLoopGroup(2);
+        try {
+            ServerBootstrap bootstrap = new ServerBootstrap();
+            ChannelFuture channelFuture = bootstrap.group(bossGroup, workerGroup)
+                    .channel(NioServerSocketChannel.class)
+                    .childHandler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        protected void initChannel(SocketChannel ch) throws Exception {
+                            ChannelPipeline channelPipeline = ch.pipeline();
+                            channelPipeline.addLast(new TankMessageDecoder()).addLast(new ServerChildHandler());
+                        }
+                    }).bind(8888).sync();
+
+            channelFuture.channel().closeFuture().sync();
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            workerGroup.shutdownGracefully();
+            bossGroup.shutdownGracefully();
+        }
+    }
+}

src/main/java/com/example/tankbattle/net/ServerChildHandler.java

@@ -0,0 +1,32 @@
+package com.example.tankbattle.net;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.util.ReferenceCountUtil;
+
+public class ServerChildHandler extends ChannelInboundHandlerAdapter {
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        Server.clients.add(ctx.channel());
+    }
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        System.out.println("channelRead");
+        try {
+            System.out.println(msg.toString());
+            TankMessage tankMessage = (TankMessage) msg;
+            System.out.println(tankMessage);
+        } finally {
+            ReferenceCountUtil.release(msg);
+        }
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        cause.printStackTrace();
+        Server.clients.remove(ctx.channel());
+        ctx.close();
+    }
+}

src/main/java/com/example/tankbattle/net/ServerFrame.java

@@ -0,0 +1,51 @@
+package com.example.tankbattle.net;
+
+import java.awt.BorderLayout;
+import java.awt.Button;
+import java.awt.Font;
+import java.awt.Frame;
+import java.awt.GridLayout;
+import java.awt.Panel;
+import java.awt.TextArea;
+import java.awt.event.WindowAdapter;
+import java.awt.event.WindowEvent;
+
+public class ServerFrame extends Frame {
+    public static final ServerFrame INSTANCE = new ServerFrame();
+    Button btnStart = new Button("Start");
+    TextArea textLeft = new TextArea();
+    TextArea textRight = new TextArea();
+    Server server = new Server();
+
+    public ServerFrame() {
+        this.setSize(1600, 600);
+        this.setLocation(300, 30);
+        this.add(btnStart, BorderLayout.NORTH);
+        Panel panel = new Panel(new GridLayout(1, 2));
+        panel.add(textLeft);
+        panel.add(textRight);
+        this.add(panel);
+        textLeft.setFont(new Font("verderna", Font.PLAIN, 25));
+
+        this.addWindowListener(new WindowAdapter() {
+            @Override
+            public void windowClosing(WindowEvent e) {
+                System.exit(0);
+            }
+        });
+    }
+
+    public static void main(String[] args) {
+        ServerFrame.INSTANCE.setVisible(true);
+        ServerFrame.INSTANCE.server.serverStart();
+    }
+
+    public void updateServerMessage(String message) {
+        this.textLeft.setText(textLeft.getText() + message + System.lineSeparator());
+    }
+
+    public void updateClientMessage(String message) {
+        this.textRight.setText(textRight.getText() + message + System.lineSeparator());
+
+    }
+}

src/main/java/com/example/tankbattle/net/TankMessage.java

@@ -0,0 +1,11 @@
+package com.example.tankbattle.net;
+
+public class TankMessage {
+    public int x;
+    public int y;
+
+    public TankMessage(int x, int y) {
+        this.x = x;
+        this.y = y;
+    }
+}

src/main/java/com/example/tankbattle/net/TankMessageDecoder.java

@@ -0,0 +1,19 @@
+package com.example.tankbattle.net;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.ByteToMessageDecoder;
+
+import java.util.List;
+
+public class TankMessageDecoder extends ByteToMessageDecoder {
+    @Override
+    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
+        if (in.readableBytes() < 8) {
+            return;
+        }
+        int x = in.readInt();
+        int y = in.readInt();
+        out.add(new TankMessage(x, y));
+    }
+}

src/main/java/com/example/tankbattle/net/TankMessageEncoder.java

@@ -0,0 +1,14 @@
+package com.example.tankbattle.net;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.MessageToByteEncoder;
+
+public class TankMessageEncoder extends MessageToByteEncoder<TankMessage> {
+
+    @Override
+    protected void encode(ChannelHandlerContext ctx, TankMessage msg, ByteBuf out) throws Exception {
+        out.writeInt(msg.x);
+        out.writeInt(msg.y);
+    }
+}