Netty

背景知识

• 网络编程基础

1. TCP协议
   TCP是一种面向连接的、可靠的、基于字节流的传输层通信协议
   详情看TCP/IP面试题

为什么要有“连接”？什么是”连接“

Byte Stream Oriented vs Message Oriented

2. Socket API

Socket()
Bind()
Listen()
Accept()
Read()
Write()
Close()

3. 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

4. Reactor 模式
   ### 手写Reactor模式的挑战
5. 处理op_write事件：写忙时需要注册op_write，不忙时注销op_write
6. 处理ByteBuffer: byteBuffer API非常难用
7. 处理粘包：需要处理接收到的字节状态
8. 处理多个Selector
9. 提供优雅的业务编程模型
   10.根据环境运行参数

网络编程总结

• socket API

• 使用多路复用

• 处理协议，粘包问题

• 编程框架

• Netty

1. Netty介绍

Netty is an NIO client server framework that enables quick and easy development
of network appications such as protocol servers and clients

2. Netty核心组件

Channel - SocketChannel
EventLoop - Selector
ChannelPipeline
ChannelHandler
Bootstrap - Main
ByteBuf - ByteBuffer

• EventLoop
  

ChannelHandler & Pipeline

3. 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关联任何对象