Java Netty (1)

Netty是由JBOSS提供的一个java开源框架，本质上也是NIO，是对NIO的封装，比NIO更加高级，功能更加强大。可以说发展的路线是IO->NIO->Netty。

ServerBootstrap和ClientBootstrap是Netty中两个比较重要的类，分别用来进行服务器和客户端的初始化。

服务器：

        // ChannelFactoryfinal ChannelFactory channelFactory = new NioServerSocketChannelFactory(  // Boss线程池,处理Socket请求
                Executors.newCachedThreadPool(),  // Worker线程池,由于使用的是NIO,1个Worker线程可以管理多个Channel
                Executors.newCachedThreadPool()); // ServerBootstrapServerBootstrap bootstrap = new ServerBootstrap(channelFactory);ServerPipelineFactory serverPipelineFactory = new ServerPipelineFactory(executionHandler);bootstrap.setPipelineFactory(serverPipelineFactory);

ServerBootstrap实例化时需要一个ServerSocketChannelFactory参数，ServerSocketChannelFactory可以选择NioServerSocketChannelFactory或者OioServerSocketChannelFactory，NioServerSocketChannelFactory使用的是NIO，OioServerSocketChannelFactory使用的是普通IO。两者都需要两个线程池，一个Boss线程池，一个Worker线程池。一个Boss线程负责对一个端口的监听，接收到Socket连接请求以后交给一个Worker线程处理，然后自己继续监听。

Worker线程负责对接收到的连接请求进行处理，如果是NIO，一个Worker线程可以处理多个Socket或者说Channel，如果是普通IO，Worker线程和Socket或者说Channel是一一对应的关系。

Channel有消息到达时，Worker线程就进行处理。处理的过程类似于Struts的Filter-chain。每个Channel都有一个ChannelPipeline，ChannelPipeline定义了很多有顺序的Handler，按顺序对接收到的消息进行处理。

有些Handler，比如大量的IO操作，或者大量的读写数据库，会造成对消息的处理时间过长，长期占用Worker线程，这时就需要另一个线程池--Netty自带的ExecutionHandler。ExecutionHandler也是一个Handler，定义在ChannelPipeline里面，它会从自己的线程池里面拿出一个线程，处理写在自己后面的Handler，从而可以尽快释放Worker线程。

ExecutionHandler的实例化：

static ExecutionHandler executionHandler = new ExecutionHandler(new OrderedMemoryAwareThreadPoolExecutor(16, 1048576, 1048576));

Excecutor有两种：MemoryAwareThreadPoolExecutor和OrderedMemoryAwareThreadPoolExecutor，前者保证不会出现内存溢出错误，如果Event太多就会堵塞，后者除了保证不会出现内存溢出错误以外，还保证同一个Channel的Event按照顺序处理。

Java Netty (1)相关推荐

java netty聊天室_netty实现消息中心（二）基于netty搭建一个聊天室
前言上篇博文(netty实现消息中心(一)思路整理 )大概说了下netty websocket消息中心的设计思路,这篇文章主要说说简化版的netty聊天室代码实现,支持群聊和点对点聊天. 此demo ...
java 带宽控制_如何使用Java netty正确限制带宽使用？
对于我使用netty nio lib在 Java中开发的下载客户端,我还实现了带宽限制功能.从技术上讲,我是通过GlobalTrafficShapingHandler对象完成的.基于这个类'JavaD ...
tt协议号服务器,TTIot: TTIoT云端物联网Iot组件;面向JAVA;netty;mqtt;异步推送;以事件为驱动;为设备提供安全可靠的连接通信能力;...
TTIoT云端物联网组件;面向JAVA;以事件为驱动;为设备提供安全可靠的连接通信能力 TTIoT简介 TTIOT的Broker采用MQTT协议与设备进行交互,可以应用在数据采集.能源监控.智能生活. ...
java netty socket_Netty对socket的抽象
传统socket 首先还是先了解下传统socket下的通信流程流程很清晰,细节不讲太多. Netty抽象在netty中步骤1监听端口对应就是NioEventLoop,即事件循环,这里的循环包括两个 ...
java netty modbus协议接收iot数据
IoTserver 源代码开源在gitee上 : IoT netty java gitee server sample c++ libuv 的IoT tcp server IoT c++ libuv ...
java netty能做什么_开发：Netty快速入门，一看就懂！
很早以前就写过关于 Netty 的使用,最近发现还有网友在看之前写的那篇 Netty 文章,个人感觉那时候写的很粗糙,怕影响同行的阅读质量,所以决定重新写一些关于 Netty 的文章,补充以前的不足. ...
java netty 面试_Java 200+ 面试题补充② Netty 模块
让我们每天都能看到自己的进步.老王带你打造最全的 Java 面试清单,认真把一件事做到最好. 1.Netty 是什么? Netty 是一款基于 NIO(Nonblocking I/O,非阻塞IO)开发 ...
Java+Netty+WebRTC、语音、视频、屏幕共享【聊天室设计实践】
背景本文使用webtrc实现了一个简单的语音视频聊天室.支持多人音视频聊天.屏幕共享. 环境配置音视频功能需要在有Https协议的域名下才能获取到设备信息, 测试环境搭建Https服务参考Wind ...
java netty wss_netty中websocket, wss
websocket 直接使用SpringBoot+Netty来支持WebSocket,并且需要支持wss,其需要注意事项有以下: wss支持 websocket请求路径中带参数针对第一个问题:wss ...

Java Netty (1)

Java Netty (1)相关推荐

最新文章

热门文章