出站 ChannelHandler 的捕获所有异常处理

在 Netty 中，您有入站和出站处理程序的概念。只需在管道的末尾（尾部）添加一个通道处理程序并实现一个捕获所有入站异常处理程序即可实现exceptionCaught覆盖。如果未沿途处理，沿入站管道发生的异常将沿着处理程序传播，直到遇到最后一个处理程序。

传出处理程序并没有完全相反的情况。相反（根据 Netty in Action，第 94 页），您需要向频道的 Future或听众Promise传递到write你的方法Handler.

由于我不确定在哪里插入前者，我想我会选择后者，所以我做了以下内容ChannelOutboundHandler:

    /**
     * Catch and log errors happening in the outgoing direction
     *
     * @see <p>p94 in "Netty In Action"</p>
     */
    private ChannelOutboundHandlerAdapter createOutgoingErrorHandler() {
        return new ChannelOutboundHandlerAdapter() {
            @Override
            public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
                logger.info("howdy! (never gets this far)");

                final ChannelFutureListener channelFutureListener = future -> {
                    if (!future.isSuccess()) {
                        future.cause().printStackTrace();
                        // ctx.writeAndFlush(serverErrorJSON("an error!"));
                        future.channel().writeAndFlush(serverErrorJSON("an error!"));
                        future.channel().close();
                    }
                };
                promise.addListener(channelFutureListener);
                ctx.write(msg, promise);
            }
        };

这被添加到管道的头部：

    @Override
    public void addHandlersToPipeline(final ChannelPipeline pipeline) {
        pipeline.addLast(
                createOutgoingErrorHandler(),
                new HttpLoggerHandler(), // an error in this `write` should go "up"
                authHandlerFactory.get(),
                // etc

问题是write如果我在错误处理程序中抛出运行时异常，则永远不会调用我的错误处理程序的方法HttpLoggerHandler.write().

我该如何做这个工作？任何传出处理程序中的错误都应该“冒泡”到附加到头部的错误。

需要注意的重要一点是，我不仅仅是想关闭通道，我想将错误消息写回到客户端（从serverErrorJSON('...')。在我尝试调整处理程序的顺序时（也尝试了来自这个答案 https://stackoverflow.com/q/30994095/200987），我已经激活了监听器，但我无法写任何东西。如果我用过ctx.write()在监听器中，似乎我在使用时进入了一个循环future.channel().write...没有做任何事情。

我找到了一个非常简单的解决方案，允许入站和出站异常到达与管道中最后一个 ChannelHandler 相同的异常处理程序。

我的管道设置如下：

        //Inbound propagation
        socketChannel.pipeline()
          .addLast(new Decoder())
          .addLast(new ExceptionHandler());

        //Outbound propagation
        socketChannel.pipeline()
          .addFirst(new OutboundExceptionRouter())
          .addFirst(new Encoder());

这是我的 ExceptionHandler 的内容，它记录捕获的异常：

    public class ExceptionHandler extends ChannelInboundHandlerAdapter {
        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
            log.error("Exception caught on channel", cause);
        }
    }

现在，OutBoundExceptionRouter 中甚至允许 ExceptionHandler 处理出站异常：

    public class OutboundExceptionRouter extends ChannelOutboundHandlerAdapter {
        @Override
        public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
            promise.addListener(ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE);
            super.write(ctx, msg, promise);
        }
    }

这是我的管道中调用的第一个出站处理程序，它的作用是将一个侦听器添加到将执行的出站写入承诺中future.channel().pipeline().fireExceptionCaught(future.cause());当承诺落空时。这fireExceptionCaught方法通过管道向入站方向传播异常，最终到达 ExceptionHandler。

如果有人感兴趣的话，从 Netty 4.1 开始，我们需要添加一个监听器来获取异常，因为在对通道执行 writeAndFlush 后，调用Write0方法 https://github.com/netty/netty/blob/830fc0d660896ce781aba0a8eb614053a4fe9201/transport/src/main/java/io/netty/channel/AbstractChannelHandlerContext.java#L715在 AbstractChannelHandlerContext.java 中调用，它将写入操作包装在 try catch 块中。 catch 块通知 Promise 而不是调用fireExceptionCaught 就像 invokeChannelRead 方法一样 https://github.com/netty/netty/blob/830fc0d660896ce781aba0a8eb614053a4fe9201/transport/src/main/java/io/netty/channel/AbstractChannelHandlerContext.java#L376用于入站消息。