Netty剖析之Netty任务队列

客官°小女子只卖身不卖艺 2023-07-03 06:06 1阅读 0赞

### 前言 ###

在前面我们有讲到，在使用Netty的时候，我们的业务处理都是放到我们自定义的handler里面，那么如果handler里面有一些执行比较耗时的操作的话，依旧会出现线程阻塞的情况，那么怎么来处理呢？我们可以回过头去看看Netty的模型图，里面有一块是**TaskQueue**，这个呢就是Netty提供给我们的任务队列，可以用来异步处理任务，它是和channel一一绑定的。

### 自定义普通任务 ###

通过ChannelHandlerContext获取channel，通过channel获取eventLoop，然后调用execute方法即可放入到任务队列，代码如下：

Channel channel = ctx.channel();
    
    channel.eventLoop().execute(new Runnable() {
        @Override
        public void run() {
            try {
                Thread.sleep(5000);
                ctx.writeAndFlush(Unpooled.copiedBuffer("自定义普通任务~", CharsetUtil.UTF_8));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    });

### 自定义定时任务 ###

定时任务也大同小异，都是通过ChannelHandlerContext获取channel，通过channel获取eventLoop，然后调用schedule方法即放入到任务队列，代码如下：

channel.eventLoop().schedule(new Runnable() {
        @Override
        public void run() {
            ctx.writeAndFlush(Unpooled.copiedBuffer("自定义定时任务~", CharsetUtil.UTF_8));
        }
    },5, TimeUnit.SECONDS);

schedule第一个参数和普通任务一样，传入一个线程即可，第二个参数是延时事件，第三个参数是延时单位，此处使用的是秒

发表评论取消回复

表情：

评论列表（有 0 条评论，1人围观）

还没有评论，来说两句吧...

相关阅读

相关 Netty剖析之Netty群聊系统

前言在前面我们讲解了Netty的基本使用，本次我们将使用Netty来完成一个群聊系统，实现服务器端和客户端之间的数据简单通讯; 群聊系统基本要求：服务器端可

╰半橙微兮°/ 2023年07月03日 07:21/ 0 赞/ 4 阅读

相关 Netty剖析之Netty异步模型

异步模型基本介绍 1. 异步的概念和同步相对，当一个异步过程调用发出后，调用者不能立刻得到结果。实际处理这个调用的组件在完成后，通过状态、通知、回调来通知调用者。 2.

浅浅的花香味﹌/ 2023年07月03日 06:15/ 0 赞/ 67 阅读

相关 Netty剖析之Http服务案例

前言前面我们讲了Netty的线程模型，还有一些Netty的特性，以及使用Netty编写过一个Tcp服务案例，本次呢，我们将结合前面所学的知识，来编写一个Http服务案例

怼烎@/ 2023年07月03日 06:15/ 0 赞/ 62 阅读

相关 Netty剖析之Netty任务队列

前言在前面我们有讲到，在使用Netty的时候，我们的业务处理都是放到我们自定义的handler里面，那么如果handler里面有一些执行比较耗时的操作的话，依旧会出现线

客官°小女子只卖身不卖艺/ 2023年07月03日 06:06/ 0 赞/ 2 阅读

相关 Netty剖析之零拷贝

什么是零拷贝？零拷贝是网络编程的关键，很多性能优化都离不开；零拷贝，是从操作系统的角度来说的。因为内核缓冲区之间，没有数据是重复的（只有 kernel b

我不是女神ヾ/ 2023年07月03日 03:29/ 0 赞/ 31 阅读

相关 Netty剖析之BIO

什么是BIO？ BIO(blocking I/O)，同步阻塞IO，服务器实现模式为一个线程处理一个连接，即每当有一个客户端连接时，就会启动一个独立的线程来进行处理，如果这

傷城~/ 2023年07月02日 14:25/ 0 赞/ 2 阅读

相关 Netty剖析之IO

什么是IO？所谓IO即`input`和`output`的缩写，是对数据流入和流出的抽象概念 IO简单的理解就是用什么样的通道进行数据的发送和接收，很大程度上

冷不防/ 2023年07月02日 14:25/ 0 赞/ 14 阅读

相关【Netty】Netty 高性能之道

Netty Netty 系列之 Netty 高性能之道 1. 背景 1.1. 惊人的性能数据最近一个圈内朋友通过私信告诉我，通过使用 Netty4 +

曾经终败给现在/ 2022年09月30日 06:11/ 0 赞/ 242 阅读

相关 netty系列之:netty初探

文章目录简介 netty介绍 netty的第一个服务器 netty的第一个客户端运行服务器和客户端总结简介我们常用浏

蔚落/ 2022年09月02日 11:51/ 0 赞/ 279 阅读

相关 Netty系列之Netty高性能之道

1. 背景 1.1. 惊人的性能数据最近一个圈内朋友通过私信告诉我，通过使用Netty4 + Thrift压缩二进制编解码技术，他们实现了10W TPS（1K的复

﹏ヽ暗。殇╰゛Y/ 2022年07月27日 14:53/ 0 赞/ 269 阅读