@UnstableApi public final class KQueueServerSocketChannel extends AbstractKQueueServerChannel implements ServerSocketChannel
AbstractChannel.AbstractUnsafeChannel.Unsafe| Modifier and Type | Field and Description |
|---|---|
protected boolean |
active |
| Constructor and Description |
|---|
KQueueServerSocketChannel() |
KQueueServerSocketChannel(int fd) |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
checkResolvable(java.net.InetSocketAddress addr) |
KQueueServerSocketChannelConfig |
config()
返回此频道的配置。
|
protected void |
doBeginRead()
安排读取操作。
|
protected void |
doBind(java.net.SocketAddress localAddress)
将 Channel绑定到SocketAddress
|
protected void |
doClose()
关闭 Channel
|
protected void |
doDeregister()
|
protected void |
doDisconnect()
将此 Channel从其远程对等方断开
|
protected int |
doReadBytes(ByteBuf byteBuf)
将字节读入给定的 ByteBuf并返回金额。
|
protected void |
doRegister()
|
protected int |
doWriteBytes(ChannelOutboundBuffer in, ByteBuf buf) |
FileDescriptor |
fd()
返回此 Channel使用的FileDescriptor 。
|
boolean |
isActive()
如果 Channel处于活动状态并已连接,则返回true 。
|
protected boolean |
isCompatible(EventLoop loop)
如果给定的 EventLoop与此实例兼容,则返回true 。
|
boolean |
isOpen()
如果 Channel已打开并且稍后可能会激活,则返回true
|
java.net.InetSocketAddress |
localAddress()
返回此通道绑定的本地地址。
|
protected java.net.SocketAddress |
localAddress0()
返回本地绑定的
SocketAddress 。
|
protected Channel |
newChildChannel(int fd, byte[] address, int offset, int len) |
protected ByteBuf |
newDirectBuffer(ByteBuf buf)
返回指定的 ByteBuf的堆外副本,并释放原始副本。
|
protected ByteBuf |
newDirectBuffer(java.lang.Object holder, ByteBuf buf)
返回指定的 ByteBuf的堆外副本,并释放指定的持有者。
|
java.net.InetSocketAddress |
remoteAddress()
返回此通道连接到的远程地址。
|
doConnect, doWrite, filterOutboundMessage, metadata, newUnsafe, remoteAddress0alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushattr, hasAttrclone, finalize, getClass, notify, notifyAll, wait, wait, waitalloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, metadata, parent, pipeline, read, unsafeattr, hasAttrbind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlushpublic KQueueServerSocketChannel()
public KQueueServerSocketChannel(int fd)
protected boolean isCompatible(EventLoop loop)
AbstractChannel
EventLoop与此实例兼容,则返回true 。
protected void doBind(java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractChannel
Channel绑定到SocketAddress
java.lang.Exception
public java.net.InetSocketAddress remoteAddress()
Channel
SocketAddress应该被放入更具体的类型,例如InetSocketAddress以检索详细信息。
remoteAddress在界面
Channel
remoteAddress ,界面
ServerSocketChannel
remoteAddress在课堂上
AbstractChannel
null如果此通道未连接。
如果此通道未连接,但可以接收来自任意远程地址的消息(例如DatagramChannel ,请使用DefaultAddressedEnvelope.recipient()来确定接收消息的来源,因为此方法将返回null 。
public java.net.InetSocketAddress localAddress()
Channel
SocketAddress应该被转换为更具体的类型,例如InetSocketAddress以检索详细信息。
localAddress在界面
Channel
localAddress ,界面
ServerSocketChannel
localAddress在类
AbstractChannel
null如果此通道未绑定。
public KQueueServerSocketChannelConfig config()
Channel
config在界面
Channel
config在界面
ServerSocketChannel
protected Channel newChildChannel(int fd, byte[] address, int offset, int len) throws java.lang.Exception
java.lang.Exception
public final FileDescriptor fd()
UnixChannel
Channel使用的FileDescriptor 。
fd ,界面
UnixChannel
protected void doClose()
throws java.lang.Exception
AbstractChannel
Channel
doClose在课堂上
AbstractChannel
java.lang.Exception
protected void doDisconnect()
throws java.lang.Exception
AbstractChannel
Channel从它的远程对等端
doDisconnect在课堂
AbstractChannel
java.lang.Exception
protected void doDeregister()
throws java.lang.Exception
AbstractChannel
doDeregister在课堂
AbstractChannel
java.lang.Exception
protected final void doBeginRead()
throws java.lang.Exception
AbstractChannel
doBeginRead在课堂上
AbstractChannel
java.lang.Exception
protected void doRegister()
throws java.lang.Exception
AbstractChannel
doRegister在课堂
AbstractChannel
java.lang.Exception
protected static void checkResolvable(java.net.InetSocketAddress addr)
protected final int doReadBytes(ByteBuf byteBuf) throws java.lang.Exception
ByteBuf并返回该金额。
java.lang.Exception
protected final int doWriteBytes(ChannelOutboundBuffer in, ByteBuf buf) throws java.lang.Exception
java.lang.Exception
protected java.net.SocketAddress localAddress0()
AbstractChannel
SocketAddress 。
localAddress0在课堂
AbstractChannel
Copyright © 2008–2018 The Netty Project. All rights reserved.