Netty 源码剖析与实战
傅健
Netty 源码贡献者、Cisco 高级软件工程师
32935 人已学习
新⼈⾸单¥59
课程目录
已完结/共 60 讲
第一章:初识Netty:背景、现状与趋势 (7讲)
第三章:Netty源码:从“线”(请求处理)的角度剖析 (8讲)
第六章:成长为Netty的贡献者 (6讲)
Netty 源码剖析与实战
登录|注册
留言
17
收藏
沉浸
阅读
分享
手机端
回顶部
当前播放: 35 | 引入"响应分发"完善客户端
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 | 结课测试&结束语
本节摘要
登录 后留言

全部留言(17)

  • 最新
  • 精选
javaYJL
老师,你好!我在dubug的时候,发现服务端断点还停留在处理新连接接入;客户端addListener(future -> { if (future.isSuccess()) { System.out.println("连接成功!"); } else { System.err.println("连接失败,开始重连"); } });这个时候客户端已经打印出”连接成功了”

作者回复: 这个问题很好,说明你看的很细致还动手实践了。这里涉及到一些细节了: 首先连接(说白了,就是TCP的三次握手)在服务器端写完下面这句话的时候: ServerSocket serverSocket = new ServerSocket(8091);(注意这里没有accept) 就已经可以连接上去了,而不是必须有accept()的执行,那accept是做什么的? 相当于快递的签入。如果你不签入,这个快递还是已经到了(连接已经建立好了),但是你无法对他进行后续处理(最起码,在服务器端你拿不到对应的socket channel来执行调用,更不用谈注册读写事件)。另外一个方面,如果你不accept,那中间的缓存区会满(取决于backlog大小),那很快,就无法建立新的连接了,和快递签入一个道理。你不签入,那快递都堆那个地方,最终还是存不下。 所以总结起来就是,accept准确的说应该说是对连接的后续处理(签入),(但是经常在表述上包括本课程都是直接说处理连接,所以可能会让你误解,以为只有accept调用,连接才能建),至于连接本身(TCP)三次握手并不是accept这个方法做的事情。 你可以写一些简单的例子验证下。很简单,几行代码,抛开netty来看,其实更容易把这些问题搞清楚,如果还有别的疑惑,欢迎继续提问,我应该说清楚这个问题了,哈哈 谢谢!

2020-01-07
7
InfoQ_fbb8f3b4ab40
如果服务端io和处理是同一个线程的话,响应应该是按请求顺序一一对应的,也可以同时发多个请求,不需要做分发吧

作者回复: 不管哪种情况下,客户端都是可以发送多个请求,比如请求A,请求B,然后服务器端处理要保证顺序的话,肯定就像你说的使用同一个线程,那这样会导致,请求A不处理完就不能处理B,明显效率不行,所以为提高效率肯定要多线程,那处理就可能结果不是按请求AB的顺序,所以才要需要一个ID来对应下,实现类似分发的效果。不过,不管怎么说,你说的本身没有问题的,因为你也可以发多个,也可以拿到响应,只是速度不会快。

2020-02-10
1
Peter
老师,在ClientV1版本中我们将new RequestMessage的工作抽出去到Encoder里去实现了,但是在ClientV2版本中为了添加RequestPendingCenter我们又不得不每次都new RequestMessage,这里有没有什么办法将RequestPendingCenter#add的工作也放到Encoder里去?

作者回复: 不适合,因为那是encoder,从encoder里获取结果?另外,你怎么来获取响应结果?所以不适合。

2019-12-11
1
yang
通过 streamId 与 future 维护一个map来异步接收服务端的响应结果 至于 客户端发送message失败,移出这种绑定关系 以及其他的复杂业务逻辑,不在我们的课程范围内。

作者回复: 是的,不然要考虑的情况远不止这些。

2020-03-23
大大大熊myeh
代码一个注释都没有……看着挺费劲的

作者回复: 不好意思,将就下吧,兄弟!有不明白的,可以留言。谢谢!

2020-02-13
shinee_x_X
老师,你这还不是开头说的第一种发送响应模式吗,客户端还是不能异步发送啊,future get的时候还是会阻色啊

作者回复: future本身就代表是异步的,而get是为了获取结果,相当于异步执行但是结果获取是阻塞同步,这两个不矛盾。 改进的核心点在于:第一个请求和第二个请求可以异步并发了,原来的不行,因为如果并发,无法把结果一一对应起来。

2019-12-20
2
13761642169
说点题外话,kafka client 发送请求给 broker,如果 client 没有收到对应的响应,会 pending,新的请求发不出去,但 kafka 吞吐还是很大的

作者回复: 但是如果他的信息传输结构定义成带关键id的,能做到的更好,就像http为什么要搞新版本一样的道理,当然原来的旧版本,现在一直在用,因为能满足需求,不够就加机器。

2019-11-15
2
xxcupid
老师,你的代码稍微有点问题,在4.1.39版本是没问题的,但是其他版本netty可能有哦问题。 你实现的DefaultPromise,它的构造函数为executor赋值为null了。这个在notifyListeners()方法调用的时候会触发NPE。老师你使用的netty是4.1.39,它的setValue0方法会先checkNotifyWaiters()如果返回true,才会notifyListeners,如果是false就不会调用该方法,而case里因为没有为promise添加任何listener,所以不会触发空指针。 如果版本较低,比如4.1.30,它的notifyListeners不是在checkNotifyWaiters为true才调用的,只要CAS设置结果成功就会调用,这就会触发NPE。 而且即使是4.1.39版本,如果用户通过addListener为promise添加了至少一个future之后,也会触发NPE。 所以在这里留言提一下,防止有些同学也踩了这个坑。
2020-04-16
1
9
争分夺秒
老师我想问下,现在用golang语言与java 的netty互通的话,是没有go语言的ProtobufDecoder之类的的实现的是吧?这是不是要手动实现?
2020-08-11
1
1
Grey
很精彩,谢谢老师
2022-09-26
收起评论