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, 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 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 AbstractNioChannel.AbstractNioUnsafe	newUnsafe() Create a new AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel
protected void	setOpWrite()

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

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

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

alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doDisconnect, doShutdownOutput, equals, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, remoteAddress0, toString, voidPromise, write, write, writeAndFlush, writeAndFlush

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

attr

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

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

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

config, isActive, metadata

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

attr

构造器详细资料

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

方法详细资料

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

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()