io.netty.channel.nio

类 AbstractNioMessageChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.channel.nio.AbstractNioChannel

io.netty.channel.nio.AbstractNioMessageChannel

所有已实现的接口:

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

直接已知子类:

NioDatagramChannel, NioSctpChannel, NioSctpServerChannel, NioServerSocketChannel, NioUdtAcceptorChannel, NioUdtMessageConnectorChannel

public abstract class AbstractNioMessageChannel
extends AbstractNioChannel

AbstractNioChannel base class for Channels that operate on messages.

嵌套类概要

从类继承的嵌套类/接口 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	AbstractNioMessageChannel(Channel parent, java.nio.channels.SelectableChannel ch, int readInterestOp)

方法概要

方法

限定符和类型	方法和说明
protected boolean	closeOnReadError(java.lang.Throwable cause)
protected boolean	continueOnWriteError() Returns true if we should continue the write loop on a write error.
protected abstract int	doReadMessages(java.util.List<java.lang.Object> buf) Read messages into the given array and return the amount which was read.
protected void	doWrite(ChannelOutboundBuffer in) Flush the content of the given buffer to the remote peer.
protected abstract boolean	doWriteMessage(java.lang.Object msg, ChannelOutboundBuffer in) Write a message to the underlying Channel.
protected AbstractNioChannel.AbstractNioUnsafe	newUnsafe() Create a new AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel

从类继承的方法 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, filterOutboundMessage, 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

构造器详细资料

AbstractNioMessageChannel

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

另请参阅:

AbstractNioChannel.AbstractNioChannel(Channel, SelectableChannel, int)

方法详细资料

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

continueOnWriteError

protected boolean continueOnWriteError()

Returns true if we should continue the write loop on a write error.

closeOnReadError

protected boolean closeOnReadError(java.lang.Throwable cause)

doReadMessages

protected abstract int doReadMessages(java.util.List<java.lang.Object> buf)
                               throws java.lang.Exception

Read messages into the given array and return the amount which was read.

抛出:

java.lang.Exception

doWriteMessage

protected abstract boolean doWriteMessage(java.lang.Object msg,
                     ChannelOutboundBuffer in)
                                   throws java.lang.Exception

Write a message to the underlying Channel.

返回:

true if and only if the message has been written

抛出:

java.lang.Exception