常州公司做网站,电子商务难学吗,自己如何做一个网络平台,做自适应网站注意事项【README】
1.本文总结自 B站 《尚硅谷-netty》;
2.NioEventLoop实际上是一个提交到线程池的Runnable任务#xff0c;在while无限循环中运行 taskQueue中的任务#xff08;串行#xff09;#xff1b; 【1】提交任务到NioEventLoop
1#xff09;NioEventLoop#xff1…【README】
1.本文总结自 B站 《尚硅谷-netty》;
2.NioEventLoop实际上是一个提交到线程池的Runnable任务在while无限循环中运行 taskQueue中的任务串行 【1】提交任务到NioEventLoop
1NioEventLoop
表示一个不断循环执行的Runnable任务每个NioEventLoop都有一个selector用于监听绑定在其上的 socket 网络通道
2NioEventLoop 内部采用串行化设计
从消息的读取-解码-处理-编码-发送始终由IO 线程 NioEventLoop 负责
3NioEventLoopGroup 下包含多个 NioEventLoop
每个 NioEventLoop 中包含有一个 Selector一个taskQueue 每个 NioEventLoop 的 Selector 上可以注册监听多个NioChannel 每个 NioChannel 只会绑定在唯一的 NioEventLoop 上每个 NioChannel 都绑定有一个自己的 ChannelPipeline
4任务提交到 NioEventLoop 后实际会添加到 taskQueue
taskQueue的访问路径如下 ChannelHandlerContext -DefaultChannelPipeline -NioSocketChannel -NioEventLoop -taskQueue 任务队列【1.1】场景1-在 netty server的handler中提交普通任务
/*** Description netty服务器处理器* author xiao tang* version 1.0.0* createTime 2022年08月27日*/
public class SimpleNettyServerHandler45 extends ChannelInboundHandlerAdapter {// 读写数据事件读取客户端发送的消息// 1. ChannelHandlerContext ctx 上下文信息包括管道pipeline通道channel地址// 2. Object msg 客户端发送的数据默认是 ObjectOverridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {System.out.println(server ctx ctx);System.out.println(查看 channel 和 pipeline的关系 );Channel channel ctx.channel();ChannelPipeline channelPipeline ctx.pipeline(); // 管道是双向链表出栈入栈// 将 msg 转为 ByteBuf 字节缓冲// 这个 ByteBuf 是 netty提供的 不是 nio的ByteBufferByteBuf buf (ByteBuf) msg;System.out.println(客户端发送消息 buf.toString(StandardCharsets.UTF_8));System.out.println(客户端地址 ctx.channel().remoteAddress());// 同步任务1// 业务场景 有一个耗时长的业务 - 异步执行 - 提交该 channel对应的 NIOEventLoop 的 taskQueue 中
// Thread.sleep(10 * 1000);
// ctx.writeAndFlush(Unpooled.copiedBuffer(hello, 客户端我是同步任务1, StandardCharsets.UTF_8));
// System.out.println(go on.....);// 以上耗时操作的解决方案1用户程序自定义的普通任务// 异步任务2ctx.channel().eventLoop().execute(new Runnable() {Overridepublic void run() {try {Thread.sleep(10 * 1000);ctx.writeAndFlush(Unpooled.copiedBuffer(hello, 客户端我是异步任务2-休眠10s, StandardCharsets.UTF_8));} catch (Exception e) {System.out.println(发生异常, e.getMessage());}}});// 异步任务3ctx.channel().eventLoop().execute(new Runnable() {Overridepublic void run() {try {Thread.sleep(20 * 1000);ctx.writeAndFlush(Unpooled.copiedBuffer(hello, 客户端我是异步任务3-休眠20s, StandardCharsets.UTF_8));} catch (Exception e) {System.out.println(发生异常, e.getMessage());}}}); 【1.2】场景2-在 netty server的handler中提交定时任务
// 异步任务2和异步任务3添加到同一个任务队列由同一个线程来运行所以异步任务2阻塞10s而异步任务3会阻塞30s1020System.out.println(异步任务 go on.....);// 用户自定义定时任务 -》 定时任务提交到 scheduledTaskQueue 中ctx.channel().eventLoop().schedule(new Runnable() {Overridepublic void run() {try {Thread.sleep(20 * 1000);ctx.writeAndFlush(Unpooled.copiedBuffer(hello, 客户端我是定时任务1-休眠5s, StandardCharsets.UTF_8));} catch (Exception e) {System.out.println(发生异常, e.getMessage());}}}, 5, TimeUnit.SECONDS);System.out.println(定时任务 go on.....);
【代码解说】
以上任务提交后实际会添加到 taskQueue taskQueue的访问路径如下 ChannelHandlerContext -DefaultChannelPipeline -NioSocketChannel -NioEventLoop -taskQueue 任务队列每个NioEventLoop只能使用1个独立线程运行任务队列中的任务即多个任务串行执行
【补充】taskQueue目录树
