宜人贷蜂巢API网关技术解密之Netty使用实践

NioEventLoop的继承关系比较复杂，在AbstractScheduledEventExecutor 中，Netty 实现了 NioEventLoop 的 schedule 功能，即我们可以通过调用一个 NioEventLoop 实例的 schedule 方法来运行一些定时任务。而在 SingleThreadEventLoop 中，又实现了任务队列的功能，通过它，我们可以调用一个NioEventLoop 实例的 execute 方法来向任务队列中添加一个 task, 并由 NioEventLoop 进行调度执行。

通常来说，NioEventLoop 肩负着两种任务，第一个是作为 IO 线程，执行与 Channel 相关的 IO 操作，包括调用 select 等待就绪的 IO 事件、读写数据与数据的处理等；而第二个任务是作为任务队列，执行 taskQueue 中的任务，例如用户调用 eventLoop.schedule 提交的定时任务也是这个线程执行的。

具体的构造过程，见下：

创建任务队列tailTasks(内部为有界的LinkedBlockingQueue)：

创建线程的任务队列taskQueue(内部为有界的LinkedBlockingQueue)，以及任务过多防止系统宕机的拒绝策略rejectedHandler。

其中tailTasks和taskQueue均是任务队列，而优先级不同，taskQueue的优先级高于tailTasks，定时任务的优先级高于taskQueue。

五、ServerBootstrap初始化及启动

了解了Netty线程池NioEvenrLoopGroup的创建过程后，下面看下API网关服务ServerBootstrap的是如何使用线程池引入服务中，为高并发访问服务的。

API网关ServerBootstrap初始化及启动代码，见下：

serverBootstrap = new ServerBootstrap();  
bossGroup = new NioEventLoopGroup(config.getBossGroupThreads());  
workerGroup = new NioEventLoopGroup(config.getWorkerGroupThreads());   
 
serverBootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)  
        .option(ChannelOption.TCP_NODELAY, config.isTcpNoDelay())  
        .option(ChannelOption.SO_BACKLOG, config.getBacklogSize())  
        .option(ChannelOption.SO_KEEPALIVE, config.isSoKeepAlive())  
        // Memory pooled  
        .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)  
        .childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)  
        .childHandler(channelInitializer);    
 
ChannelFuture future = serverBootstrap.bind(config.getPort()).sync();  
log.info("API-gateway started on port: {}", config.getPort());  
future.channel().closeFuture().sync(); 

（编辑：威海站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!