org.apache.hadoop.net

类 SocketInputStream

java.lang.Object

java.io.InputStream

org.apache.hadoop.net.SocketInputStream

所有已实现的接口:

Closeable, AutoCloseable, Channel, ReadableByteChannel

public class SocketInputStream
extends InputStream
implements ReadableByteChannel

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

构造器概要

构造器

构造器和说明
SocketInputStream(ReadableByteChannel channel, long timeout) Create a new input stream with the given timeout.
SocketInputStream(Socket socket) Same as SocketInputStream(socket.getChannel(), socket.getSoTimeout()) : Create a new input stream with the given timeout.
SocketInputStream(Socket socket, long timeout) Same as SocketInputStream(socket.getChannel(), timeout): Create a new input stream with the given timeout.

方法概要

方法

限定符和类型	方法和说明
void	close()
ReadableByteChannel	getChannel() Returns underlying channel used by inputstream.
boolean	isOpen()
int	read()
int	read(byte[] b, int off, int len)
int	read(ByteBuffer dst)
void	waitForReadable() waits for the underlying channel to be ready for reading.

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

available, mark, markSupported, read, reset, skip

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

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

构造器详细资料

SocketInputStream

public SocketInputStream(ReadableByteChannel channel,
                 long timeout)
                  throws IOException

Create a new input 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 reading, should also be a SelectableChannel. The channel will be configured to be non-blocking.

timeout - timeout in milliseconds. must not be negative.

抛出:

IOException

SocketInputStream

public SocketInputStream(Socket socket,
                 long timeout)
                  throws IOException

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

Create a new input 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

另请参阅:

SocketInputStream(ReadableByteChannel, long)

SocketInputStream

public SocketInputStream(Socket socket)
                  throws IOException

Same as SocketInputStream(socket.getChannel(), socket.getSoTimeout()) :

Create a new input 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.

抛出:

IOException

另请参阅:

SocketInputStream(ReadableByteChannel, long)

方法详细资料

read

public int read()
         throws IOException

指定者:

read 在类中 InputStream

抛出:

IOException

read

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

覆盖:

read 在类中 InputStream

抛出:

IOException

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Channel

覆盖:

close 在类中 InputStream

抛出:

IOException

getChannel

public ReadableByteChannel getChannel()

Returns underlying channel used by inputstream. This is useful in certain cases like channel for FileChannel.transferFrom(ReadableByteChannel, long, long).

isOpen

public boolean isOpen()

指定者:

isOpen 在接口中 Channel

read

public int read(ByteBuffer dst)
         throws IOException

指定者:

read 在接口中 ReadableByteChannel

抛出:

IOException

waitForReadable

public void waitForReadable()
                     throws IOException

waits for the underlying channel to be ready for reading. 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.