netty版本

使用的netty版本是io.netty:netty-all:4.1.33.Final

Netty耗时任务的处理

Netty中EventLoop用来处理IO线程，因此handler中的耗时任务(比如数据库连接、远程调用等)不能在EventLoop里面执行。如果有耗时任务，需要将耗时任务添加到业务线程池中执行。
处理耗时任务的两种方式
- Handler中加入线程池
- Context中添加线程池
两种方式的对比
- Handler中自定义业务线程池更加灵活，每个Handler都可以自己控制自己的业务线程池，对于非耗时的任务可以不使用业务线程池，直接在EventLoop线程中执行。
- Context中添加线程池(Netty建议的方式),在pipeline中添加Handler的时候，添加一个业务线程池。这种方式Handler中的代码不需要做任何修改，但是整个Handler都交给业务线程池，无论是否是耗时任务都会加入到队列里，控制的粒度比较粗。
如果业务ChannelHandler处理逻辑比较简单，执行时间是受控的，业务I/O线程的负载也不重，在这种应用场景下，业务ChannelHandler可以和I/O操作共享同一个线程。使用这种线程模型会带来两个优势：
- 开发简单，开发业务ChannelHandler的不需要关注Netty的线程模型
- 性能更高：因为减少了一次线程上下文切换，所以性能会更高。
Netty线程池的特点
- Channel和EventLoop是N:1的关系：一个Channel生命周期内只注册一个EventLoop，一个EventLoop可能会给分配给多个Channel,所以如果一个Channel阻塞可能会导致其他在同一个EventLoop上的Channel都阻塞。
- 一个EventLoopGroup包含一个或者多个EventLoop,一个EventLoop在其生命周期内只与一个Thread绑定（EbeddedEventLoop除外）EventLoop的Thread负责处理该事件循环内所有的IO事件

代码案例

`Handler`自定义业务线程池

Handler中自定义业务线程池

    @ChannelHandler.Sharablepublic class EchoServerHandler extends SimpleChannelInboundHandler<String> {public static final ChannelHandler INSTANCE = new EchoServerHandler();private static final String LINE = System.getProperty("line.separator");private EchoServerHandler() {}protected static ExecutorService newFixedThreadPool() {final ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("netty-business-%d").setDaemon(false).build();return new ThreadPoolExecutor(200, 200,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>(10000),threadFactory);}final static ListeningExecutorService service = MoreExecutors.listeningDecorator(newFixedThreadPool());@Overridepublic void channelRead0(ChannelHandlerContext ctx, String msg) {service.submit(new Runnable() {@Overridepublic void run() {//模拟耗时任务try {Thread.sleep(5000);logger.info("execute time 5s");} catch (InterruptedException e) {Thread.currentThread().interrupt();}ctx.writeAndFlush(msg + LINE).addListener(ChannelFutureListener.CLOSE);}});}}

Server启动代码

    public class EchoServer {private final int port;public EchoServer(int port) {this.port = port;}public void start() throws Exception {NioEventLoopGroup boss = new NioEventLoopGroup(1);NioEventLoopGroup worker = new NioEventLoopGroup();try {ServerBootstrap b = new ServerBootstrap();b.group(boss, worker).channel(NioServerSocketChannel.class).localAddress(new InetSocketAddress(port)).childHandler(new ChannelInitializer<SocketChannel>() {@Overridepublic void initChannel(SocketChannel ch) {ChannelPipeline pipeline = ch.pipeline();pipeline.addLast(new LineBasedFrameDecoder(1024));pipeline.addLast(new StringDecoder());pipeline.addLast(new StringEncoder());pipeline.addLast(EchoServerHandler.INSTANCE);}});ChannelFuture f = b.bind().sync();System.out.println(String.format("%s started and listen on %s", EchoServer.class.getName(), f.channel().localAddress()));f.channel().closeFuture().sync();} finally {boss.shutdownGracefully().sync();worker.shutdownGracefully().sync();}}public static void main(String[] args) throws Exception {new EchoServer(8080).start();}}

使用多个telnet连接并请求，输出结果,可以看出执行任务使用的是我们自己定义的线程池
```
    netty-business-0 execute time 5snetty-business-1 execute time 5s
```

Context中添加线程池

Handler代码无需任何的改动,不需要启动任何额外线程来处理任务

    @ChannelHandler.Sharablepublic class EchoServerHandler extends SimpleChannelInboundHandler<String> {public static final ChannelHandler INSTANCE = new EchoServerHandler();private static final String LINE = System.getProperty("line.separator");private EchoServerHandler() {}@Overridepublic void channelRead0(ChannelHandlerContext ctx, String msg) {//模拟耗时任务try {Thread.sleep(5000);System.out.printf("%s execute time 5s \n", Thread.currentThread().getName());} catch (InterruptedException e) {Thread.currentThread().interrupt();}ctx.writeAndFlush(msg + LINE).addListener(ChannelFutureListener.CLOSE);}}

启动代码

    public class EchoServer {private final int port;public EchoServer(int port) {this.port = port;}public void start() throws Exception {final ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("netty-context-business-%d").setDaemon(false).build();NioEventLoopGroup boss = new NioEventLoopGroup(1);NioEventLoopGroup worker = new NioEventLoopGroup();NioEventLoopGroup business = new NioEventLoopGroup(200,threadFactory);try {ServerBootstrap b = new ServerBootstrap();b.group(boss, worker).channel(NioServerSocketChannel.class).localAddress(new InetSocketAddress(port)).childHandler(new ChannelInitializer<SocketChannel>() {@Overridepublic void initChannel(SocketChannel ch) {ChannelPipeline pipeline = ch.pipeline();pipeline.addLast(new LineBasedFrameDecoder(1024));pipeline.addLast(new StringDecoder());pipeline.addLast(new StringEncoder());pipeline.addLast(business, EchoServerHandler.INSTANCE);}});ChannelFuture f = b.bind().sync();System.out.println(String.format("%s started and listen on %s", EchoServer.class.getName(), f.channel().localAddress()));f.channel().closeFuture().sync();} finally {boss.shutdownGracefully().sync();worker.shutdownGracefully().sync();business.shutdownGracefully().sync();}}public static void main(String[] args) throws Exception {new EchoServer(8080).start();}}

使用多个telnet连接并请求，输出结果

    netty-context-business-0 execute time 5s netty-context-business-1 execute time 5s

Netty案例(二)之耗时任务的处理相关推荐

【Netty】Netty 入门案例分析 ( Netty 线程模型 | Netty 案例需求 | IntelliJ IDEA 项目导入 Netty 开发库 )
文章目录一. Netty 线程模型二. Netty 案例需求三. IntelliJ IDEA 引入 Netty 包一. Netty 线程模型 1 . Netty 中的线程池 : Netty 中 ...
蚂蚁区块链投票案例(二)---投票合约设计开发
文章目录摘要背景案例场景用例分析系统管理员注册添加小区.添加房屋编辑房屋发起投票统计投票业主注册业主实名认证客房关系认证投票合约设计设计原则合约设计合约开发命名规则 ...
2021年大数据Flink（三十五）：Table与SQL 案例二
目录案例二需求代码实现-SQL 代码实现-Table 案例二需求使用SQL和Table两种方式对DataStream中的单词进行统计代码实现-SQL package cn.it.sql;i ...
2021年大数据Flink（二十）：案例二基于数量的滚动和滑动窗口
目录案例二基于数量的滚动和滑动窗口需求代码实现案例二基于数量的滚动和滑动窗口需求需求1:统计在最近5条消息中,各自路口通过的汽车数量,相同的key每出现5次进行统计--基于数量的滚动窗 ...
2021年大数据Spark（三十七）：SparkStreaming实战案例二 UpdateStateByKey
目录 SparkStreaming实战案例二 UpdateStateByKey 需求 1.updateStateByKey 2.mapWithState 代码实现 SparkStreaming实战案例 ...
2021年大数据Spark（二十七）：SparkSQL案例一花式查询和案例二WordCount
目录案例一:花式查询案例二:WordCount 基于DSL编程基于SQL编程具体演示代码如下: 案例一:花式查询 package cn.itcast.sqlimport org.apache. ...
【数字信号处理】线性时不变系统 LTI “ 输入 “ 与 “ 输出 “ 之间的关系 ( 线性卷积计算案例二 | 计算卷积 )
文章目录一.线性卷积计算案例二一.线性卷积计算案例二给定如下两个序列 : x(n)={3,4,5}[−2,0]x(n) = \{ 3 , 4, 5 \}_{[-2,0]}x(n)={3,4, ...
【数字信号处理】线性时不变系统 LTI ( 判断某个系统是否是 “ 非时变 “ 系统 | 案例二 )
文章目录一.判断系统是否 " 非时变 " 1.案例二 ① 时不变系统概念 ② 先变换后移位 ③ 先移位后变换 ④ 结论一.判断系统是否 " 非时变 " 1. ...
Redis简单案例(二) 网站最近的访问用户
原文:Redis简单案例(二) 网站最近的访问用户我们有时会在网站中看到最后的访问用户.最近的活跃用户等等诸如此类的一些信息.本文就以最后的访问用户为例, 用Redis来实现这个小功能.在这之前,我 ...

Netty案例(二)之耗时任务的处理

文章目录

netty版本

Netty耗时任务的处理

代码案例

`Handler`自定义业务线程池

Context中添加线程池

Netty案例(二)之耗时任务的处理相关推荐

最新文章

热门文章

Netty案例(二)之耗时任务的处理

文章目录

netty版本

Netty耗时任务的处理

代码案例

Handler自定义业务线程池

Context中添加线程池

Netty案例(二)之耗时任务的处理相关推荐

最新文章

热门文章

`Handler`自定义业务线程池