Netty连接断开时，后端无感知？这样解决发送消息报错！

后端

2023-12-17 10:38:08

在 Netty 中感知客户端断开连接的艺术

简介

在网络应用中，服务器端使用 Netty 作为底层通信框架非常普遍。然而，当前端客户端断开连接时，服务器端仍在发送消息，这可能会导致发送消息失败。为了避免这种情况，我们需要掌握感知客户端连接断开并采取相应措施的方法。

感知客户端断开连接的方法

有几种方法可以感知客户端的断开连接：

1. 超时机制

Netty 中允许设置一个超时时间，当客户端在一段时间内没有向服务器端发送数据时，服务器端就会认为客户端已断开连接。此时会触发一个 ChannelInactive 事件，可以监听此事件感知客户端断开。

2. 心跳检测

除了超时机制，还可以使用心跳检测。服务器端定期向客户端发送心跳包，客户端收到后需要及时回复。如果客户端在一段时间内没有回复心跳包，服务器端就会认为客户端已断开连接。同样，会触发 ChannelInactive 事件用于感知。

3. 正常关闭

当客户端正常关闭连接时，会向服务器端发送一个断开连接请求。服务器端收到后关闭与客户端的连接，也会触发 ChannelInactive 事件。

4. 通知

当客户端断开连接时，可以通过某种方式通知服务器端，如发送消息或调用服务。

代码示例

以下是使用 Netty 监听 ChannelInactive 事件感知客户端断开连接的示例代码：

public class NettyServer {

    private ChannelFuture channelFuture;

    public void start() throws InterruptedException {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ChannelPipeline pipeline = ch.pipeline();
                            pipeline.addLast(new ChannelInboundHandlerAdapter() {
                                @Override
                                public void channelInactive(ChannelHandlerContext ctx) throws Exception {
                                    // 客户端断开连接
                                    System.out.println("客户端断开连接");
                                }
                            });
                        }
                    });

            channelFuture = serverBootstrap.bind(8080).sync();
            channelFuture.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }

    public static void main(String[] args) throws InterruptedException {
        new NettyServer().start();
    }
}