Mit Netty 4, wie handle ich Referenz gezählt Objekte, wenn eine Ausnahme in einem Handler geworfen wird?

Question

Angenommen, ich ein eingehenden Kanal-Handler wie diese:

public class Handler extends ChannelInboundHandlerAdapter {                                                     

    @Override                                                                
    protected void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {                                              
     // msg is actually a reference counted object                                                      
    }                                                                  

    @Override                                                                
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {                                            
     // Handle exception here, can't release msg since it's not passed.                                                 
    }                                                                  
} 

Da exceptionCaught nicht die eingehende Nachricht in seiner Signatur erhält, wie es scheint, gibt es keine Möglichkeit, dass der Verweis gezählt Objekt, um sicherzustellen, ist freigegeben. Es scheint, dass ich gezwungen bin, den gesamten Inhalt von channelRead in einen try/catch-Block zu packen, um sicherzustellen, dass ich für irgendwelche Ausnahmen richtig wiederherstellen kann, ohne den gesamten Prozess zu beenden. Ist das wahr?

Answer 1

Sie sollten Ihre Referenz gezählt Objekte innerhalb der Probe-endlich, wie von der Netty quick start tutorial gezeigt.

Dies kann wie folgt geschehen:

public class Handler extends ChannelInboundHandlerAdapter {                                                     

    @Override                                                                
    protected void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {                                              
     try { 
      // msg is actually a reference counted object 
     } finally { 
      ReferenceCountUtil.release(msg); 
     }                                                  
    }                                                                  

    @Override                                                                
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {                                            
     // Handle exception here, can't release msg since it's not passed.                                                 
    }                                                                  
} 

Beachten Sie, dass ich ReferenceCountUtil.release(msg); statt nur msg.release() genannt habe, ist dies, weil die Tatsache, dass die ersten automatisch Aufruf überprüft, ob das betreffende Objekt freigegeben werden kann, während Für Letzteres müssen Sie das Objekt auf einen anderen Typ umwandeln, bevor Sie die Freigabemethode aufrufen können.