首页
学习
活动
专区
工具
TVP
发布

后端技术

专栏成员
269
文章
276854
阅读量
31
订阅数
kafka 网络模型2 Selector
在上一篇文章中,我分析了Kafka的请求、响应流程,但留下了Selector的疑点。本文会分析Selector和它的poll()是如何进行网络IO的,NetworkReceive是如何被完整读取的,Send是如何被完整写出的,还会涉及到KafkaChannel和它的mute机制。
平凡的学生族
2020-06-09
9160
kafka 网络模型1 请求响应流程
在kafka 启动1 入口函数中,我们阅读了KafkaServer的注释,这里直接总结一下:
平凡的学生族
2020-06-02
1.2K0
对后端开发的理解
参考: https://www.zhihu.com/question/23084473
平凡的学生族
2019-12-20
6640
java nio 源码分析2 IO
getTemporaryDirectBuffer和SocketChannelImpl值得分析
平凡的学生族
2019-12-20
7560
java nio总结 行为分析
由上图2可知, java Charset一般用于创建编码/解码对象, 对输入输出流进行编解码.
平凡的学生族
2019-12-20
5610
netty 线程模型(未完成)
虽然Netty的线程模型基于主从Reactor多线程,借用了MainReactor和SubReactor的结构。但是实际实现上SubReactor和Worker线程在同一个线程池中
平凡的学生族
2019-05-25
5200
java nio 在windows的实现
参考java nio 在windows上的实现 很多人说是IOCP,其实是select。 首先我们一步步查看调用链: Selector.select->...->WindowsSelectorImpl.doSelect->WindowsSelectorImpl.SubSelector.poll->WindowsSelectorImpl.SubSelector.poll0 我们看下WindowsSelectorImpl.SubSelector.poll:
平凡的学生族
2019-05-25
1.6K0
总结io (nio、InputStream等)
蓝色线和红色线的含义都是 "相当于",比如,在InputStream中,抽象构件指的是InputStream类,而装饰角色指的是FileInputStream角色
平凡的学生族
2019-05-25
7340
java nio 使用入门
while循环中,多次channel.read(buffer)、flip并write后,如果不调用clear会使read返回0 跟踪read方法到IOUtils的readIntoNativeBuffer方法,看到当limit - postion为0时,方法直接返回0。
平凡的学生族
2019-05-25
3770
java nio 聊天室
https://github.com/KimRasak/java-nio-chat-room/
平凡的学生族
2019-05-25
1K0
netty源码解析 注册NioServerSocketChannel
最终在AbstractNioChannel.doRegister里的selectionKey = javaChannel().register(eventLoop().unwrappedSelector(), 0, this);确定把java nio的channel注册到关联的eventLoop所持有的selector上。
平凡的学生族
2019-05-25
4670
java的nio是水平触发吗
java的nio是水平触发吗?在linux上,其实现是基于linux epoll的。所以首先我们要了解epoll。
平凡的学生族
2019-05-25
8500
java nio 深入探究
NIO.2应该就是AIO?反正是基于IOCP。 它是怎么用的?为什么效率高?其上的框架有什么?
平凡的学生族
2019-05-25
3880
没有更多了
社区活动
【纪录片】中国数据库前世今生
穿越半个世纪,探寻中国数据库50年的发展历程
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档