Własność bufora w Netty 4: Jak zarządza się cyklem życia bufora?

Question

Próbuję napisać klienta HTTP, aby pobrać wielokrotność kanałów jednocześnie (do 1k), również jako ćwiczenie nauczyć Netty 4.

Moje pytanie brzmi, czy jest to dobre wyjaśnienie gdzieś jak nowa Infrastruktura ByteBuf działa? Kto "jest ich właścicielem", jak się dzielą (prawda?)? Czy każdy ChannelHandler w ChannelPipeline ma swój własny ByteBuf?

Oto przykład, że zostawiła mnie zastanawia:

dodałem wystąpienie następnej klasy rurociągu klienta HTTP:

public class MyFilter extends MessageToMessageDecoder<HttpObject> { 

    @Override 
    protected Object decode(ChannelHandlerContext ctx, HttpObject msg) throws Exception { 
     // do some work, but leave msg unchanged 
     BufUtil.retain(msg); // Why do I need to call BufUtil.retain(msg) ??? 
     return msg; 
} 

Gdybym nie nazywają BufUtil.retain na MSG, wydaje się, że dostaje GCd i otrzymuję różnego rodzaju fałszywe błędy.

Answer 1

rozszerza ReferenceCounted, aby śledzić cykl życia przechowywanego bufora. Po utworzeniu instancji ReferenceCounted rozpoczyna się ona od refCnt z 1. Jeśli zadzwonisz pod numer retain(), zwiększy się refCnt. refCnt został zmniejszony na release(), a zasób bazowy (ByteBuf w tym przypadku) zostaje zniszczony, gdy refCnt stanie się 0.

Zwykle program obsługi nie musi przechowywać odniesienia do komunikatu, który zakończył obsługiwać, ponieważ wiadomość jest zwykle wyrzucana lub przekształcana w coś innego po przetworzeniu. W związku z tym należy wywołać metodę release() po jej zakończeniu przez program obsługi. Jest to często podatne na błędy i bardzo łatwo prowadzi do wycieku zasobów.

Aby uniknąć nieszczelności, która jest bardzo trudna do wyśledzenia, należy przedłużyć SimpleChannelInboundHandler, która automatycznie wywołuje release() w wiadomościach po ich przetworzeniu.

Aby uzyskać więcej informacji na temat liczenia odniesień w Netty, przeczytaj this wiki page. Zawiera również szczegółowe informacje o tym, jak rozwiązać problem wycieków w buforze, korzystając z mechanizmu wykrywania wycieków w buforze Netty.