怎么对ChannelHandler作测试?

使用EmbeddedChannel。它的数据流程以下所示:bash

  • writeOutbound:将出站消息写到EmbeddedChannel中,若是能经过readOutbound从EmbeddedChannel中读到数据,返回true
  • readOutbound:从EmbeddedChannel中读取一个出站消息,它所返回的全部东西都会穿过整个的ChannelPipeline。若是没有读取的,就返回null
  • writeInbound:将入站消息写到EmbeddedChannel中,若是能经过readInbound从EmbeddedChannel中读取数据,返回true
  • readInbound:从EmbeddedChannel中读取一个入站消息,任何返回都会通过ChannelPipeline。若是没有读取,返回null

测试案例

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())
复制代码
相关文章
相关标签/搜索