如何使netty处理程序在捕获到异常后继续读取数据？

Question

在我的netty处理程序中，我覆盖了exceptionCaught方法来捕获由netty ObjectDecoder抛出的TooLongFrameException。在出现异常的情况下，我会向服务器发送一条消息，告知该错误的相关信息。服务器收到该消息，然后尝试继续发送更多数据。问题是，我的处理程序似乎没有继续读取数据。

我使用netty 4.1.18最终版

import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.TooLongFrameException;

public final class MyHandler extends SimpleChannelInboundHandler<MyObject> {

    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, MyObject obj) throws Exception {

    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        if (cause instanceof TooLongFrameException) {
            ctx.writeAndFlush( messageAboutError );
            return;
        } else
            ctx.writeAndFlush( messageAboutUnexpectedError );
        super.exceptionCaught(ctx, cause);
    }
}

在我捕获到netty ObjectDecoder抛出的异常后，如何让我的处理程序继续读取数据？

Answer 1

真正的问题是，一旦您处于这种状态，ObjectDecoder将出现一个混乱的“解码状态”，因此除了断开连接之外，您没有什么可以做的。如果您要使用另一种消息格式，您可以做的就是丢弃消息的其余部分，只在收到新消息后再开始解析。如何做到这一点等，实际上取决于协议本身。