Commit e1f44d6a authored by Administrator's avatar Administrator

交互协议,切回TCP。Android上面目前不支持UDT

parent 4d9a3411
......@@ -61,13 +61,13 @@ public class G4ProxyClient {
workerGroup = new NioEventLoopGroup(
0,
new DefaultThreadFactory("nat-endpoint-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class)),
NioUdtProvider.BYTE_PROVIDER
new DefaultThreadFactory("nat-endpoint-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class))
//, NioUdtProvider.BYTE_PROVIDER
);
join2NatServerBootStrap = new Bootstrap();
join2NatServerBootStrap.group(workerGroup);
// join2NatServerBootStrap.channel(NioSocketChannel.class);
join2LittleProxyBootStrap.channelFactory(NioUdtProvider.BYTE_ACCEPTOR);
join2NatServerBootStrap.channel(NioSocketChannel.class);
//join2LittleProxyBootStrap.channelFactory(NioUdtProvider.BYTE_ACCEPTOR);
join2NatServerBootStrap.handler(new ChannelInitializer<SocketChannel>() {
@Override
......
......@@ -45,18 +45,19 @@ public class G4ProxyServer {
ServerBootstrap natServerBootStrap = new ServerBootstrap();
NioEventLoopGroup serverBossGroup = new NioEventLoopGroup(
0,
new DefaultThreadFactory("natServer-boss-group" + DefaultThreadFactory.toPoolName(NioEventLoopGroup.class)),
NioUdtProvider.BYTE_PROVIDER
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
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)
.option(ChannelOption.SO_REUSEADDR, true)
// .channelFactory(NioUdtProvider.BYTE_ACCEPTOR)
// .option(ChannelOption.SO_BACKLOG, 10)
// .option(ChannelOption.SO_REUSEADDR, true)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment