public abstract class AbstractOioMessageChannel extends AbstractOioChannel
AbstractChannel.AbstractUnsafe
Channel.Unsafe
SO_TIMEOUT
Modifier | Constructor and Description |
---|---|
protected |
AbstractOioMessageChannel(Channel parent) |
Modifier and Type | Method and Description |
---|---|
protected void |
doRead() |
protected abstract int |
doReadMessages(java.util.List<java.lang.Object> msgs)
将消息读入给定数组并返回读取的数量。
|
clearReadPending, doBeginRead, doConnect, isCompatible, isReadPending, newUnsafe, setReadPending
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doClose, doDeregister, doDisconnect, doRegister, doShutdownOutput, doWrite, equals, eventLoop, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, remoteAddress0, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr, hasAttr
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
attr, hasAttr
protected AbstractOioMessageChannel(Channel parent)
protected void doRead()
doRead
在课堂上
AbstractOioChannel
protected abstract int doReadMessages(java.util.List<java.lang.Object> msgs) throws java.lang.Exception
java.lang.Exception
Copyright © 2008–2018 The Netty Project. All rights reserved.