使用EmbeddedChannel。它的数据流程如下所示:
ByteBuf buf=Upooled.buffer();
for(int i=1;i<10;i++){
buf.writeInt(i*-1);
}
//MyAbsChannelHandler 负责将每个负数转为正数,并一个一个的输出
EmbeddedChannel channel=new EmbeddedChannel(new MyAbsChannelHandler());
assertTrue(channel.writeOutbound(buf));
//finish 表示将 EmbeddedChannel 标记为完成,如果有可读的入站数据或出站数据,返回true
assertTrue(channel.finish());
for(int i=1;i<10;i++){
assertEquals(i,channel.readOutbound());
}
assertNull(channel.readOutbound())
复制代码