Netty 源码剖析与实战
傅健
Netty 源码贡献者、Cisco 高级软件工程师
32935 人已学习
新⼈⾸单¥59
课程目录
已完结/共 60 讲
第一章:初识Netty:背景、现状与趋势 (7讲)
第三章:Netty源码:从“线”(请求处理)的角度剖析 (8讲)
第六章:成长为Netty的贡献者 (6讲)
Netty 源码剖析与实战
登录|注册
留言
7
收藏
沉浸
阅读
分享
手机端
回顶部
当前播放: 27 | 源码剖析:断开连接
00:00 / 00:00
高清
  • 高清
1.0x
  • 2.0x
  • 1.5x
  • 1.25x
  • 1.0x
  • 0.75x
  • 0.5x
网页全屏
全屏
00:00
付费课程,可试看
01 | 课程介绍
02 | 内容综述
03 | 揭开Netty面纱
04 | 为什么舍近求远:不直接用JDK NIO?
05 | 为什么孤注一掷:独选Netty?
06 | Netty的前尘往事
07 | Netty的现状与趋势
08 | Netty怎么切换三种I/O模式?
09 | 源码剖析:Netty对I/O模式的支持
10 | Netty如何支持三种Reactor?
11 | 源码剖析:Netty对Reactor的支持
12 | TCP粘包/半包Netty全搞定
13 | 源码剖析:Netty对处理粘包/半包的支持
14 | 常用的“二次”编解码方式
15 | 源码剖析:Netty对常用编解码的支持
16 | keepalive与idle监测
17 | 源码剖析:Netty对keepalive与idle监测的支持
18 | Netty的那些“锁”事
19 | Netty如何玩转内存使用
20 | 源码解析:Netty对堆外内存和内存池的支持
21 | Netty代码编译与总览
22 | 源码剖析:启动服务
23 | 源码剖析:构建连接
24 | 源码剖析:接收数据
25 | 源码剖析:业务处理
26 | 源码剖析:发送数据
27 | 源码剖析:断开连接
28 | 源码剖析:关闭服务
29 | 编写网络应用程序的基本步骤
30 | 案例介绍和数据结构设计
31 | 实现服务器端编解码
32 | 实现一个服务器端
33 | 实现客户端编解码
34 | 完成一个客户端雏形
35 | 引入"响应分发"完善客户端
36 | Netty编码中易错点解析
37 | 调优参数:调整System参数夯实基础
38 | 调优参数:权衡Netty核心参数
39 | 调优参数:图解费脑的三个参数
40 | 跟踪诊断:如何让应用易诊断?
41 | 跟踪诊断:应用能可视,心里才有底
42 | 跟踪诊断:让应用内存不“泄露”?
43 | 优化使用:用好自带注解省点心
44 | 优化使用:“整改”线程模型让"响应"健步如飞
45 | 优化使用:增强写,延迟与吞吐量的抉择
46 | 优化使用:如何让应用丝般“平滑”?
47 | 优化使用:为不同平台开启native
48 | 安全增强:设置“高低水位线”等保护好自己
49 | 安全增强:启用空闲监测
50 | 安全增强:简单有效的黑白名单
51 | 安全增强:少不了的自定义授权
52 | 安全增强:拿来即用的SSL-对话呈现表象
53 | 安全增强:拿来即用的SSL-抓包暴露本质
54 | 安全增强:拿来即用的SSL-轻松融入案例
55 | Cassandra如何使用Netty ?
56 | Dubbo如何使用Netty ?
57 | Hadoop如何使用Netty ?
58 | 赏析Netty之美
59 | 如何给Netty贡献代码?
60 | 结课测试&结束语
本节摘要
登录 后留言

全部留言(7)

  • 最新
  • 精选
delete is create
如何获取当前所有连接,或者如何统计当前连接数呢?直接在注册和断开时加一减一不准, 因为客户端断网断电后 这些方法不会被触发

作者回复: 所以你要引入idle检测,发现这些因为断网断电而无效的连接,从而主动断开(channelHandlerContext.close()),这个时候就会触发相应的方法了。如果没有引入,就不仅是统一不准的问题了,还等于说存在资源泄漏了(“僵尸”连接)。

2020-04-10
2
2
武文文武
老师您好,有个问题请教一下,我们用netty做服务端,前端访问服务端是从一个连接池中拿连接,然后访问netty服务端,但是现在生产运维提出让我实现优雅关闭,也就是在服务端升级的时候要让客户端无感知,但是由于连接是基于tcp的长连接,就算用gracefulShutdown也保证不了客户端无感知,您有什么好的建议来实现这种长连接的优雅关闭吗?感谢老师的指教

作者回复: 回复在您第二个提的问题上了。这里不再赘述了。请查看,有问题再沟通,谢谢。

2020-04-21
冬渐暖
关闭之前流程为: 1.多路复用器(Selector) 接收到OP_ READ事件: 2.处理OP_ READ事件: NioSocketChannel.NioSocketChannelUnsafe.read() 调用NioSocketChannelUnsafe,这个类里面有个重载方法prepareToClose(),官方介绍为“We need to cancel this key of the channel so we may not end up in a eventloop spin, because we try to read or write until the actual close happens which may be later due, SO_LINGER handling.” 意思大概就是我先去试下读或者写,看看你是不是骗我的,失败了才是真正的关闭 优雅的关闭动作: unbind netty创建的所有channel。channel.unbind() close netty创建的所有channel。channel.close() shutdown netty的线程执行器。factory.releaseExternalResources() 本质是 1.先关channel (包含cancel多路复用器的key) 2.清理消息:新消息全部不给进,队列里的消息也全部清掉 3.触发fireChannellnactive和fireChannelUnregistered close方法中,客户端发出正常的挥手请求,执行pipeline里面的inactive和unregister方法,即停止运行和取消注册。当然也有做优化--》即关闭连接到一定数量(阀值)的时候,后面的链接可能也相应的关掉了,所以就重新检查下所有的连接有没有关闭,可以减少关闭那些已经被关闭的连接所用的时间 而异常关闭,客户端来不及发出挥手请求,发出的是RST复位请求,服务端在刚才说的unsafe.read方法中doReadBytes(byteBuf)这句直接抛出I/O异常,被捕捉后进入handleReadException方法,在方法中有fireExceptionCaught调用pipeline的exceptionCaught方法,而fireExceptionCaught下面还有之前说的closeOnRead,执行pipeline里面的inactive和unregister方法。 和read write一样,关闭的本质还是调用了jdk的java.nio.channels.spi.AbstractInterruptibleChannel 的close方法,看清了,不是sun.nio.ch.SocketChannelImpl
2020-11-04
3
叶峥瑶
如果第三章讲解这些流程的时候,能顺便带上第二章中讲解的一些特性就更好了,第三章跟第二章太割裂了;请问下老师,netty的bytebuf支持堆外内存和堆内内存,那什么场景需要用堆内/堆外?
2020-08-19
1
delete is create
老师 netty集群搭建 怎么做? 用什么做负载均衡? 用什么管理channel?
2020-07-09
1
1
星期八
如果是kill -9关闭程序还会触发异常关闭得过程吗? 如果不触发,会不会出现客户端过一点时间才会自动断掉呢?
2020-08-11
💢 星星💢
老师,你最后的代码走到 pipeline.fireChannelInactive(),pipeline.fireChannelUnregistered() 这二个事件是干啥的?
2020-01-30
2
收起评论