当需要关闭channel的时候会调用close
方法进行关闭操作,该方法在抽象类AbstractUnsafe中实现,源码过程如下:
接下来着重分析prepareToClose
、doClose0
、fireChannelInactiveAndDeregister
这三个方法。
prepareToClose()
在关闭前先判断是异步关闭还是同步关闭,由channel当前的状态和SO_LINGER
设置共同决定,如果设置了SO_LINGER
则会在channel进行close
后阻塞SO_LINGER
设置的时间,在此之间系统会尽量将未发送成功的数据发送出去。而netty中则先调用doDeregister
方法将eventloop中对应的selectionKey取消掉,防止继续执行操作。
doClose0()
doClose0()
在boss线程的channel中则直接关闭,在worker线程中先取消connect操作,如果有的话。
fireChannelInactiveAndDeregister()
deregister后向pipeline中触发相应的事件。
至此,Unsafe的close方法分析到此结束。
版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: