AbstractChannel.AbstractUnsafe (Netty API Reference (4.1.22.Final))

java.lang.Object
- io.netty.channel.AbstractChannel.AbstractUnsafe

All Implemented Interfaces:

Channel.Unsafe

已知直接子类：

AbstractNioChannel.AbstractNioUnsafe

Enclosing class:

AbstractChannel
```
protected abstract class AbstractChannel.AbstractUnsafe
extends java.lang.Object
implements Channel.Unsafe
```
Unsafe实现哪些子类必须扩展和使用。

构造方法摘要

构造方法
Modifier	Constructor and Description
`protected`	`AbstractUnsafe()`

方法摘要

所有方法接口方法具体的方法
Modifier and Type	Method and Description
`protected java.lang.Throwable`	`annotateConnectException(java.lang.Throwable cause, java.net.SocketAddress remoteAddress)` 将远程地址附加到由连接尝试失败引起的异常消息。
`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` ，但不会触发任何事件。
`protected void`	`closeIfClosed()`
`void`	`deregister(ChannelPromise promise)` 操作完成后，从`EventLoop`注销`ChannelPromise`的`Channel` ，并通知`ChannelPromise` 。
`void`	`disconnect(ChannelPromise promise)` 断开`ChannelFuture`的`Channel`，并在操作完成后通知`ChannelPromise` 。
`protected boolean`	`ensureOpen(ChannelPromise promise)`
`void`	`flush()` 清除通过 `Channel.Unsafe.write(Object, ChannelPromise)`预定的所有写入操作。
`protected void`	`flush0()`
`java.net.SocketAddress`	`localAddress()` 返回本地绑定的 `SocketAddress`或 `null`如果没有）。
`ChannelOutboundBuffer`	`outboundBuffer()` 返回`Channel`中的`ChannelOutboundBuffer` ，其中存储待处理的写入请求。
`protected java.util.concurrent.Executor`	`prepareToClose()` 准备关闭`Channel` 。
`RecvByteBufAllocator.Handle`	`recvBufAllocHandle()` 返回分配的`RecvByteBufAllocator.Handle` ，用于在接收数据时分配`ByteBuf` 。
`void`	`register(EventLoop eventLoop, ChannelPromise promise)` 注册`ChannelPromise`的`Channel`，并在注册完成后通知`ChannelFuture` 。
`java.net.SocketAddress`	`remoteAddress()` 返回 `SocketAddress`其上结合远程或 `null`如果未尚未绑定。
`protected void`	`safeSetFailure(ChannelPromise promise, java.lang.Throwable cause)` 将指定的 `promise`标记为失败。
`protected void`	`safeSetSuccess(ChannelPromise promise)` 将指定的 `promise`标记为成功。
`void`	`shutdownOutput(ChannelPromise promise)` 关闭相应`Channel`的输出部分。
`ChannelPromise`	`voidPromise()` 返回一个特殊的ChannelPromise，可以重复使用并传递给`Channel.Unsafe`中的操作。
`void`	`write(java.lang.Object msg, ChannelPromise promise)` 计划写入操作。

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.Channel.Unsafe
connect

- 构造方法详细信息
  - AbstractUnsafe
```
protected AbstractUnsafe()
```
- 方法详细信息
  - recvBufAllocHandle
```
public RecvByteBufAllocator.Handle recvBufAllocHandle()
```
    从接口Channel.Unsafe复制的描述
    
    返回分配的RecvByteBufAllocator.Handle ，用于在接收数据时分配ByteBuf 。
    
    Specified by:
    
    recvBufAllocHandle接口 Channel.Unsafe
  - outboundBuffer
```
public final ChannelOutboundBuffer outboundBuffer()
```
    从接口Channel.Unsafe复制的描述
    
    返回Channel的ChannelOutboundBuffer ，其中存储待处理的写入请求。
    
    Specified by:
    
    outboundBuffer接口 Channel.Unsafe
  - localAddress
```
public final java.net.SocketAddress localAddress()
```
    从接口Channel.Unsafe复制的描述
    
    返回本地绑定的 SocketAddress或 null如果没有）。
    
    Specified by:
    
    localAddress接口 Channel.Unsafe
  - remoteAddress
```
public final java.net.SocketAddress remoteAddress()
```
    从接口Channel.Unsafe复制的描述
    
    返回 SocketAddress其上结合远程或 null如果未尚未绑定。
    
    Specified by:
    
    remoteAddress接口 Channel.Unsafe
  - register
```
public final void register(EventLoop eventLoop,
                           ChannelPromise promise)
```
    从接口Channel.Unsafe复制的描述
    
    注册ChannelPromise的Channel，并在注册完成后通知ChannelFuture 。
    
    Specified by:
    
    register接口 Channel.Unsafe
  - bind
```
public final void bind(java.net.SocketAddress localAddress,
                       ChannelPromise promise)
```
    从接口Channel.Unsafe复制的描述
    
    绑定SocketAddress到Channel的的ChannelPromise并通知其一旦其完成。
    
    Specified by:
    
    bind接口 Channel.Unsafe
  - disconnect
```
public final void disconnect(ChannelPromise promise)
```
    从接口Channel.Unsafe复制的描述
    
    断开ChannelFuture的Channel，并在操作完成后通知ChannelPromise 。
    
    Specified by:
    
    disconnect接口 Channel.Unsafe
  - close
```
public final void close(ChannelPromise promise)
```
    从接口Channel.Unsafe复制的描述
    
    关闭ChannelPromise的Channel，并在操作完成后通知ChannelPromise 。
    
    Specified by:
    
    close接口 Channel.Unsafe
  - shutdownOutput
```
@UnstableApi
public final void shutdownOutput(ChannelPromise promise)
```
    关闭相应Channel的输出部分。例如，这将清理ChannelOutboundBuffer ，不允许再写入。
  - closeForcibly
```
public final void closeForcibly()
```
    从接口Channel.Unsafe复制的描述
    
    立即关闭Channel ，但不会触发任何事件。可能仅在注册尝试失败时才有用。
    
    Specified by:
    
    closeForcibly接口 Channel.Unsafe
  - deregister
```
public final void deregister(ChannelPromise promise)
```
    从接口Channel.Unsafe复制的描述
    
    ChannelPromise的ChannelPromise从EventLoop注销Channel ，并在操作完成后通知ChannelPromise 。
    
    Specified by:
    
    deregister接口 Channel.Unsafe
  - beginRead
```
public final void beginRead()
```
    从接口Channel.Unsafe复制的描述
    
    附表填充第一的入缓冲区的读取操作ChannelInboundHandler在ChannelPipeline 。如果已经有待处理的读取操作，则此方法不执行任何操作。
    
    Specified by:
    
    beginRead接口 Channel.Unsafe
  - write
```
public final void write(java.lang.Object msg,
                        ChannelPromise promise)
```
    从接口Channel.Unsafe复制的描述
    
    计划写入操作。
    
    Specified by:
    
    write接口 Channel.Unsafe
  - flush
```
public final void flush()
```
    从接口Channel.Unsafe复制的描述
    
    冲出通过 Channel.Unsafe.write(Object, ChannelPromise)计划的所有写入操作。
    
    Specified by:
    
    flush ，界面 Channel.Unsafe
  - flush0
```
protected void flush0()
```
  - voidPromise
```
public final ChannelPromise voidPromise()
```
    从接口Channel.Unsafe复制的描述
    
    返回一个特殊的ChannelPromise，可以重复使用并传递给Channel.Unsafe中的操作。它永远不会被通知成功或错误，所以只是一个以ChannelPromise为参数但不想通知的操作的占位符。
    
    Specified by:
    
    voidPromise接口 Channel.Unsafe
  - ensureOpen
```
protected final boolean ensureOpen(ChannelPromise promise)
```
  - safeSetSuccess
```
protected final void safeSetSuccess(ChannelPromise promise)
```
    将指定的promise标记为成功。如果promise已经完成，请记录一条消息。
  - safeSetFailure
```
protected final void safeSetFailure(ChannelPromise promise,
                                    java.lang.Throwable cause)
```
    将指定的promise标记为失败。如果promise已经完成，请记录一条消息。
  - closeIfClosed
```
protected final void closeIfClosed()
```
  - annotateConnectException
```
protected final java.lang.Throwable annotateConnectException(java.lang.Throwable cause,
                                                             java.net.SocketAddress remoteAddress)
```
    将远程地址附加到由连接尝试失败引起的异常消息。
  - prepareToClose
```
protected java.util.concurrent.Executor prepareToClose()
```
    准备关闭Channel 。如果这个方法返回一个Executor ，调用者必须调用Executor.execute(Runnable)方法与调用任务AbstractChannel.doClose()对返回Executor 。如果此方法返回null ，则必须从调用者线程调用AbstractChannel.doClose() 。（即EventLoop ）

Class AbstractChannel.AbstractUnsafe

构造方法摘要

方法摘要

Methods inherited from class java.lang.Object

Methods inherited from interface io.netty.channel.Channel.Unsafe

构造方法详细信息

AbstractUnsafe

方法详细信息

recvBufAllocHandle

outboundBuffer

localAddress

remoteAddress

register

bind

disconnect

close

shutdownOutput

closeForcibly

deregister

beginRead

write

flush

flush0

voidPromise

ensureOpen

safeSetSuccess

safeSetFailure

closeIfClosed

annotateConnectException

prepareToClose