src/org/objectweb/cjdbc/common/stream/CJDBCOutputStream.java

説明を見る。

package org.objectweb.cjdbc.common.stream;

import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.StreamCorruptedException;
import java.net.Socket;

public class CJDBCOutputStream
{

  private ObjectOutputStream output;
  private long               bytesWritten;
  private Socket             socket;
  private boolean            useCompression = false;
  private long               speed          = -1;
  private long               dateCreated;
  private int                unshared       = 0;

  public CJDBCOutputStream(Socket socket) throws IOException,
      StreamCorruptedException
  {
    this(socket.getOutputStream());
    this.socket = socket;
  }

  public CJDBCOutputStream(OutputStream out) throws IOException,
      StreamCorruptedException
  {
    output = new ObjectOutputStream(new BufferedOutputStream(out));
    dateCreated = System.currentTimeMillis();
    bytesWritten = 0;
  }

  public void flush() throws IOException
  {
    output.flush();
  }

  public void close() throws IOException
  {
    output.close();
  }

  public void writeObject(Object obj) throws IOException
  {
    if (useCompression)
    {
      byte[] bytes = CJDBCStream.compressObject(obj);
      bytesWritten += bytes.length + 4;
      // we are sending an integer on the pipe.

      output.writeInt(bytes.length);
      output.write(bytes);
    }
    else
    {
      // Use the unshared version to prevent the stream to keep references on
      // objects. This prevents objects sent through the channel from being
      // garbage collected and results in memory leaks.
      output.writeUnshared(obj);
      if (CJDBCStream.CLEAN_INTERVAL != -1
          && (unshared++ > CJDBCStream.CLEAN_INTERVAL))
      {
        unshared = 0;
        output.flush();
        output.reset();
      }
    }

  }

  public void writeUTF(String string) throws IOException
  {
    // use writeUnshared of writeObject of this class
    this.writeObject(string);
    if (string != null)
      bytesWritten += string.length();
  }

  public void writeInt(int value) throws IOException
  {
    bytesWritten += 4;
    output.writeInt(value);
  }

  public void writeLong(long value) throws IOException
  {
    bytesWritten += 8;
    output.writeLong(value);
  }

  public void writeBoolean(boolean value) throws IOException
  {
    bytesWritten += 1;
    output.writeBoolean(value);
  }

  public long getBytesWritten()
  {
    return bytesWritten;
  }

  public Socket getSocket()
  {
    return socket;
  }

  public long getDateCreated()
  {
    return dateCreated;
  }

  public boolean getUseCompression()
  {
    return useCompression;
  }

  public long getSpeed()
  {
    return speed;
  }
}

---