Netty进阶之路-JDK业务线程池

港控/mmm° 2022-01-26 22:37 414阅读 0赞

### Netty进阶之路-JDK业务线程池 ###

*  前言
 *  JDK业务线程池分析
 *  JDK业务线程池实现

# 前言 #

之前我们说了有2种思路解决服务端处理耗时的业务，第一种EventExecutorGroup，第二钟就是采用DK业务线程池

# JDK业务线程池分析 #

和EventExecutorGroup不同，I/O线程会将业务放入到jdk线程中执行，writeAndFlush之后再放入I/O线程中。如果是一个长连接，业务非常耗时可以采用这种方式，采用EventExecutorGroup的方法是无效的。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyOTQ2MzQ0NzM_size_16_color_FFFFFF_t_70]

# JDK业务线程池实现 #

直接在业务处理的时候使用线程池即可

//定义
    static ExecutorService executorService = Executors.newFixedThreadPool(10);
    
    @Override
        public void channelRead(final ChannelHandlerContext ctx, final Object msg) throws IOException {
        	executorService.execute(new Runnable() {
    			@Override
    			public void run() {
    				System.out.println("服务端接收到请求");
    		    	RPCRequest request = (RPCRequest) msg;
    		    	//业务处理 假设每次处理需要1S
    		    	try {
    					Thread.sleep(1000);
    				} catch (InterruptedException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    		        String result=InvokeServiceUtil.invoke(request);
    		        RPCResponse response=new RPCResponse();
    		        response.setRequestID(request.getRequestID());
    		        response.setResult(result);
    		        ctx.writeAndFlush(response);
    			}
    		});
        }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2EyOTQ2MzQ0NzM_size_16_color_FFFFFF_t_70]: /images/20220127/5d93e62b3b4c491caf1bedfec45c6151.png