Netty

如果你不相信努力和时光,那么成果就会是第一个选择辜负你的。不要去否定你自己的过去,也不要用你的过去牵扯你现在的努力和对未来的展望。不是因为拥有希望你才去努力,而是去努力了,你才有可能看到希望的光芒。Netty,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com,来源:原文

Netty

背景知识

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

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

Byte Stream Oriented vs Message Oriented

  1. Socket API
Socket()
Bind()
Listen()
Accept()
Read()
Write()
Close()

Socket of C/S

  1. 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
  1. Reactor 模式
    Reactor模式### 手写Reactor模式的挑战
  2. 处理op_write事件:写忙时需要注册op_write,不忙时注销op_write
  3. 处理ByteBuffer: byteBuffer API非常难用
  4. 处理粘包:需要处理接收到的字节状态
  5. 处理多个Selector
  6. 提供优雅的业务编程模型
    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

  1. Netty核心组件
Channel - SocketChannel
EventLoop - Selector
ChannelPipeline
ChannelHandler
Bootstrap - Main
ByteBuf - ByteBuffer
  • EventLoop
    事件循环

ChannelHandler & Pipeline

ChannelHandler & Pipeline

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

(0)
飞熊的头像飞熊bm

相关推荐

发表回复

登录后才能评论
极客之音——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!