org.apache.hadoop.net

类 SocketOutputStream

java.lang.Object

java.io.OutputStream

org.apache.hadoop.net.SocketOutputStream

所有已实现的接口:

Closeable, Flushable, AutoCloseable, Channel, WritableByteChannel

public class SocketOutputStream
extends OutputStream
implements WritableByteChannel

This implements an output stream that can have a timeout while writing. This sets non-blocking flag on the socket channel. So after creating this object , read() on Socket.getInputStream() and write() on Socket.getOutputStream() on the associated socket will throw llegalBlockingModeException. Please use SocketInputStream for reading.

构造器概要

构造器

构造器和说明
SocketOutputStream(Socket socket, long timeout) Same as SocketOutputStream(socket.getChannel(), timeout): Create a new ouput stream with the given timeout.
SocketOutputStream(WritableByteChannel channel, long timeout) Create a new ouput stream with the given timeout.

方法概要

方法

限定符和类型	方法和说明
void	close()
WritableByteChannel	getChannel() Returns underlying channel used by this stream.
boolean	isOpen()
void	transferToFully(FileChannel fileCh, long position, int count) Transfers data from FileChannel using FileChannel.transferTo(long, long, WritableByteChannel).
void	waitForWritable() waits for the underlying channel to be ready for writing.
void	write(byte[] b, int off, int len)
int	write(ByteBuffer src)
void	write(int b)

从类继承的方法 java.io.OutputStream

flush, write

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SocketOutputStream

public SocketOutputStream(WritableByteChannel channel,
                  long timeout)
                   throws IOException

Create a new ouput stream with the given timeout. If the timeout is zero, it will be treated as infinite timeout. The socket's channel will be configured to be non-blocking.

参数:

channel - Channel for writing, should also be a SelectableChannel. The channel will be configured to be non-blocking.

timeout - timeout in milliseconds. must not be negative.

抛出:

IOException

SocketOutputStream

public SocketOutputStream(Socket socket,
                  long timeout)
                   throws IOException

Same as SocketOutputStream(socket.getChannel(), timeout):

Create a new ouput stream with the given timeout. If the timeout is zero, it will be treated as infinite timeout. The socket's channel will be configured to be non-blocking.

参数:

socket - should have a channel associated with it.

timeout - timeout timeout in milliseconds. must not be negative.

抛出:

IOException

另请参阅:

SocketOutputStream(WritableByteChannel, long)

方法详细资料

write

public void write(int b)
           throws IOException

指定者:

write 在类中 OutputStream

抛出:

IOException

write

public void write(byte[] b,
         int off,
         int len)
           throws IOException

覆盖:

write 在类中 OutputStream

抛出:

IOException

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Channel

覆盖:

close 在类中 OutputStream

抛出:

IOException

getChannel

public WritableByteChannel getChannel()

Returns underlying channel used by this stream. This is useful in certain cases like channel for FileChannel.transferTo(long, long, WritableByteChannel)

isOpen

public boolean isOpen()

指定者:

isOpen 在接口中 Channel

write

public int write(ByteBuffer src)
          throws IOException

指定者:

write 在接口中 WritableByteChannel

抛出:

IOException

waitForWritable

public void waitForWritable()
                     throws IOException

waits for the underlying channel to be ready for writing. The timeout specified for this stream applies to this wait.

抛出:

SocketTimeoutException - if select on the channel times out.

IOException - if any other I/O error occurs.

transferToFully

public void transferToFully(FileChannel fileCh,
                   long position,
                   int count)
                     throws IOException

Transfers data from FileChannel using FileChannel.transferTo(long, long, WritableByteChannel). Similar to readFully(), this waits till requested amount of data is transfered.

参数:

fileCh - FileChannel to transfer data from.

position - position within the channel where the transfer begins

count - number of bytes to transfer.

抛出:

EOFException - If end of input file is reached before requested number of bytes are transfered.

SocketTimeoutException - If this channel blocks transfer longer than timeout for this stream.

IOException - Includes any exception thrown by FileChannel.transferTo(long, long, WritableByteChannel).