Clearing-ein ByteBuffer

Sehr einfaches problem: ich lese aus einem SocketChannel und möchte schreiben die Ergebnisse auf ein anderes SocketChannel. Ich bin über einen Selektor-Objekt, so dass ich warten, bis einer der SocketChannel lesbar ist, dump die Daten in einen ByteBuffer, und dann, wenn die nächste SocketChannel beschreibbar ist, habe ich einen dump der ByteBuffer es. OK so weit. Es wird jedoch nicht angezeigt, gibt es eine Möglichkeit, eigentlich "klar" einen ByteBuffer, so kann ich das nicht jede Art von überprüfen, um zu wissen, Wann neue Daten da sind.

Ich ausprobiert habe .clear () - Methode, aber, dass anscheinend nicht klar, das Puffer -, sondern nur setzt die buffer-position 1.

Hier einige Beispiel-code:

ByteBuffer channel1buf = ByteBuffer.allocate(1024);
ByteBuffer channel2buf = ByteBuffer.allocate(1024);

if (key.isReadable()) {
    if (key.channel().equals(channel1)) {
        channel1.read(channel2buf);
    } else if (key.channel().equals(channel2)) {
        channel2.read(channel1buf);
    }
} else if (key.isWritable()) {
    if (key.channel().equals(channel1) && channel1buf.asCharBuffer().length() > 0) {
        channel1.write(channel1buf);
        /* some way to clear channel1buf */
    } else /* same idea for channel2... */
}
  • Sollten Sie die ByteBuffer als Anhang während der Registrierung von Kanal zu dem Selektor (Dritter parameter der regsiter-Methode), so können Sie abrufen, die Anlage aus der SelectionKey und vermeiden Sie alle verschachtelten if-Klauseln.
InformationsquelleAutor user1241397 | 2012-02-29
  1. 6

    Buffer.clear setzt die position, ja, und dann können Sie getPosition() > 0 zu überprüfen, wenn etwas Hinzugefügt wurde, um den Puffer danach, nicht...?

    • Dass fast funktioniert, aber der Puffer hat noch die alten Daten, so dass es dann drucken Sie keine überlauf. Ich denke, ich könnte gehen Sie durch die Puffer und reinigen Sie es manuell, aber das scheint nicht zu elegant.
    • Der Punkt ist, warum haben Sie Sorge, wenn die Puffer noch den alten Daten? Es ist nicht so, wenn Sie es deaktivieren aus Sie lassen würde GC nichts. Nur schauen Sie nicht auf alles, was sich darunter getPosition() und Sie sollten in Ordnung sein...oder ist es etwas, was ich bin fehlt?
    • Naja, der Puffer einige Feste Größe, so dass, wenn ich tun, dass ich schließlich aus dem Raum laufen in den Puffer.
    • Nicht wahr. Wenn Sie anrufen Buffer.clear() es setzt die schreib-position auf 0, so dass jede neue schreibt in den Puffer schreiben Sie einfach über die alten Daten, die du hast.
    • Ah, kapiert! War nicht sicher, in welche Richtung "unten" bezog sich auch :-).
    • Kann die Verwendung von ByteBuffer führen, um die Out-of-memory? Ist der Speicher gelöscht, wenn Sie Sie ausführen clear()?
    • ja, Sie kann dazu führen, ein OOM, wenn man genügend von Ihnen, und halten Sie Sie.. Nein, aufrufen von clear() nichts zu reklamieren, das Gedächtnis; lassen Sie Sie fallen aus dem Rahmen und entfernen von verweisen tut. ByteBuffers werden wie jedes andere Java-Objekt.
    • Nach langer Arbeit haben wir ein Gerät zum Absturz und Neustart. Aber das Gerät zeigt nur die boot-Bildschirm und startet wieder (das OS bootet nicht vollständig). Können die out-of-memory Ursache solcher Folgen? Oder kann das passieren, wenn wir sehr oft (jede Sekunde) erstellen Sie ein bytebuffer? Kann etwas passieren, um die Erinnerung? Oder etwas anderes? Sie wird mir sehr helfen mit Ihrer Meinung!) danke!

    InformationsquelleAutor Louis Wasserman
  2. 5

    Ich gelöst gleiche problem, das der code, hoffe es kann dir helfen.

    channel1buf.clear();
//zerolize buff manually
channel1buf.put(new byte[1024]);
channel1buf.clear();
    • Oder Arrays.fill(channel1buf, (byte) 0); channel1buf.clear();
    • Aber diese Art der ZeroMemory() zu einem buffer ist nicht erforderlich, wenn Sie verwenden die ByteBuffer Klasse so wie es ist verwendet werden soll, die durch den Aufruf flip() vor dem Lesen rewind() vor re-Lektüre, clear() oder compact() vor dem schreiben.
    InformationsquelleAutor waveacme
Schreibe einen Kommentar