io.netty.channel.nio

类 AbstractNioByteChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.channel.nio.AbstractNioChannel

io.netty.channel.nio.AbstractNioByteChannel

所有已实现的接口:

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

直接已知子类:

NioSocketChannel, NioUdtByteConnectorChannel

public abstract class AbstractNioByteChannel
extends AbstractNioChannel

AbstractNioChannel base class for Channels that operate on bytes.

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	AbstractNioByteChannel.NioByteUnsafe

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

AbstractNioChannel.AbstractNioUnsafe, AbstractNioChannel.NioUnsafe

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

AbstractChannel.AbstractUnsafe

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

Channel.Unsafe

字段概要

从类继承的字段 io.netty.channel.nio.AbstractNioChannel

readInterestOp

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected void	clearOpWrite()
protected abstract int	doReadBytes(ByteBuf buf) Read bytes into the given ByteBuf and return the amount.
protected void	doWrite(ChannelOutboundBuffer in) Flush the content of the given buffer to the remote peer.
protected int	doWrite0(ChannelOutboundBuffer in) Write objects to the OS.
protected abstract int	doWriteBytes(ByteBuf buf) Write bytes form the given ByteBuf to the underlying Channel.
protected abstract long	doWriteFileRegion(FileRegion region) Write a FileRegion
protected java.lang.Object	filterOutboundMessage(java.lang.Object msg) Invoked when a new message is added to a ChannelOutboundBuffer of this AbstractChannel, so that the Channel implementation converts the message to another.
protected void	incompleteWrite(boolean setOpWrite)
protected boolean	isInputShutdown0()
ChannelMetadata	metadata() Return the ChannelMetadata of the Channel which describe the nature of the Channel.
protected AbstractNioChannel.AbstractNioUnsafe	newUnsafe() Create a new AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel
protected void	setOpWrite()
protected abstract ChannelFuture	shutdownInput() Shutdown the input side of the channel.

从类继承的方法 io.netty.channel.nio.AbstractNioChannel

clearReadPending, doBeginRead, doClose, doConnect, doDeregister, doFinishConnect, doRegister, eventLoop, isCompatible, isOpen, isReadPending, javaChannel, newDirectBuffer, newDirectBuffer, selectionKey, setReadPending, unsafe

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

alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doDisconnect, doShutdownOutput, equals, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, 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

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

attr, hasAttr

构造器详细资料

AbstractNioByteChannel

protected AbstractNioByteChannel(Channel parent,
                                 java.nio.channels.SelectableChannel ch)

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

方法详细资料

shutdownInput

protected abstract ChannelFuture shutdownInput()

Shutdown the input side of the channel.

isInputShutdown0

protected boolean isInputShutdown0()

newUnsafe

protected AbstractNioChannel.AbstractNioUnsafe newUnsafe()

从类复制的说明: AbstractChannel

Create a new AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel

指定者:

newUnsafe 在类中 AbstractChannel

metadata

public ChannelMetadata metadata()

从接口复制的说明: Channel

Return the ChannelMetadata of the Channel which describe the nature of the Channel.

doWrite0

protected final int doWrite0(ChannelOutboundBuffer in)
                      throws java.lang.Exception

Write objects to the OS.

参数:

in - the collection which contains objects to write.

返回:

The value that should be decremented from the write quantum which starts at ChannelConfig.getWriteSpinCount(). The typical use cases are as follows:

• 0 - if no write was attempted. This is appropriate if an empty ByteBuf (or other empty content) is encountered
• 1 - if a single call to write data was made to the OS
• ChannelUtils.WRITE_STATUS_SNDBUF_FULL - if an attempt to write data was made to the OS, but no data was accepted

抛出:

java.lang.Exception - if an I/O exception occurs during write.

doWrite

protected void doWrite(ChannelOutboundBuffer in)
                throws java.lang.Exception

从类复制的说明: AbstractChannel

Flush the content of the given buffer to the remote peer.

指定者:

doWrite 在类中 AbstractChannel

抛出:

java.lang.Exception

filterOutboundMessage

protected final java.lang.Object filterOutboundMessage(java.lang.Object msg)

从类复制的说明: AbstractChannel

Invoked when a new message is added to a ChannelOutboundBuffer of this AbstractChannel, so that the Channel implementation converts the message to another. (e.g. heap buffer -> direct buffer)

覆盖:

filterOutboundMessage 在类中 AbstractChannel

incompleteWrite

protected final void incompleteWrite(boolean setOpWrite)

doWriteFileRegion

protected abstract long doWriteFileRegion(FileRegion region)
                                   throws java.lang.Exception

Write a FileRegion

参数:

region - the FileRegion from which the bytes should be written

返回:

amount the amount of written bytes

抛出:

java.lang.Exception

doReadBytes

protected abstract int doReadBytes(ByteBuf buf)
                            throws java.lang.Exception

Read bytes into the given ByteBuf and return the amount.

抛出:

java.lang.Exception

doWriteBytes

protected abstract int doWriteBytes(ByteBuf buf)
                             throws java.lang.Exception

Write bytes form the given ByteBuf to the underlying Channel.

参数:

buf - the ByteBuf from which the bytes should be written

返回:

amount the amount of written bytes

抛出:

java.lang.Exception

setOpWrite

protected final void setOpWrite()

clearOpWrite

protected final void clearOpWrite()