Netty
背景知识
- 网络编程基础
- TCP协议
TCP是一种面向连接的、可靠的、基于字节流的传输层通信协议
详情看TCP/IP面试题
为什么要有“连接”?什么是”连接“
Byte Stream Oriented vs Message Oriented
- Socket API
Socket()
Bind()
Listen()
Accept()
Read()
Write()
Close()
- BIO & NIO
- BIO
ServerSocket
Socket
BIO服务模型: thread per request/thread pre connection
BIO面临的C10K挑战
- NIO
ServerSocketChannel
SocketChannel
Selector
- OP_ACCEPT
- OP_CONNECT
- OP_READ
- OP_WRITE
- Reactor 模式
### 手写Reactor模式的挑战
- 处理op_write事件:写忙时需要注册op_write,不忙时注销op_write
- 处理ByteBuffer: byteBuffer API非常难用
- 处理粘包:需要处理接收到的字节状态
- 处理多个Selector
- 提供优雅的业务编程模型
10.根据环境运行参数
网络编程总结
-
socket API
-
使用多路复用
-
处理协议,粘包问题
-
编程框架
-
Netty
- Netty介绍
Netty is an NIO client server framework that enables quick and easy development
of network appications such as protocol servers and clients
- Netty核心组件
Channel - SocketChannel
EventLoop - Selector
ChannelPipeline
ChannelHandler
Bootstrap - Main
ByteBuf - ByteBuffer
ChannelHandler & Pipeline
- Netty源码讲解及实例
TCP/IP协议
- 拥塞控制
使用拥塞控制来完成相关的数据流服务
Socket API
Socket()
Bind()
Listen()
Accept()
Read()
Write()
Close()
sync queue
accept queue
BIO & NIO
BIO
ServerSocket
Socket
BIO的Java实现代码
1111
NIO (EventLoop)
ServerSocketChannel
SocketChannel
NIO的Java实现代码
2222
一个人可以负责多个连接
监听一万个连接里面任意状态变化
如果监听到某个Socket有连接,就派发给后面干活的线程
serverChannel.register(selector, SelectionKey.OP_ACCEPT);
Selecter API
channel.register(selector) 注册监听
while(true) + select() 轮询事件
selectedKeys() 获得SelectionKey对象,表示channel的注册信息
SelectionKey.attach()对SelectKey关联任何对象
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/202471.html