程序包 org.apache.dubbo.common.serialize.protobuf.support

类 GenericProtobufJsonObjectInput

java.lang.Object

org.apache.dubbo.common.serialize.protobuf.support.GenericProtobufJsonObjectInput

所有已实现的接口:

DataInput, ObjectInput

public class GenericProtobufJsonObjectInput
extends Object
implements ObjectInput

GenericGoogleProtobuf object input implementation

构造器概要

构造器

构造器	说明
GenericProtobufJsonObjectInput(InputStream in)

方法概要

修饰符和类型	方法	说明
Map<String,Object>	readAttachments()	FIXME, only supports transmission of String values.
boolean	readBool()	Read boolean.
byte	readByte()	Read byte.
byte[]	readBytes()	Read byte array.
double	readDouble()	Read double.
Object	readEvent()
float	readFloat()	Read float.
int	readInt()	Read integer.
long	readLong()	Read long.
Object	readObject()	Consider use ObjectInput.readObject(Class) or ObjectInput.readObject(Class, Type) where possible
<T> T	readObject(Class<T> cls)	read object
<T> T	readObject(Class<T> cls, Type type)	read object
short	readShort()	Read short integer.
Throwable	readThrowable()	The following methods are customized for the requirement of Dubbo's RPC protocol implementation.
String	readUTF()	Read UTF-8 string.

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

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

构造器详细资料

GenericProtobufJsonObjectInput

public GenericProtobufJsonObjectInput(InputStream in)

方法详细资料

readBool

public boolean readBool()
                 throws IOException

从接口复制的说明: DataInput

Read boolean.

指定者:

readBool 在接口中 DataInput

返回:

boolean.

抛出:

IOException

readByte

public byte readByte()
              throws IOException

从接口复制的说明: DataInput

Read byte.

指定者:

readByte 在接口中 DataInput

返回:

byte value.

抛出:

IOException

readShort

public short readShort()
                throws IOException

从接口复制的说明: DataInput

Read short integer.

指定者:

readShort 在接口中 DataInput

返回:

short.

抛出:

IOException

readInt

public int readInt()
            throws IOException

从接口复制的说明: DataInput

Read integer.

指定者:

readInt 在接口中 DataInput

返回:

integer.

抛出:

IOException

readLong

public long readLong()
              throws IOException

从接口复制的说明: DataInput

Read long.

指定者:

readLong 在接口中 DataInput

返回:

long.

抛出:

IOException

readFloat

public float readFloat()
                throws IOException

从接口复制的说明: DataInput

Read float.

指定者:

readFloat 在接口中 DataInput

返回:

float.

抛出:

IOException

readDouble

public double readDouble()
                  throws IOException

从接口复制的说明: DataInput

Read double.

指定者:

readDouble 在接口中 DataInput

返回:

double.

抛出:

IOException

readUTF

public String readUTF()
               throws IOException

从接口复制的说明: DataInput

Read UTF-8 string.

指定者:

readUTF 在接口中 DataInput

返回:

string.

抛出:

IOException

readBytes

public byte[] readBytes()
                 throws IOException

从接口复制的说明: DataInput

Read byte array.

指定者:

readBytes 在接口中 DataInput

返回:

byte array.

抛出:

IOException

readObject

public Object readObject()

从接口复制的说明: ObjectInput

Consider use ObjectInput.readObject(Class) or ObjectInput.readObject(Class, Type) where possible

指定者:

readObject 在接口中 ObjectInput

返回:

object

readObject

public <T> T readObject(Class<T> cls)
                 throws IOException

从接口复制的说明: ObjectInput

read object

指定者:

readObject 在接口中 ObjectInput

参数:

cls - object class

返回:

object

抛出:

IOException - if an I/O error occurs

readObject

public <T> T readObject(Class<T> cls,
                        Type type)
                 throws IOException

从接口复制的说明: ObjectInput

read object

指定者:

readObject 在接口中 ObjectInput

参数:

cls - object class

type - object type

返回:

object

抛出:

IOException - if an I/O error occurs

readThrowable

public Throwable readThrowable()
                        throws IOException

从接口复制的说明: ObjectInput

The following methods are customized for the requirement of Dubbo's RPC protocol implementation. Legacy protocol implementation will try to write Map, Throwable and Null value directly to the stream, which does not meet the restrictions of all serialization protocols.

See how ProtobufSerialization, KryoSerialization implemented these methods for more details.

The binding of RPC protocol and biz serialization protocol is not a good practice. Encoding of RPC protocol should be highly independent and portable, easy to cross platforms and languages, for example, like the http headers, restricting the content of headers / attachments to Ascii strings and uses ISO_8859_1 to encode them. https://tools.ietf.org/html/rfc7540#section-8.1.2

指定者:

readThrowable 在接口中 ObjectInput

抛出:

IOException

readAttachments

public Map<String,Object> readAttachments()
                                         throws IOException,
                                                ClassNotFoundException

FIXME, only supports transmission of String values.

指定者:

readAttachments 在接口中 ObjectInput

返回:

抛出:

IOException

ClassNotFoundException

readEvent

public Object readEvent()
                 throws IOException,
                        ClassNotFoundException

指定者:

readEvent 在接口中 ObjectInput

抛出:

IOException

ClassNotFoundException