public static interface Channel.Unsafe
Modifier and Type | Method and Description |
---|---|
void |
beginRead()
附表填充第一的入缓冲区的读取操作 ChannelInboundHandler 在ChannelPipeline 。
|
void |
bind(java.net.SocketAddress localAddress, ChannelPromise promise)
绑定 SocketAddress 到Channel 的的ChannelPromise 并通知其一旦其完成。
|
void |
close(ChannelPromise promise)
关闭 ChannelPromise 的Channel ,并在操作完成后通知ChannelPromise 。
|
void |
closeForcibly()
立即关闭 Channel ,但不会触发任何事件。
|
void |
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
连接 Channel 指定的ChannelFuture 与指定的远程SocketAddress 。
|
void |
deregister(ChannelPromise promise)
操作完成后,从 EventLoop 注销ChannelPromise 的Channel ,并通知ChannelPromise 。
|
void |
disconnect(ChannelPromise promise)
断开 ChannelFuture 的Channel ,并在操作完成后通知ChannelPromise 。
|
void |
flush()
清除所有通过
write(Object, ChannelPromise) 预定的写入操作。
|
java.net.SocketAddress |
localAddress()
返回本地绑定的
SocketAddress 或
null 如果没有。
|
ChannelOutboundBuffer |
outboundBuffer()
返回 Channel 的ChannelOutboundBuffer ,其中存储待处理的写入请求。
|
RecvByteBufAllocator.Handle |
recvBufAllocHandle()
返回分配的 RecvByteBufAllocator.Handle ,用于接收数据时将分配ByteBuf 。
|
void |
register(EventLoop eventLoop, ChannelPromise promise)
注册 ChannelPromise 的Channel ,并在注册完成后通知ChannelFuture 。
|
java.net.SocketAddress |
remoteAddress()
返回绑定的
SocketAddress 远程或
null 如果没有绑定。
|
ChannelPromise |
voidPromise()
返回一个特殊的ChannelPromise,可以重复使用并传递给 Channel.Unsafe 中的操作。
|
void |
write(java.lang.Object msg, ChannelPromise promise)
计划写入操作。
|
RecvByteBufAllocator.Handle recvBufAllocHandle()
RecvByteBufAllocator.Handle
,用于在接收数据时分配ByteBuf
。
java.net.SocketAddress localAddress()
null
如果没有则返回
SocketAddress
。
java.net.SocketAddress remoteAddress()
SocketAddress
其上结合远程或
null
如果未尚未绑定。
void register(EventLoop eventLoop, ChannelPromise promise)
ChannelPromise
的Channel
,并在注册完成后通知ChannelFuture
。
void bind(java.net.SocketAddress localAddress, ChannelPromise promise)
SocketAddress
到Channel
的的ChannelPromise
并通知其一旦其完成。
void connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
Channel
指定的ChannelFuture
与指定的远程SocketAddress
。
如果应该使用特定的本地SocketAddress
则需要将其作为参数给出。
否则,只需将null
传递给它。
一旦连接操作完成, ChannelPromise
将会收到通知。
void disconnect(ChannelPromise promise)
ChannelFuture
的Channel
,并在操作完成后通知ChannelPromise
。
void close(ChannelPromise promise)
ChannelPromise
的Channel
,并在操作完成后通知ChannelPromise
。
void closeForcibly()
Channel
,但不会触发任何事件。
可能仅在注册尝试失败时才有用。
void deregister(ChannelPromise promise)
EventLoop
注销ChannelPromise
的Channel
,并通知ChannelPromise
。
void beginRead()
ChannelInboundHandler
在ChannelPipeline
。
如果已经有待处理的读取操作,则此方法不执行任何操作。
void write(java.lang.Object msg, ChannelPromise promise)
void flush()
write(Object, ChannelPromise)
计划的所有写入操作。
ChannelPromise voidPromise()
Channel.Unsafe
中的操作。
它永远不会被通知成功或错误,所以只是一个以ChannelPromise
作为参数但不想获得通知的操作的占位符。
ChannelOutboundBuffer outboundBuffer()
Channel
中存储未决写入请求的ChannelOutboundBuffer
。
Copyright © 2008–2018 The Netty Project. All rights reserved.