感慨

一晃两年多了，自从刚开始给公司编写的几个网络模块，后来就没有在度使用的机会了。
讲解Netty的书籍有许多，其中《Netty实战》这本书比较经典，推荐大家用这本书入门。

概述

工欲善其事，必先利其器。
作为一个网络处理框架，如果没有脱离网络的单元测试，那么你要构建完整的一套代码，方能测试相应功能，是无法想象的。
ChannelHandler 是 Netty 应用程序的关键元素，无非就是处理输入数据，然后输出处理结果。
EmbeddedChannel，它是 Netty 专门为改进针对 ChannelHandler 的单元测试而提供的。它在设计上包含的关键方法，正是针对数据输入、数据输出的。

参考链接

https://blog.csdn.net/ljz2016/article/details/82899550
《netty实战》第9章

示例

目标：输入为大写字母，输出为小写字母。

处理器代码

public class TestDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
        byte[] readByte = new byte[byteBuf.readableBytes()];
        byteBuf.readBytes(readByte);
        for (int i = 0; i < readByte.length; i++) {
            readByte[i] += 32;//大写转小写
        }
        list.add(readByte);
    }
}

测试代码

    @Test
    public void test001() {
        ByteBuf buf = Unpooled.buffer();

        buf.writeByte("A".getBytes()[0]);
        buf.writeByte("B".getBytes()[0]);
        buf.writeByte("C".getBytes()[0]);

        ByteBuf input = buf.duplicate();
        EmbeddedChannel channel = new EmbeddedChannel(new TestDecoder());
        assertTrue(channel.writeInbound(input.retain()));
        assertTrue(channel.finish());


        //读取消息
        byte[] readByte = channel.readInbound();
        System.out.println("" + new String(readByte));
    }

运行效果

打印出

abc