企业官网建设流程全解析

网站后台用什么软件做,电商平台怎么注册,wordpress生存,百度搜索推广的五大优势阅读 Netty 源码关于 NioEventLoop 和 Channel 初始化部分的思考 这里不废话#xff0c;我们直接开始。 1. 线程模型#xff1a;Reactor 线程是怎么启动的#xff1f;一对一还是一对多#xff1f; 怎么启动的#xff1f;#xff08;懒加载#xff09; 你可能会在源码里找…阅读 Netty 源码关于 NioEventLoop 和 Channel 初始化部分的思考这里不废话我们直接开始。1. 线程模型Reactor 线程是怎么启动的一对一还是一对多怎么启动的懒加载你可能会在源码里找new Thread(...).start()但你会发现 Netty 的启动时机非常隐晦。答案Netty 的 EventLoopReactor 线程是**懒加载Lazy Load**的。源码逻辑当你创建NioEventLoopGroup时线程并没有真正启动。只有当第一个任务比如register注册 Channel或者execute提交任务被扔进这个 EventLoop 时它才会检测当前线程状态。如果发现是“未启动”状态它才会调用 JDK 底层的thread.start()把线程拉起来。总结有活儿干的时候才启动没活儿干时只是个空对象。一对一还是一对多答案一个线程管多个连接1:N。但反过来一个连接只属于一个线程1:1。原理解析EventLoop本质上就是一个死循环的线程。为了减少线程上下文切换的开销Netty 采用 IO 多路复用Selector。一个EventLoop持有一个Selector这个Selector可以同时监听成千上万个Channel连接的事件。关键点一旦一个 Channel 被分配给了某个 EventLoop这辈子它所有的 IO 操作读写都只会在这个 EventLoop 的线程里执行。好处这完全消除了该 Channel 内部的线程安全问题根本不需要加锁无锁化设计。2. 异步机制为什么全是 Future/Promise怎么实现“不用等”为什么代码里全是 Future 和 Promise答案这是 Netty 实现异步编程的基石。区别Promise承诺是给干活的人Netty 内部线程用的。干活的人拿到 Promise任务做完了填个“成功”出错了填个“异常”。它是可写的。Future未来是给发号施令的人用户/主线程用的。你拿到的是 Future你只能看状态IsDone?、拿结果Get或者注册回调。它是只读的。注Netty 里 Promise 继承自 Future。怎么实现“不用等结果回来继续往下执行”场景模拟你调用channel.write(Hello)。Netty 立刻返回给你一个ChannelFuture对象。注意这时候数据可能还在内存里根本没发出去。你的代码拿到了这个 Future没有任何阻塞继续往下跑去处理别的业务了。后台发生的事Netty 的 IO 线程在稍后的某个时间点把 “Hello” 真正写到了网络里。通知写完后IO 线程把对应的Promise设置为Success。如果你之前在 Future 上注册了监听器addListener监听器的代码就会被触发执行。生活类比你去奶茶店点单调用方法店员给你一张小票Future你拿着小票去旁边玩手机继续往下执行。等奶茶做好了后台任务完成店员广播叫号触发 Listener你去取奶茶。3. 任务队列为什么既要处理 IO 事件又要处理普通任务为什么混在一起做你在源码的run()方法里会看到一个for (;;)循环里面大概是这样select()看看网络有没有动静。processSelectedKeys()处理网络 IO读写数据。runAllTasks()处理队列里的普通任务。答案为了保证线程封闭Thread Confinement。核心原因我们前面说过一个 Channel 的所有操作必须在同一个线程里。场景假设你现在的业务线程比如 Tomcat 的线程想给某个 Channel 写数据。你不能直接在业务线程里操作 Channel 的 Socket因为那样不安全。解决你会调用channel.write()。Netty 发现调用者不是该 Channel 绑定的 EventLoop 线程它就会把这个“写操作”封装成一个Task扔到 EventLoop 的任务队列里。执行EventLoop 转完一圈做完 IO 后顺手就把队列里的“写操作”拿出来执行了。总结为了让所有对 Channel 的修改都在同一个线程内完成避免加锁。外部线程想干涉必须排队入队由 EventLoop 自己来执行。总结启动Netty 很懒你把任务扔进去它才启动线程。分配一个线程EventLoop像是包工头手下管着几千个工人Channel。每个工人只听这一个包工头的话。异步包工头接活时先给你开个收据Future然后让你一边玩去。活干完了他再按收据上的电话通知你。队列如果你想指挥工人干活但你不是包工头你不能直接吼工人。你得写个纸条Task塞进包工头的信箱Queue。包工头忙完手头的活IO会去信箱拿纸条执行。