io.netty.channel.oio

类 AbstractOioByteChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.channel.oio.AbstractOioChannel

io.netty.channel.oio.AbstractOioByteChannel

所有已实现的接口:

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

直接已知子类:

OioByteStreamChannel

public abstract class AbstractOioByteChannel
extends AbstractOioChannel

Abstract base class for OIO which reads and writes bytes from/to a Socket

嵌套类概要

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

AbstractChannel.AbstractUnsafe

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

Channel.Unsafe

字段概要

从类继承的字段 io.netty.channel.oio.AbstractOioChannel

SO_TIMEOUT

构造器概要

构造器

限定符	构造器和说明
protected	AbstractOioByteChannel(Channel parent)

方法概要

方法

限定符和类型	方法和说明
protected abstract int	available() Return the number of bytes ready to read from the underlying Socket.
protected boolean	checkInputShutdown() Check if the input was shutdown and if so return true.
protected void	doRead()
protected abstract int	doReadBytes(ByteBuf buf) Read bytes from the underlying Socket.
protected void	doWrite(ChannelOutboundBuffer in) Flush the content of the given buffer to the remote peer.
protected abstract void	doWriteBytes(ByteBuf buf) Write the data which is hold by the ByteBuf to the underlying Socket.
protected abstract void	doWriteFileRegion(FileRegion region) Write the data which is hold by the FileRegion to the underlying Socket.
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 boolean	isInputShutdown()
ChannelMetadata	metadata() Return the ChannelMetadata of the Channel which describe the nature of the Channel.

从类继承的方法 io.netty.channel.oio.AbstractOioChannel

doBeginRead, doConnect, isCompatible, isReadPending, newUnsafe, setReadPending

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

alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doClose, doDeregister, doDisconnect, doRegister, doShutdownOutput, equals, eventLoop, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, remoteAddress0, toString, unsafe, 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, isOpen

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

attr

构造器详细资料

AbstractOioByteChannel

protected AbstractOioByteChannel(Channel parent)

另请参阅:

AbstractOioByteChannel(Channel)

方法详细资料

isInputShutdown

protected boolean isInputShutdown()

metadata

public ChannelMetadata metadata()

从接口复制的说明: Channel

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

checkInputShutdown

protected boolean checkInputShutdown()

Check if the input was shutdown and if so return true. The default implementation sleeps also for AbstractOioChannel.SO_TIMEOUT milliseconds to simulate some blocking.

doRead

protected void doRead()

指定者:

doRead 在类中 AbstractOioChannel

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)
                                                throws java.lang.Exception

从类复制的说明: 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

抛出:

java.lang.Exception

available

protected abstract int available()

Return the number of bytes ready to read from the underlying Socket.

doReadBytes

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

Read bytes from the underlying Socket.

参数:

buf - the ByteBuf into which the read bytes will be written

返回:

amount the number of bytes read. This may return a negative amount if the underlying Socket was closed

抛出:

java.lang.Exception - is thrown if an error occurred

doWriteBytes

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

Write the data which is hold by the ByteBuf to the underlying Socket.

参数:

buf - the ByteBuf which holds the data to transfer

抛出:

java.lang.Exception - is thrown if an error occurred

doWriteFileRegion

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

Write the data which is hold by the FileRegion to the underlying Socket.

参数:

region - the FileRegion which holds the data to transfer

抛出:

java.lang.Exception - is thrown if an error occurred