ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

原来RocketMQ中间件可以这么玩!面试资料分享

2021-07-06 07:03:58  阅读:150  来源: 互联网

标签:20210706 Netty 中间件 面试 线程 https images com RocketMQ


# 流程描述 我们从bind函数开始: 1、首先创建了两个NioEventLoopGroup,这是初始化了两个线程组,这两个线程组根据命名可以知道一个是bossGroup,是服务器用来接收客户端的请求的,另一个是workGroup是用来处理NioServerSocketChannel的网络读写的。这两个线程组实际承担的是一个Reactor的角色。 2、第二步就是初始化一个ServerBootstrap,这是Netty用于启动NIO服务端的辅助启动类,目的是降低服务器开发的复杂度。ServerBootstrap的初始化首先是调用group方法,将两个线程组作为参数传到ServerBootstrap中。接着创建channel为NioServerSocketChannel。然后调用option配置channel的TCP参数,其中SO_BACKLOG设置为1024的意思是服务器监听队列的大小是1024,最后设置处理IO事件的处理器ChildChannelHandler,它的作用类似于Rector模式中的handler用来处理IO事件。 3、启动类初始化完成后调用ServerBootstrap的bind方法绑定端口,监听请求,在调用sync等待绑定完成。完成之后返回一个ChannelFuture作用是用于异步操作的通知回调。 4、调用 future.channel().closeFuture().sync进行阻塞,等待服务端链路关闭main函数退出。 5、调用EventLoopGroup的shutdownGracefully方法,释放相关的资源。 ![硬核!十分钟带你看懂Netty如何实现C/S(源码解析)](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524719710937.jpg) # Netty的线程模型 netty是一个高可用的基于事件驱动的异步的NIO框架,核心的线程模型是Reactor,Reactor线程模型有单线程Reactor,多线程Reactor和多线程主从复制的Reactor,这里我们就用最简单的单线程Reactor来分析下Netty的线程模型,进而来看Netty的相关核心类在此模型下扮演的角色和作用。 在网络交互中,无论你是建立连接进行通信还是数据的读写都是继续网络通信协议的,底层就是TCP/IP协议栈,协议栈是操作系统层的,我们无法修改他的协议栈,但是操作系统给了我们可以操作和使用协议栈的接口,比如我们经常使用的bind、accept、connect等,而这写操作的本身,我们都是对socket的操作,所以我们可以任务一个socket,就是用户跟TCP/IP协议栈进行交互的门户。 # 传统的IO ![硬核!十分钟带你看懂Netty如何实现C/S(源码解析)](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524719973097.jpg) 一请求一应答,这是BIO。每次读写都需要生成新的线程,请求多的时候占用大量的线程资源。高并发的情况下很可能造成巨大的线上故障。 # NIO Reactor模型 ![硬核!十分钟带你看懂Netty如何实现C/S(源码解析)](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524719753102.jpg) socket注册到Selector中,由Selector决策哪个事件可以执行。 # Netty的线程模型 服务器的线程模型为例: ![硬核!十分钟带你看懂Netty如何实现C/S(源码解析)](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524719679457.jpg) 抽象出NioEventLoop来表示一个不断循环执行处理任务的线程,每个NioEventLoop有一个selector,用于监听绑定在其上的socket链路。服务端维护了两个EventLoopGroup,一个bossGroup,一个workGroup,bossGroup用来处理客户端的连接请求,然后打开Channel,把这个Channel交给workGroup中的一个EventLoop被注册来处理该Channel上的所有请求。一个Channel只会被一个workGroup处理,一个workGroup可以同时被多个Channel使用。 简单了解了Netty的一个线程模型,我们来看看netty编程中那些核心类的作用。 # Netty架构 ![image.png](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524720467288.jpg) # 核心类分析 # EventLoop EventLoop是Netty中极其重要的组件,翻译为时间循环,一个EventLoop被分配给Channel来负责这个Cahnnel上的所有事件。EventLoop你可以理解为一个线程,EventLoopGroup是一个线程池,EventLoopGroup继承ScheduledExecutorService,也就是调度线程池,理论上EventLoopGroup应该具有ScheduledExecutorService的所有的功能,之所以叫做事件循环,我猜想它必然有一个循环把Cahnnel上面准备就绪的事件提交给一个Thread来处理。这个实现在SingleThreadEventLoop的一个继承类EpollEventLoop中的run方法实现 # 资料分享 这是我从某优质机构弄来的一些资料,内容我认为确实称得上优质二字,**如需领取,请点赞这篇文章,关注我然后[点击这里即可免费领取](https://docs.qq.com/doc/DSmxTbFJ1cmN1R2dB)** **首先分享一份学习大纲,内容较多,涵盖了互联网行业所有的流行以及核心技术,以截图形式分享:** (亿级流量性能调优实战+一线大厂分布式实战+架构师筑基必备技能+设计思想开源框架解读+性能直线提升架构技术+高效存储让项目性能起飞+分布式扩展到微服务架构.........实在是太多了) ![](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524720329935.jpg) **其次分享一些技术知识,以截图形式分享一部分:** Tomcat架构解析: ![](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524720847791.jpg) 算法训练+高分宝典: ![](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524720548940.jpg) Spring Cloud+Docker微服务实战: ![](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524720875940.jpg) **最后分享一波面试资料:** > 切莫死记硬背,小心面试官直接让你出门右拐 1000道互联网Java面试题: ![](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524720909676.jpg) Java高级架构面试知识整理: ![](http://www.icode9.com/i/li/?n=2&i=images/20210706/1625524721773446.jpg)

标签:20210706,Netty,中间件,面试,线程,https,images,com,RocketMQ
来源: https://blog.51cto.com/u_15289173/2985305

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有