netty 连接成功后过几秒马上又中断，这是什么鬼？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 2014 天前的主题，其中的信息可能已经有所发展或是发生改变。

前端 android，后端 springboot，连接用的 netty，用 tls 加密了的。环境是 win10 本机同时部署客户端和服务端。

每次都是连接成功后过几秒又会断开连接。这期间发送请求都会发送失败。断开连接时触发 channelinactive 方法。

前后端的 log 中没有任何报错或者警告信息，因为我已经排除过了。

如果不是前后端代码的问题，而是什么别的问题（例如防火墙），该如何排查？

第 1 条附言 · 2019-05-20 15:50:27 +08:00

服务端：

ServerBootstrap b = new ServerBootstrap();
b.group(boss, work)
.channel(NioServerSocketChannel.class)
.option(ChannelOption.SO_BACKLOG, 128)
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10 * 1000)
.childOption(ChannelOption.TCP_NODELAY, true)
.childHandler(this)
.bind(6789)
.addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) throws Exception {
future.removeListener(this);
if(!future.isSuccess() && future.cause() != null) log.error("服务器绑定端口失败", future.cause());
if(future.isSuccess()) log.info("服务器绑定端口成功");
}
});

@Override
protected void initChannel(NioSocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
ByteBuf delimiter = Unpooled.copiedBuffer(Constant.LINE_SEPARATOR.getBytes());
pipeline.addLast(new IdleStateHandler(60,60, 0));
pipeline.addLast(new DelimiterBasedFrameDecoder(2048,delimiter));
pipeline.addLast(new StringDecoder(Charset.forName("UTF-8")));
pipeline.addLast(new StringEncoder(Charset.forName("UTF-8")));
pipeline.addLast(handleGroup, new NettyServerHandler(playerMap, tableMap, userName2Player));
SSLEngine engine = ContextSSLFactory.getServerSslContext().createSSLEngine();
engine.setUseClientMode(false);
engine.setNeedClientAuth(true);
pipeline.addFirst(new SslHandler(engine));
}

第 2 条附言 · 2019-05-20 15:52:52 +08:00

客户端 1

private GameClient() {
EventLoopGroup eventLoopGroup = new NioEventLoopGroup();
bootstrap = new Bootstrap();
bootstrap.group(eventLoopGroup)
.channel(NioSocketChannel.class)
.option(ChannelOption.TCP_NODELAY, true)
.option(ChannelOption.SO_KEEPALIVE, true)
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, CONNECT_TIMEOUT)
.handler(new ChannelInitializer<NioSocketChannel>() {
@Override
protected void initChannel(NioSocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
ByteBuf delimiter = Unpooled.copiedBuffer(Constants.LINE_SEPARATOR.getBytes());
pipeline.addLast(new IdleStateHandler(60, 60, 0));
pipeline.addLast(new DelimiterBasedFrameDecoder(2048, delimiter));
pipeline.addLast(new StringDecoder(Charset.forName("UTF-8")));
pipeline.addLast(new StringEncoder(Charset.forName("UTF-8")));
pipeline.addLast(new GameClientHandler());
SSLEngine engine = ContextSSLFactory.getInstance().getClientSslContext().createSSLEngine();
engine.setUseClientMode(true);
pipeline.addFirst(new SslHandler(engine, true));
}
});
}

第 3 条附言 · 2019-05-20 15:53:15 +08:00

public void connectServer() {
if(isConnected() || !semaphore.tryAcquire()) return;
executor.execute(new Runnable() {
@Override
public void run() {
Logger.i("正在连接游戏服务器" + Constants.gameHost + ":" + Constants.gamePort + ".......");
InetSocketAddress remoteAddress = new InetSocketAddress(Constants.gameHost, Constants.gamePort);
bootstrap.connect(remoteAddress).addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) throws Exception {
semaphore.release();
future.removeListener(this);
if(!future.isSuccess() && future.cause() != null) handleConnectFailure(future.cause(), remoteAddress);
if(future.isSuccess()) {
Logger.w("服务器连接成功" + remoteAddress.getHostName() + ":" + remoteAddress.getPort());
channel = future.channel();
}
}
});
}
});
}

第 4 条附言 · 2019-05-20 17:03:01 +08:00

无聊把 ssl 禁了再启动试了一下，终于不断开了。。。。

这尼玛的 ssl，虐的我不要不要的。

Netty

连接

断开

接用

10 条回复 • 2020-05-07 17:18:11 +08:00