Class ObjectDecoderInputStream
- java.lang.Object
-
- java.io.InputStream
-
- io.netty.handler.codec.serialization.ObjectDecoderInputStream
-
- All Implemented Interfaces:
java.io.Closeable,java.io.DataInput,java.io.ObjectInput,java.lang.AutoCloseable
public class ObjectDecoderInputStream extends java.io.InputStream implements java.io.ObjectInput
-
-
Field Summary
Fields Modifier and Type Field Description private ClassResolverclassResolverprivate java.io.DataInputStreaminprivate intmaxObjectSize
-
Constructor Summary
Constructors Constructor Description ObjectDecoderInputStream(java.io.InputStream in)Creates a newObjectInput.ObjectDecoderInputStream(java.io.InputStream in, int maxObjectSize)Creates a newObjectInput.ObjectDecoderInputStream(java.io.InputStream in, java.lang.ClassLoader classLoader)Creates a newObjectInput.ObjectDecoderInputStream(java.io.InputStream in, java.lang.ClassLoader classLoader, int maxObjectSize)Creates a newObjectInput.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description intavailable()voidclose()voidmark(int readlimit)booleanmarkSupported()intread()intread(byte[] b)intread(byte[] b, int off, int len)booleanreadBoolean()bytereadByte()charreadChar()doublereadDouble()floatreadFloat()voidreadFully(byte[] b)voidreadFully(byte[] b, int off, int len)intreadInt()java.lang.StringreadLine()Deprecated.UseBufferedReader.readLine()instead.longreadLong()java.lang.ObjectreadObject()shortreadShort()intreadUnsignedByte()intreadUnsignedShort()java.lang.StringreadUTF()voidreset()longskip(long n)intskipBytes(int n)
-
-
-
Field Detail
-
in
private final java.io.DataInputStream in
-
maxObjectSize
private final int maxObjectSize
-
classResolver
private final ClassResolver classResolver
-
-
Constructor Detail
-
ObjectDecoderInputStream
public ObjectDecoderInputStream(java.io.InputStream in)
Creates a newObjectInput.- Parameters:
in- theInputStreamwhere the serialized form will be read from
-
ObjectDecoderInputStream
public ObjectDecoderInputStream(java.io.InputStream in, java.lang.ClassLoader classLoader)Creates a newObjectInput.- Parameters:
in- theInputStreamwhere the serialized form will be read fromclassLoader- theClassLoaderwhich will load the class of the serialized object
-
ObjectDecoderInputStream
public ObjectDecoderInputStream(java.io.InputStream in, int maxObjectSize)Creates a newObjectInput.- Parameters:
in- theInputStreamwhere the serialized form will be read frommaxObjectSize- the maximum byte length of the serialized object. if the length of the received object is greater than this value, aStreamCorruptedExceptionwill be raised.
-
ObjectDecoderInputStream
public ObjectDecoderInputStream(java.io.InputStream in, java.lang.ClassLoader classLoader, int maxObjectSize)Creates a newObjectInput.- Parameters:
in- theInputStreamwhere the serialized form will be read fromclassLoader- theClassLoaderwhich will load the class of the serialized objectmaxObjectSize- the maximum byte length of the serialized object. if the length of the received object is greater than this value, aStreamCorruptedExceptionwill be raised.
-
-
Method Detail
-
readObject
public java.lang.Object readObject() throws java.lang.ClassNotFoundException, java.io.IOException- Specified by:
readObjectin interfacejava.io.ObjectInput- Throws:
java.lang.ClassNotFoundExceptionjava.io.IOException
-
available
public int available() throws java.io.IOException- Specified by:
availablein interfacejava.io.ObjectInput- Overrides:
availablein classjava.io.InputStream- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException- Specified by:
closein interfacejava.lang.AutoCloseable- Specified by:
closein interfacejava.io.Closeable- Specified by:
closein interfacejava.io.ObjectInput- Overrides:
closein classjava.io.InputStream- Throws:
java.io.IOException
-
mark
public void mark(int readlimit)
- Overrides:
markin classjava.io.InputStream
-
markSupported
public boolean markSupported()
- Overrides:
markSupportedin classjava.io.InputStream
-
read
public int read() throws java.io.IOException- Specified by:
readin interfacejava.io.ObjectInput- Specified by:
readin classjava.io.InputStream- Throws:
java.io.IOException
-
read
public final int read(byte[] b, int off, int len) throws java.io.IOException- Specified by:
readin interfacejava.io.ObjectInput- Overrides:
readin classjava.io.InputStream- Throws:
java.io.IOException
-
read
public final int read(byte[] b) throws java.io.IOException- Specified by:
readin interfacejava.io.ObjectInput- Overrides:
readin classjava.io.InputStream- Throws:
java.io.IOException
-
readBoolean
public final boolean readBoolean() throws java.io.IOException- Specified by:
readBooleanin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readByte
public final byte readByte() throws java.io.IOException- Specified by:
readBytein interfacejava.io.DataInput- Throws:
java.io.IOException
-
readChar
public final char readChar() throws java.io.IOException- Specified by:
readCharin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readDouble
public final double readDouble() throws java.io.IOException- Specified by:
readDoublein interfacejava.io.DataInput- Throws:
java.io.IOException
-
readFloat
public final float readFloat() throws java.io.IOException- Specified by:
readFloatin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readFully
public final void readFully(byte[] b, int off, int len) throws java.io.IOException- Specified by:
readFullyin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readFully
public final void readFully(byte[] b) throws java.io.IOException- Specified by:
readFullyin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readInt
public final int readInt() throws java.io.IOException- Specified by:
readIntin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readLine
@Deprecated public final java.lang.String readLine() throws java.io.IOExceptionDeprecated.UseBufferedReader.readLine()instead.- Specified by:
readLinein interfacejava.io.DataInput- Throws:
java.io.IOException
-
readLong
public final long readLong() throws java.io.IOException- Specified by:
readLongin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readShort
public final short readShort() throws java.io.IOException- Specified by:
readShortin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readUnsignedByte
public final int readUnsignedByte() throws java.io.IOException- Specified by:
readUnsignedBytein interfacejava.io.DataInput- Throws:
java.io.IOException
-
readUnsignedShort
public final int readUnsignedShort() throws java.io.IOException- Specified by:
readUnsignedShortin interfacejava.io.DataInput- Throws:
java.io.IOException
-
readUTF
public final java.lang.String readUTF() throws java.io.IOException- Specified by:
readUTFin interfacejava.io.DataInput- Throws:
java.io.IOException
-
reset
public void reset() throws java.io.IOException- Overrides:
resetin classjava.io.InputStream- Throws:
java.io.IOException
-
skip
public long skip(long n) throws java.io.IOException- Specified by:
skipin interfacejava.io.ObjectInput- Overrides:
skipin classjava.io.InputStream- Throws:
java.io.IOException
-
skipBytes
public final int skipBytes(int n) throws java.io.IOException- Specified by:
skipBytesin interfacejava.io.DataInput- Throws:
java.io.IOException
-
-