io.netty.channel

类 DefaultMaxMessagesRecvByteBufAllocator

java.lang.Object

io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator

所有已实现的接口:

MaxMessagesRecvByteBufAllocator, RecvByteBufAllocator

直接已知子类:

AdaptiveRecvByteBufAllocator, FixedRecvByteBufAllocator, ServerChannelRecvByteBufAllocator

public abstract class DefaultMaxMessagesRecvByteBufAllocator
extends java.lang.Object
implements MaxMessagesRecvByteBufAllocator

Default implementation of MaxMessagesRecvByteBufAllocator which respects ChannelConfig.isAutoRead() and also prevents overflow.

嵌套类概要

嵌套类

限定符和类型	类和说明
class	DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle Focuses on enforcing the maximum messages per read condition for DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle.continueReading().

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

RecvByteBufAllocator.DelegatingHandle, RecvByteBufAllocator.ExtendedHandle, RecvByteBufAllocator.Handle

构造器概要

构造器

构造器和说明
DefaultMaxMessagesRecvByteBufAllocator()
DefaultMaxMessagesRecvByteBufAllocator(int maxMessagesPerRead)

方法概要

限定符和类型	方法和说明
int	maxMessagesPerRead() Returns the maximum number of messages to read per read loop.
MaxMessagesRecvByteBufAllocator	maxMessagesPerRead(int maxMessagesPerRead) Sets the maximum number of messages to read per read loop.
boolean	respectMaybeMoreData() Get if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.
DefaultMaxMessagesRecvByteBufAllocator	respectMaybeMoreData(boolean respectMaybeMoreData) Determine if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.

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

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

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

newHandle

构造器详细资料

DefaultMaxMessagesRecvByteBufAllocator

public DefaultMaxMessagesRecvByteBufAllocator()

DefaultMaxMessagesRecvByteBufAllocator

public DefaultMaxMessagesRecvByteBufAllocator(int maxMessagesPerRead)

方法详细资料

maxMessagesPerRead

public int maxMessagesPerRead()

从接口复制的说明: MaxMessagesRecvByteBufAllocator

Returns the maximum number of messages to read per read loop. a channelRead() event. If this value is greater than 1, an event loop might attempt to read multiple times to procure multiple messages.

指定者:

maxMessagesPerRead 在接口中 MaxMessagesRecvByteBufAllocator

maxMessagesPerRead

public MaxMessagesRecvByteBufAllocator maxMessagesPerRead(int maxMessagesPerRead)

从接口复制的说明: MaxMessagesRecvByteBufAllocator

Sets the maximum number of messages to read per read loop. If this value is greater than 1, an event loop might attempt to read multiple times to procure multiple messages.

指定者:

maxMessagesPerRead 在接口中 MaxMessagesRecvByteBufAllocator

respectMaybeMoreData

public DefaultMaxMessagesRecvByteBufAllocator respectMaybeMoreData(boolean respectMaybeMoreData)

Determine if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.

参数:

respectMaybeMoreData -

• true to stop reading if we think there is no more data. This may save a system call to read from the socket, but if data has arrived in a racy fashion we may give up our maxMessagesPerRead() quantum and have to wait for the selector to notify us of more data.
• false to keep reading (up to maxMessagesPerRead()) or until there is no data when we attempt to read.

返回:

this.

respectMaybeMoreData

public final boolean respectMaybeMoreData()

Get if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.

返回:

• true to stop reading if we think there is no more data. This may save a system call to read from the socket, but if data has arrived in a racy fashion we may give up our maxMessagesPerRead() quantum and have to wait for the selector to notify us of more data.
• false to keep reading (up to maxMessagesPerRead()) or until there is no data when we attempt to read.