最近在用Netty帮助业务开发封装一个通讯组件的时候,关于ChannelFactory发现了一些问题,暂时纪录如下:
1 - 内存泄漏问题
梁飞的博客中提到了Netty的ChannelFactory在不断的销毁和创建过程中,会出现内存泄漏的问题,从而在dubbo中采用静态化的方式来规避这个问题(原文:http://javatar.iteye.com/blog/1138527)。但是我的开发环境下面(jdk1.7.0_09Mac版 + Netty 3.6.2),使用类似梁飞博客中的测试案例时,采用静态化反而会出现Can't assign requested address的错误,如果不使用静态化的方式,反而能够顺利运行(大约运行了2个小时,重复了2000多万次的创建和销毁)。
2 - java.util.concurrent.RejectedExecutionException
在心跳的测试过程中,发现Server unbound再重新bound之后,客户端无法重新连接,报了java.util.concurrent.RejectedExecutionException。开始无论如何也没想明白为什么,google之后再结合代码的改动突然想到,心跳失败后会关闭连接时会调用ChannelFactory.releaseExternalResources()的方法,重新连接时并没有再次初始化ChannelFactory对象,由于releaseExternalResources方法会调用所有executor(包括bossExecutor,workerExecutor,内部的deadlock proof executor等)的shutdown方法,这样在重新连接时向executor发送建立连接的task时就会出现异常。
P.S: java.util.concurrent.RejectedExecutionException的发生条件(from stackoverflow):
- when calling
execute()
on aThreadPoolExecutor
and the maximum pool size has been reached. - when calling
execute()
on aThreadPoolExecutor
at the same time thatshutdownNow
, and has essentially lost the race with theshutdownNow
call. - when trying to schedule execution of a runnable in a
ScheduledThreadPoolExecutor
after the executor has been shutdown.
相关推荐
在描述中提到的"org.jboss.netty.channel.ChannelFactory"是Netty框架的核心组件之一。ChannelFactory是Netty中的一个接口,它负责创建并管理Channel实例。Channel是Netty中连接到远程或本地端点的抽象,可以用来...
ChannelFactory 负责创建 Channel,ChannelPipelineFactory 负责创建 ChannelPipeline。 Netty 提供了一个异步的、事件驱动的网络应用程序框架和工具,使用 Netty 可以快速开发出可维护的、high-performance 的协议...
Netty的整体架构包括ChannelFactory、Boss、Worker、Channel、ChannelEvent、Pipeline、ChannelContext、Handler、Sink等组件。其中,ChannelFactory是工厂类,负责创建Channel对象;Boss和Worker是线程池,负责处理...
通过设置ChannelFactory、Group、Pipeline等,然后调用bind或connect方法启动服务。 7. **EventLoopGroup(事件循环组)**:一组EventLoop,每个EventLoop负责处理一组Channel的事件。通常,服务器端会有一个...
#### ChannelFactory 用于创建新的`Channel`实例。 #### ChannelUnsafe 提供了一些不安全的操作,允许用户直接访问底层的NIO操作。 ### ChannelHandler `ChannelHandler`是Netty中的核心组件之一,用于处理读写...
- `ServerBootstrap` 是 Netty 中用于配置服务器的工具类,用于设置各种参数如 `bossGroup`、`workerGroup`、`channelFactory`、`SO_BACKLOG`、`handler` 和 `childHandler`。 - `SO_BACKLOG` 参数设置连接请求...
然后,创建Netty的客户端Bootstrap,配置好EventLoopGroup(通常使用NioEventLoopGroup,它是非阻塞I/O的实现),并设置ChannelFactory来创建客户端Channel。接着,定义Pipeline,添加自定义的处理器,处理器可以...
在Netty中,根据不同的协议和I/O模型,会选择相应的ChannelFactory实例来创建Channel。例如,对于TCP连接,客户端使用NioSocketChannelFactory,服务器端则使用NioServerSocketChannelFactory。 Netty的灵活性在于...
- 组建管道:通过 `channelFactory` 创建新的 Channel 实例,并通过 `childHandler` 添加 ChannelInitializer 来初始化新建立的连接的 ChannelPipeline。 2. **Channel**: - Channel 是 Netty 中的核心概念,...
UdpServerSocketChannel: 用于netty 4.1的UDP服务器,它为每个远程地址分配用户通道(就像netty TCP服务器一样) 默认情况下,分配的通道永远...import io.netty.channel.ChannelFactory; import io.netty.channel.Ch
3. 指定通道类型:`channel(Class)` 或 `channelFactory(ChannelFactory)` 4. 设置本地地址:`localAddress(SocketAddress)`,如服务器监听的端口 5. 设置通道选项:`option(ChannelOption, T)`,用于定制通道的行为...