146 lines
5.0 KiB
Markdown
146 lines
5.0 KiB
Markdown
# 精尽 Netty 源码解析 —— Channel（八）之 disconnect 操作
|
||
|
||
# 1. 概述
|
||
|
||
本文分享 Netty NIO Channel **客户端**断开连接( **disconnect** )操作的过程。
|
||
|
||
在看 Netty NIO Channel 对 `#disconnect(ChannelPromise promise)` 方法的实现代码之前，我们先来看看 Java **原生** NIO SocketChannel 的 `#disconnect()` 方法。
|
||
|
||
- 结果，结果，结果，翻了半天，只看到 NIO SocketChannel 的父类 AbstractInterruptibleChannel 中，有 `#close()` 方法，而找不到 `#disconnect()` 方法。这个是啥情况？
|
||
- 我们又去翻了 Java **原生** UDP DatagramSocket 类，结果找到了 `#connect()` 方法。这个又是啥情况？
|
||
|
||
不卖关子了，直接说结论啦：
|
||
|
||
- Java **原生** NIO SocketChannel **不存在**，当调用 Netty `NioSocketChannel#disconnect(ChannelPromise promise)` 时，会自动转换成 **close** 操作，即 [《精尽 Netty 源码解析 —— Channel（七）之 close 操作》](http://svip.iocoder.cn/Netty/Channel-7-close/) 。
|
||
- 实际上， `Channel#disconnect(ChannelPromise promise)` 方法，是 Netty 为 UDP 设计的。
|
||
|
||
# 2. NioSocketChannel
|
||
|
||
通过 `NioSocketChannel#disconnect()` 方法，应用程序里可以主动关闭 NioSocketChannel 通道。代码如下：
|
||
|
||
```
|
||
@Override
|
||
public ChannelFuture disconnect() {
|
||
return pipeline.disconnect();
|
||
}
|
||
```
|
||
|
||
- NioSocketChannel 继承 AbstractChannel 抽象类，所以 `#disconnect()` 方法实际是 AbstractChannel 实现的。
|
||
- 在方法内部，会调用对应的 `ChannelPipeline#disconnect()` 方法，将 disconnect 事件在 pipeline 上传播。
|
||
|
||
# 3. DefaultChannelPipeline
|
||
|
||
`DefaultChannelPipeline#disconnect()` 方法，代码如下：
|
||
|
||
```
|
||
@Override
|
||
public final ChannelPipeline disconnect() {
|
||
tail.disconnect();
|
||
return this;
|
||
}
|
||
```
|
||
|
||
- 在方法内部，会调用 `TailContext#disconnect()` 方法，将 flush 事件在 pipeline 中，从尾节点向头节点传播。详细解析，见 [「4. TailContext」](https://svip.iocoder.cn/Netty/Channel-8-disconnect/#) 。
|
||
|
||
# 4. TailContext
|
||
|
||
TailContext 对 `#flush()` 方法的实现，是从 AbstractChannelHandlerContext 抽象类继承，代码如下：
|
||
|
||
```
|
||
@Override
|
||
public ChannelFuture disconnect() {
|
||
return disconnect(newPromise());
|
||
}
|
||
|
||
@Override
|
||
public ChannelFuture disconnect(final ChannelPromise promise) {
|
||
// 判断是否为合法的 Promise 对象
|
||
if (isNotValidPromise(promise, false)) {
|
||
// cancelled
|
||
return promise;
|
||
}
|
||
|
||
final AbstractChannelHandlerContext next = findContextOutbound();
|
||
EventExecutor executor = next.executor();
|
||
if (executor.inEventLoop()) {
|
||
// <1> 如果没有 disconnect 操作，则执行 close 事件在 pipeline 上
|
||
// Translate disconnect to close if the channel has no notion of disconnect-reconnect.
|
||
// So far, UDP/IP is the only transport that has such behavior.
|
||
if (!channel().metadata().hasDisconnect()) {
|
||
next.invokeClose(promise);
|
||
// 如果有 disconnect 操作，则执行 disconnect 事件在 pipeline 上
|
||
} else {
|
||
next.invokeDisconnect(promise);
|
||
}
|
||
} else {
|
||
safeExecute(executor, new Runnable() {
|
||
@Override
|
||
public void run() {
|
||
// <1> 如果没有 disconnect 操作，则执行 close 事件在 pipeline 上
|
||
if (!channel().metadata().hasDisconnect()) {
|
||
next.invokeClose(promise);
|
||
// 如果有 disconnect 操作，则执行 disconnect 事件在 pipeline 上
|
||
} else {
|
||
next.invokeDisconnect(promise);
|
||
}
|
||
}
|
||
}, promise, null);
|
||
}
|
||
return promise;
|
||
}
|
||
```
|
||
|
||
- 在
|
||
|
||
|
||
|
||
```
|
||
<1>
|
||
```
|
||
|
||
|
||
|
||
处，调用
|
||
|
||
|
||
|
||
```
|
||
ChannelMetadata#hasDisconnect()
|
||
```
|
||
|
||
|
||
|
||
方法，判断 Channel
|
||
|
||
|
||
|
||
是否支持
|
||
|
||
|
||
|
||
disconnect 操作。
|
||
|
||
- 如果支持，则**转换**执行 close 事件在 pipeline 上。后续的逻辑，就是 [《精尽 Netty 源码解析 —— Channel（七）之 close 操作》](http://svip.iocoder.cn/Netty/Channel-7-close/) 。
|
||
- 如果不支持，则**保持**执行 disconnect 事件在 pipeline 上。
|
||
|
||
- 支持 disconnect 操作的 Netty Channel 实现类有：
|
||
|
||
|
||
|
||
支持
|
||
|
||
- 和文头，我们提到的，只有 Java **原生** UDP DatagramSocket 支持是一致的。从 `So far, UDP/IP is the only transport that has such behavior.` 的英文注释，也能证实这一点。
|
||
|
||
- 不支持 disconnect 操作的 Netty Channel 实现类有：
|
||
|
||
|
||
|
||
不支持
|
||
|
||
- 和文头，我们提到的，只有 Java **原生** NIO SocketChannel 不支持是一致的。
|
||
|
||
因为本系列，暂时不分享 UDP 相关的内容，所以对“执行 disconnect 事件在 pipeline 上”就不解析了。
|
||
|
||
# 666. 彩蛋
|
||
|
||
水更一篇，本来以为 Netty NIO Channel 的 disconnect 操作是个**骚**操作。 |