io.netty.channel.nio

类 AbstractNioChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.channel.nio.AbstractNioChannel

所有已实现的接口:

Channel, ChannelOutboundInvoker, AttributeMap, java.lang.Comparable<Channel>

直接已知子类:

AbstractNioByteChannel, AbstractNioMessageChannel

public abstract class AbstractNioChannel
extends AbstractChannel

Abstract base class for Channel implementations which use a Selector based approach.

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	AbstractNioChannel.AbstractNioUnsafe
static interface	AbstractNioChannel.NioUnsafe Special Unsafe sub-type which allows to access the underlying SelectableChannel

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

AbstractChannel.AbstractUnsafe

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

Channel.Unsafe

字段概要

字段

限定符和类型	字段和说明
protected int	readInterestOp

构造器概要

构造器

限定符	构造器和说明
protected	AbstractNioChannel(Channel parent, java.nio.channels.SelectableChannel ch, int readInterestOp) Create a new instance

方法概要

限定符和类型	方法和说明
protected void	clearReadPending() Set read pending to false.
protected void	doBeginRead() Schedule a read operation.
protected void	doClose() Close the Channel
protected abstract boolean	doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) Connect to the remote peer
protected void	doDeregister() Deregister the Channel from its EventLoop.
protected abstract void	doFinishConnect() Finish the connect
protected void	doRegister() Is called after the Channel is registered with its EventLoop as part of the register process.
NioEventLoop	eventLoop() Return the EventLoop this Channel was registered to.
protected boolean	isCompatible(EventLoop loop) Return true if the given EventLoop is compatible with this instance.
boolean	isOpen() Returns true if the Channel is open and may get active later
protected boolean	isReadPending() 已过时。 No longer supported. No longer supported.
protected java.nio.channels.SelectableChannel	javaChannel()
protected ByteBuf	newDirectBuffer(ByteBuf buf) Returns an off-heap copy of the specified ByteBuf, and releases the original one.
protected ByteBuf	newDirectBuffer(ReferenceCounted holder, ByteBuf buf) Returns an off-heap copy of the specified ByteBuf, and releases the specified holder.
protected java.nio.channels.SelectionKey	selectionKey() Return the current SelectionKey
protected void	setReadPending(boolean readPending) 已过时。 Use clearReadPending() if appropriate instead. No longer supported.
AbstractNioChannel.NioUnsafe	unsafe() Returns an internal-use-only object that provides unsafe operations.

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

alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doDisconnect, doShutdownOutput, doWrite, equals, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, newUnsafe, parent, pipeline, read, remoteAddress, remoteAddress0, toString, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush

从类继承的方法 io.netty.util.DefaultAttributeMap

attr, hasAttr

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

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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

config, isActive, metadata

从接口继承的方法 io.netty.util.AttributeMap

attr, hasAttr

字段详细资料

readInterestOp

protected final int readInterestOp

构造器详细资料

AbstractNioChannel

protected AbstractNioChannel(Channel parent,
                             java.nio.channels.SelectableChannel ch,
                             int readInterestOp)

Create a new instance

参数:

parent - the parent Channel by which this instance was created. May be null

ch - the underlying SelectableChannel on which it operates

readInterestOp - the ops to set to receive data from the SelectableChannel

方法详细资料

isOpen

public boolean isOpen()

从接口复制的说明: Channel

Returns true if the Channel is open and may get active later

unsafe

public AbstractNioChannel.NioUnsafe unsafe()

从接口复制的说明: Channel

Returns an internal-use-only object that provides unsafe operations.

指定者:

unsafe 在接口中 Channel

覆盖:

unsafe 在类中 AbstractChannel

javaChannel

protected java.nio.channels.SelectableChannel javaChannel()

eventLoop

public NioEventLoop eventLoop()

从接口复制的说明: Channel

Return the EventLoop this Channel was registered to.

指定者:

eventLoop 在接口中 Channel

覆盖:

eventLoop 在类中 AbstractChannel

selectionKey

protected java.nio.channels.SelectionKey selectionKey()

Return the current SelectionKey

isReadPending

@Deprecated
protected boolean isReadPending()

已过时。 No longer supported. No longer supported.

setReadPending

@Deprecated
protected void setReadPending(boolean readPending)

已过时。 Use clearReadPending() if appropriate instead. No longer supported.

clearReadPending

protected final void clearReadPending()

Set read pending to false.

isCompatible

protected boolean isCompatible(EventLoop loop)

从类复制的说明: AbstractChannel

Return true if the given EventLoop is compatible with this instance.

指定者:

isCompatible 在类中 AbstractChannel

doRegister

protected void doRegister()
                   throws java.lang.Exception

从类复制的说明: AbstractChannel

Is called after the Channel is registered with its EventLoop as part of the register process. Sub-classes may override this method

覆盖:

doRegister 在类中 AbstractChannel

抛出:

java.lang.Exception

doDeregister

protected void doDeregister()
                     throws java.lang.Exception

从类复制的说明: AbstractChannel

Deregister the Channel from its EventLoop. Sub-classes may override this method

覆盖:

doDeregister 在类中 AbstractChannel

抛出:

java.lang.Exception

doBeginRead

protected void doBeginRead()
                    throws java.lang.Exception

从类复制的说明: AbstractChannel

Schedule a read operation.

指定者:

doBeginRead 在类中 AbstractChannel

抛出:

java.lang.Exception

doConnect

protected abstract boolean doConnect(java.net.SocketAddress remoteAddress,
                                     java.net.SocketAddress localAddress)
                              throws java.lang.Exception

Connect to the remote peer

抛出:

java.lang.Exception

doFinishConnect

protected abstract void doFinishConnect()
                                 throws java.lang.Exception

Finish the connect

抛出:

java.lang.Exception

newDirectBuffer

protected final ByteBuf newDirectBuffer(ByteBuf buf)

Returns an off-heap copy of the specified ByteBuf, and releases the original one. Note that this method does not create an off-heap copy if the allocation / deallocation cost is too high, but just returns the original ByteBuf..

newDirectBuffer

protected final ByteBuf newDirectBuffer(ReferenceCounted holder,
                                        ByteBuf buf)

Returns an off-heap copy of the specified ByteBuf, and releases the specified holder. The caller must ensure that the holder releases the original ByteBuf when the holder is released by this method. Note that this method does not create an off-heap copy if the allocation / deallocation cost is too high, but just returns the original ByteBuf..

doClose

protected void doClose()
                throws java.lang.Exception

从类复制的说明: AbstractChannel

Close the Channel

指定者:

doClose 在类中 AbstractChannel

抛出:

java.lang.Exception