DelimiterBasedFrameDecoder，它是如何工作的？

Question

我假设我是netty的新手；我正在尝试创建一个到外部服务器的客户端，该服务器输出以 0x0d 结尾的消息，因此我决定使用 DelimiterBasedFrameDecoder 来处理这些消息。

这只是对处理程序的测试：

public class TestHandler extends DelimiterBasedFrameDecoder {

    public TestHandler(){

        super(200, true, ChannelBuffers.wrappedBuffer(new byte[] { 0x0d }));

    }

    @Override
    protected Object decode(ChannelHandlerContext ctx, Channel ch,
            ChannelBuffer cbuf) throws Exception {


        ByteBuffer buf = ByteBuffer.allocate(cbuf.readableBytes());

        cbuf.readBytes(buf);

        byte[] data = buf.array();

        for(byte b : data){

            System.out.print(b + " ");

        }

        System.out.println();

            ...... (some other code)

     }

我从中看到的错误是它没有按照我在构造函数中指定的方式删除分隔符；在 byte[] 数据的末尾，我总是有 0x0d； 因此，就像测试一样，我更改了构造函数中的分隔符，在其上添加了一个测试值，例如 0x55

super(200, true, ChannelBuffers.wrappedBuffer(new byte[] { 0x55 }));

，它的工作方式相同，与之前没有区别。 我认为我以错误的方式使用它，或者我以错误的方式读取数据。 使用这个类的正确方法是什么？

需要明确的是，在这个处理程序的实际代码中，我从读取的数据创建一个对象，然后从decode()方法返回这个对象，然后我有另一个扩展SimpleChannelHandler的处理程序来获取这个对象（它类似于示例在用户指南中）。

感谢您的帮助 再见

Answer 1

我认为您的解码方法没有正确使用构造函数的“stripBytes”部分。

如果您检查 Netty 的 DelimiterBasedFrameDecoder 中的代码，您将在代码中看到以下 if 条件，而您重写的解码方法中缺少该条件。这导致字节不被剥离。

 if (stripDelimiter) {
            frame = buffer.readBytes(minFrameLength);
            buffer.skipBytes(minDelimLength);
        } else {
            frame = buffer.readBytes(minFrameLength + minDelimLength);
        }