public abstract class AbstractOioMessageChannel extends AbstractOioChannel
AbstractChannel.AbstractUnsafeChannel.UnsafeSO_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, setReadPendingalloc, 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, writeAndFlushattr, hasAttrclone, finalize, getClass, notify, notifyAll, wait, wait, waitattr, hasAttrprotected 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.