Netty 4: Referenzzähler in gewickelten Puffern

Question

Netty 4.1.2.Final

Ich verwende Unpooled.wrappedBuffer Verfahren mehr als ein ByteBuf s einzuwickeln, API doc ist here.

public static ByteBuf wrappedBuffer(ByteBuf... buffers) 

Der Doc sagt

Referenzzählung Besitz aller Variablen dieser Methode übertragen wird.

Ich aktualisiere die Frage, damit es klarer ist.

Ich muss mehr als eine ByteBuf s an mehrere Verbindungen gleichzeitig senden. Ich kann ChannelGroup nicht verwenden, da einige der Clients im Long-Polling-Modus arbeiten, was bedeutet, dass die Antwort in der nächsten Anfrage gesendet werden muss, deren Kanal in diesem Moment nicht bereit ist.

Daher habe ich die folgende Datenstruktur, die die angeschlossenen Kanäle

private static final ConcurrentHashMap<String, Channel> channels 
    = new ConcurrentHashMap<String, Channel>(); 

Shops und Ich habe ein Verfahren mit den ByteBuf zu den Kanälen

public static void broadcast(final long registrationID, final ByteBuf [] buffers){ 
    final ByteBuf wrappedBuf = Unpooled.wrappedBuffer(buffers); 
    for(Map.Entry<String, Channel> entry : channels.entrySet()){ 
    final Channel channel = entry.getValue(); 
    if(channel != null){ 
     wrappedBuf.retain(); 

     boolean isLongPooling = channel.attr(TYPE).get(); 
     if(isLongPooling) 
      Reply.send(channel, wrappedBuf); // add into a queue which will be pulled by client in next request 
     else 
      channel.writeAndFlush(wrappedBuf); // real time client , send in current channel 
    } 
    } 
    wrappedBuf.release(); 
} 

Das Problem auszustrahlen ist, dass: Wenn ich haben mehr als einen Echtzeit-Client verbunden, nur einer von ihnen empfängt die Antwort, selbst wenn alle von ihnen geschrieben sind.

Es scheint, dass es ein Problem ist, das durch Referenzzählung verursacht wird?

Danke

Answer 1

Nein ... es bedeutet, dass die Sie benötigen Release() aufzurufen, auf dem zurückgegebenen Puffer.