怎么对ChannelHandler做测试？
使用EmbeddedChannel。它的数据流程如下所示：
- 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())
复制代码本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
原始发表：2018年05月30日，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录