io.netty.handler.codec.json

类 JsonObjectDecoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.ByteToMessageDecoder

io.netty.handler.codec.json.JsonObjectDecoder

所有已实现的接口:

ChannelHandler, ChannelInboundHandler

public class JsonObjectDecoder
extends ByteToMessageDecoder

Splits a byte stream of JSON objects and arrays into individual objects/arrays and passes them up the ChannelPipeline.

The byte stream is expected to be in UTF-8 character encoding or ASCII. The current implementation uses direct byte to char cast and then compares that char to a few low range ASCII characters like '{'}, {@code '['} or {@code '"'}. UTF-8 is not using low range [0..0x7F] byte values for multibyte codepoint representations therefore fully supported by this implementation.

This class does not do any real parsing or validation. A sequence of bytes is considered a JSON object/array if it contains a matching number of opening and closing braces/brackets. It's up to a subsequent {@link ChannelHandler} to parse the JSON text into a more usable form i.e. a POJO.

嵌套类概要

从类继承的嵌套类/接口 io.netty.handler.codec.ByteToMessageDecoder

ByteToMessageDecoder.Cumulator

从接口继承的嵌套类/接口 io.netty.channel.ChannelHandler

ChannelHandler.Sharable

字段概要

从类继承的字段 io.netty.handler.codec.ByteToMessageDecoder

COMPOSITE_CUMULATOR, MERGE_CUMULATOR

构造器概要

构造器

构造器和说明
JsonObjectDecoder()
JsonObjectDecoder(boolean streamArrayElements)
JsonObjectDecoder(int maxObjectLength)
JsonObjectDecoder(int maxObjectLength, boolean streamArrayElements)

方法概要

限定符和类型	方法和说明
protected void	decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) Decode the from one ByteBuf to an other.
protected ByteBuf	extractObject(ChannelHandlerContext ctx, ByteBuf buffer, int index, int length) Override this method if you want to filter the json objects/arrays that get passed through the pipeline.

从类继承的方法 io.netty.handler.codec.ByteToMessageDecoder

actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered

从类继承的方法 io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught

从类继承的方法 io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, isSharable

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

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

从接口继承的方法 io.netty.channel.ChannelHandler

handlerAdded

构造器详细资料

JsonObjectDecoder

public JsonObjectDecoder()

JsonObjectDecoder

public JsonObjectDecoder(int maxObjectLength)

JsonObjectDecoder

public JsonObjectDecoder(boolean streamArrayElements)

JsonObjectDecoder

public JsonObjectDecoder(int maxObjectLength,
                         boolean streamArrayElements)

参数:

maxObjectLength - maximum number of bytes a JSON object/array may use (including braces and all). Objects exceeding this length are dropped and an TooLongFrameException is thrown.

streamArrayElements - if set to true and the "top level" JSON object is an array, each of its entries is passed through the pipeline individually and immediately after it was fully received, allowing for arrays with "infinitely" many elements.

方法详细资料

decode

protected void decode(ChannelHandlerContext ctx,
                      ByteBuf in,
                      java.util.List<java.lang.Object> out)
               throws java.lang.Exception

从类复制的说明: ByteToMessageDecoder

Decode the from one ByteBuf to an other. This method will be called till either the input ByteBuf has nothing to read when return from this method or till nothing was read from the input ByteBuf.

指定者:

decode 在类中 ByteToMessageDecoder

参数:

ctx - the ChannelHandlerContext which this ByteToMessageDecoder belongs to

in - the ByteBuf from which to read data

out - the List to which decoded messages should be added

抛出:

java.lang.Exception - is thrown if an error occurs

extractObject

protected ByteBuf extractObject(ChannelHandlerContext ctx,
                                ByteBuf buffer,
                                int index,
                                int length)

Override this method if you want to filter the json objects/arrays that get passed through the pipeline.