테스트 채널 NetHyards의 핸드 헬드

Question

나는 임베디드 채널이 어떻게 작동하는지 알아 내기 위해 Netty에서 아주 간단한 것을 테스트하려고합니다. 같은

@Component 
@Sharable 
public class VersionServerHandler extends ChannelInboundHandlerAdapter { 

    private VersionService versionService; 

    @Autowired 
    public VersionServerHandler(VersionService versionService) { 
     this.versionService = versionService; 
    } 

    @Override 
    public void channelRead(ChannelHandlerContext ctx, Object msg) { 
     boolean isSupported = versionService.isVersionSupported((VersionRequest) msg.getVersion()); 

     // more logic 
     ctx.writeAndFlush(msg); 
    } 

내 테스트 같습니다 : 내 핸들러는 다음과 같습니다 난 그냥 그물코 예처럼에서 VersionServerHandler와 EmbeddedChannel 바이트를 쓰기 위해 노력하고있어

@Mock 
    private VersionService versionService; 

    @Test 
    public void testChannelRead() { 
     EmbeddedChannel embeddedChannel = new EmbeddedChannel(new VersionServerHandler(versionService); 
     ByteBuf buf = Unpooled.buffer(); 
     for (int i = 0; i < 9; i++) { 
      buf.writeByte(i); 
     } 
     ByteBuf dup = buf.duplicate(); 

     boolean test = embeddedChannel.writeInbound(dup.retain()); 
     // test is false 

하지만 test은 false입니다 사실이 아니다. 제가 누락 된 것이 있습니까? 감사.

Answer 1

왜냐하면 writeInbound(...)은 메시지가 파이프 라인 끝에 도달하면 true 만 반환하기 때문입니다. 확인하고 싶은 것을 확인하려면 writeInbound(...)으로 전화 한 다음 readOutbound()을 사용하고 null을 반환하지 않는지 확인하십시오. 또한 channel.finish()은 true을 반환해야합니다.