当前位置：首页 > wzjs >正文

安全证四川省建设厅官方网站网页设计实训报告总结1000字免费

wzjs 2025/9/11 10:36:24

安全证四川省建设厅官方网站,网页设计实训报告总结1000字免费,站长之家alexa排名,e想时代官方网站一.前言最近碰到了一个需求，需要判断客户端与服务端之间的连接是否已经断开，查阅资料后发现Netty提供了如下几种方式，现总结如下，方便后续查看。二.存活检测方式 2.1 SO_KEEPALIVE选项 Netty提供了SO_KEEPALIVE选项&#xf…

一.前言

最近碰到了一个需求，需要判断客户端与服务端之间的连接是否已经断开，查阅资料后发现Netty提供了如下几种方式，现总结如下，方便后续查看。

二.存活检测方式

2.1 `SO_KEEPALIVE`选项

Netty提供了SO_KEEPALIVE选项，当连接保持空闲一段时间时，TCP 会自动向远程对等方发送保持活动探测。但由于该时间间隔依赖于操作系统（通常默认值为2小时），因此此种方式不太被推荐使用。

2.2 `IdleStateHandler`

当Channel在一段时间内没有执行读或写操作时，会触发IdleStateEvent。

IdleStateHandler关于读写空闲多久触发IdleStateEvent包含如下三个参数：

readerIdleTime：读空闲时间，超过设定的时间，会触发IdleState.READER_IDLE，若设置为0表示禁用。
writerIdleTime：写空闲时间，超过设定的时间，会触发IdleState.WRITE_IDLE，若设置为0表示禁用。
allIdleTime：读写都空闲时间，超过设定时间，会触发IdleState.ALL_IDLE，若设置为0表示禁用。

上述IdleStateEvent可以在方法public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception中捕获。

下面是一个客户端应用IdleStateHandler的示例，在该示例中，若30秒没有读写事件时，客户端会连续向服务端发送 3次PING，每次间隔10秒，若期间收到了服务端回复的PING_ACK则表明连接还存在，否则直接关闭该连接。

public class NettyRWTimeoutClient {private static final int PORT = 8080;public static void main(String[] args) {EventLoopGroup group = new NioEventLoopGroup();try {Bootstrap bootstrap = new Bootstrap();bootstrap.group(group).channel(NioSocketChannel.class).handler(new ChannelInitializer<NioSocketChannel>() {@Overrideprotected void initChannel(NioSocketChannel ch) {ChannelPipeline pipeline = ch.pipeline();pipeline.addLast(new StringDecoder(StandardCharsets.UTF_8));pipeline.addLast(new StringEncoder(StandardCharsets.UTF_8));// 30s内读写都空闲, 触发 IdleStateEventpipeline.addLast(new IdleStateHandler(0, 0, 30, TimeUnit.SECONDS));pipeline.addLast(new ClientHandler());}});ChannelFuture future = bootstrap.connect("localhost", PORT).sync();future.channel().closeFuture().sync();} catch (InterruptedException e) {e.printStackTrace();} finally {group.shutdownGracefully();}}
}class ClientHandler extends SimpleChannelInboundHandler<String> {private final int maxPingAttempts = 3; // 最多发送3次PINGprivate int pingCount = 0;private int pingTimeInterval = 10; // 每隔10s发送一次PINGprivate ScheduledFuture<?> pingTask;@Overridepublic void channelRead0(ChannelHandlerContext ctx, String msg) {if ("PING_ACK".equals(msg)) {System.out.println("Received PING_ACK from server");pingCount = 0; // PING_ACK, 重置Ping计数if (pingTask != null) {pingTask.cancel(false); // 取消后续PING任务pingTask = null;}} else {System.out.println("Received: " + msg);}}@Overridepublic void userEventTriggered(ChannelHandlerContext ctx, Object evt) {if (evt instanceof IdleStateEvent) {IdleStateEvent event = (IdleStateEvent) evt;if (event.state() == IdleState.ALL_IDLE) {sendPingToServer(ctx);}}}private void sendPingToServer(ChannelHandlerContext ctx) {if (pingTask != null) {return; // 任务已在进行中}System.out.println("start send PINT To Server");pingTask = ctx.executor().scheduleAtFixedRate(() -> {if (pingCount < maxPingAttempts) {System.out.println("Sending PING " + (pingCount + 1));ctx.writeAndFlush("PING");pingCount++;} else {System.out.println("No response after " + maxPingAttempts + " PINGs, closing connection.");ctx.close();pingTask.cancel(false);}}, 0, pingTimeInterval, TimeUnit.SECONDS); // 每10s发送一次 PING}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {cause.printStackTrace();ctx.close();}
}