public?void?bind(ServiceConfig?serviceConfig)?{EventLoopGroup?bossGroup?=?new?NioEventLoopGroup();EventLoopGroup?workerGroup?=?new?NioEventLoopGroup();try?{ServerBootstrap?bootstrap?=?new?ServerBootstrap();
????????????bootstrap.group(bossGroup,?workerGroup)
????????????????????.channel(NioServerSocketChannel.class)
????????????????????.childHandler(this.rpcServerInitializer)
????????????????????.childOption(ChannelOption.SO_KEEPALIVE,true)
????????????;try?{ChannelFuture?channelFuture?=?bootstrap.bind(serviceConfig.getHost(),serviceConfig.getPort()).sync();//...channelFuture.channel().closeFuture().sync();


????????????}?catch?(InterruptedException?e)?{throw?new?RpcException(e);
????????????}
????????}finally?{
????????????bossGroup.shutdownGracefully();
????????????workerGroup.shutdownGracefully();
????????}
????}

public?interface?RpcThreadPool?{Executor?getExecutor(int?threadSize,int?queues);
}

@Qualifier("fixedRpcThreadPool")@Componentpublic?class?FixedRpcThreadPool?implements?RpcThreadPool?{private?Executor?executor;@Overridepublic?Executor?getExecutor(int?threadSize,int?queues)?{if(null==executor)?{synchronized?(this)?{if(null==executor)?{
????????????????????executor=?new?ThreadPoolExecutor(threadSize,?threadSize,?0L,?TimeUnit.MILLISECONDS,
????????????????????????????queues?==?0???new?SynchronousQueue<Runnable>()?:(queues?<?0???new?LinkedBlockingQueue<Runnable>():?new?LinkedBlockingQueue<Runnable>(queues)),new?RejectedExecutionHandler()?{@Overridepublic?void?rejectedExecution(Runnable?r,?ThreadPoolExecutor?executor)?{???????????????????????????????????//...}
????????????????????????????});
????????????????}
????????????}
????????}return?executor;
????}
}

@Componentpublic?class?RpcThreadPoolFactory?{@Autowiredprivate?Map<String,RpcThreadPool>?rpcThreadPoolMap;public?RpcThreadPool?getThreadPool(String?threadPoolName){return?this.rpcThreadPoolMap.get(threadPoolName);
????}
}

@Overrideprotected?void?channelRead0(ChannelHandlerContext?channelHandlerContext,?RpcRequest?rpcRequest)?{this.executor.execute(new?Runnable()?{@Overridepublic?void?run()?{RpcInvoker?rpcInvoker=RpcServerInvoker.this.buildInvokerChain(RpcServerInvoker.this);RpcResponse?response=(RpcResponse)?rpcInvoker.invoke(RpcServerInvoker.this.buildRpcInvocation(rpcRequest));
????????????channelHandlerContext.writeAndFlush(response);
????????}
????});
}