使用EmbeddedChannel。它的數據流程以下所示:bash
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())
複製代碼