server client 切换为udt通信模式

g4proxy-new/src/main/java/com/virjar/g4proxy_new/client/G4ProxyClient.java

@@ -59,7 +59,11 @@ public class G4ProxyClient {
             }
         });
 
-        workerGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("nat-endpoint-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class)));
+        workerGroup = new NioEventLoopGroup(
+                0,
+                new DefaultThreadFactory("nat-endpoint-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class)),
+                NioUdtProvider.BYTE_PROVIDER
+        );
         join2NatServerBootStrap = new Bootstrap();
         join2NatServerBootStrap.group(workerGroup);
         // join2NatServerBootStrap.channel(NioSocketChannel.class);

g4proxy-new/src/main/java/com/virjar/g4proxy_new/server/G4ProxyServer.java

@@ -43,8 +43,16 @@ public class G4ProxyServer {
     private void startUpInternal() {
 
         ServerBootstrap natServerBootStrap = new ServerBootstrap();
-        NioEventLoopGroup serverBossGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("natServer-boss-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class)));
-        NioEventLoopGroup serverWorkerGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("natServer-worker-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class)));
+        NioEventLoopGroup serverBossGroup = new NioEventLoopGroup(
+                0,
+                new DefaultThreadFactory("natServer-boss-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class)),
+                NioUdtProvider.BYTE_PROVIDER
+        );
+        NioEventLoopGroup serverWorkerGroup = new NioEventLoopGroup(
+                0,
+                new DefaultThreadFactory("natServer-worker-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class)),
+                NioUdtProvider.BYTE_PROVIDER
+        );
         natServerBootStrap.group(serverBossGroup, serverWorkerGroup)
                 .channelFactory(NioUdtProvider.BYTE_ACCEPTOR)
                 .option(ChannelOption.SO_BACKLOG, 10)