org.joyqueue.store.message

类 MessageParser

java.lang.Object

org.joyqueue.store.message.MessageParser

public class MessageParser
extends Object

消息解析器

作者:

liyue25 Date: 2019-01-15

字段概要

字段

限定符和类型	字段和说明
static int	APP
static int	BIZ_ID
static int	BODY
static int	CLIENT_IP
static int	CLIENT_TIMESTAMP
static int	CRC
static int	EXPAND
static int	FIXED_LENGTH_1
static int	FIXED_LENGTH_16
static int	FIXED_LENGTH_2
static int	FIXED_LENGTH_4
static int	FIXED_LENGTH_8
static int	FLAG
static int	INDEX
static int	LENGTH
static int	MAGIC
static int	PARTITION
static int	PRIORITY
static int	PROPERTY
static int	STORAGE_TIMESTAMP
static int	SYS
static int	TERM
static int	VARIABLE_LENGTH_1
static int	VARIABLE_LENGTH_2
static int	VARIABLE_LENGTH_4

构造器概要

构造器

构造器和说明
MessageParser()

方法概要

限定符和类型	方法和说明
static ByteBuffer	build(byte[][] variableAttributes)
static int	getBit(ByteBuffer messageBuffer, int byteOffset, int bitOffset)
static byte	getByte(ByteBuffer messageBuffer, int offset)
static ByteBuffer	getByteBuffer(ByteBuffer messageBuffer, int relativeOffset)
static byte[]	getBytes(ByteBuffer messageBuffer, int relativeOffset)
static int	getFixedAttributesLength()
static int	getInt(ByteBuffer messageBuffer, int offset)
static long	getLong(ByteBuffer messageBuffer, int offset)
static short	getShort(ByteBuffer messageBuffer, int offset)
static String	getString(ByteBuffer messageBuffer)
static void	main(String[] args)
static void	setBit(ByteBuffer messageBuffer, int byteOffset, int bitOffset, boolean bitValue)
static void	setByte(ByteBuffer messageBuffer, int offset, byte value)
static void	setInt(ByteBuffer messageBuffer, int offset, int value)
static void	setLong(ByteBuffer messageBuffer, int offset, long value)
static void	setShort(ByteBuffer messageBuffer, int offset, short value)

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

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

字段详细资料

VARIABLE_LENGTH_1

public static final int VARIABLE_LENGTH_1

另请参阅:

常量字段值

VARIABLE_LENGTH_2

public static final int VARIABLE_LENGTH_2

另请参阅:

常量字段值

VARIABLE_LENGTH_4

public static final int VARIABLE_LENGTH_4

另请参阅:

常量字段值

FIXED_LENGTH_1

public static final int FIXED_LENGTH_1

另请参阅:

常量字段值

FIXED_LENGTH_2

public static final int FIXED_LENGTH_2

另请参阅:

常量字段值

FIXED_LENGTH_4

public static final int FIXED_LENGTH_4

另请参阅:

常量字段值

FIXED_LENGTH_8

public static final int FIXED_LENGTH_8

另请参阅:

常量字段值

FIXED_LENGTH_16

public static final int FIXED_LENGTH_16

另请参阅:

常量字段值

LENGTH

public static final int LENGTH

PARTITION

public static final int PARTITION

INDEX

public static final int INDEX

TERM

public static final int TERM

MAGIC

public static final int MAGIC

SYS

public static final int SYS

PRIORITY

public static final int PRIORITY

CLIENT_IP

public static final int CLIENT_IP

CLIENT_TIMESTAMP

public static final int CLIENT_TIMESTAMP

STORAGE_TIMESTAMP

public static final int STORAGE_TIMESTAMP

CRC

public static final int CRC

FLAG

public static final int FLAG

BODY

public static final int BODY

BIZ_ID

public static final int BIZ_ID

PROPERTY

public static final int PROPERTY

EXPAND

public static final int EXPAND

APP

public static final int APP

构造器详细资料

MessageParser

public MessageParser()

方法详细资料

getFixedAttributesLength

public static int getFixedAttributesLength()

getByte

public static byte getByte(ByteBuffer messageBuffer,
                           int offset)

setByte

public static void setByte(ByteBuffer messageBuffer,
                           int offset,
                           byte value)

getShort

public static short getShort(ByteBuffer messageBuffer,
                             int offset)

setShort

public static void setShort(ByteBuffer messageBuffer,
                            int offset,
                            short value)

getBit

public static int getBit(ByteBuffer messageBuffer,
                         int byteOffset,
                         int bitOffset)

setBit

public static void setBit(ByteBuffer messageBuffer,
                          int byteOffset,
                          int bitOffset,
                          boolean bitValue)

getInt

public static int getInt(ByteBuffer messageBuffer,
                         int offset)

setInt

public static void setInt(ByteBuffer messageBuffer,
                          int offset,
                          int value)

getLong

public static long getLong(ByteBuffer messageBuffer,
                           int offset)

setLong

public static void setLong(ByteBuffer messageBuffer,
                           int offset,
                           long value)

getByteBuffer

public static ByteBuffer getByteBuffer(ByteBuffer messageBuffer,
                                       int relativeOffset)

getBytes

public static byte[] getBytes(ByteBuffer messageBuffer,
                              int relativeOffset)

build

public static ByteBuffer build(byte[][] variableAttributes)

getString

public static String getString(ByteBuffer messageBuffer)

main

public static void main(String[] args)