`
asticx
  • 浏览: 5914 次
社区版块
存档分类
最新评论

Netty ChannelFactory

阅读更多

最近在用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 a ThreadPoolExecutor and the maximum pool size has been reached.
  • when calling execute() on a ThreadPoolExecutor at the same time that shutdownNow, and has essentially lost the race with the shutdownNow call.
  • when trying to schedule execution of a runnable in a ScheduledThreadPoolExecutor after the executor has been shutdown.
分享到:
评论

相关推荐

    netty-3.2.1.Final.jar

    在描述中提到的"org.jboss.netty.channel.ChannelFactory"是Netty框架的核心组件之一。ChannelFactory是Netty中的一个接口,它负责创建并管理Channel实例。Channel是Netty中连接到远程或本地端点的抽象,可以用来...

    Netty的入门经典例子

    ChannelFactory 负责创建 Channel,ChannelPipelineFactory 负责创建 ChannelPipeline。 Netty 提供了一个异步的、事件驱动的网络应用程序框架和工具,使用 Netty 可以快速开发出可维护的、high-performance 的协议...

    netty技术实现即时通信方案.pdf

    Netty的整体架构包括ChannelFactory、Boss、Worker、Channel、ChannelEvent、Pipeline、ChannelContext、Handler、Sink等组件。其中,ChannelFactory是工厂类,负责创建Channel对象;Boss和Worker是线程池,负责处理...

    Netty项目代码

    通过设置ChannelFactory、Group、Pipeline等,然后调用bind或connect方法启动服务。 7. **EventLoopGroup(事件循环组)**:一组EventLoop,每个EventLoop负责处理一组Channel的事件。通常,服务器端会有一个...

    learning-netty

    #### ChannelFactory 用于创建新的`Channel`实例。 #### ChannelUnsafe 提供了一些不安全的操作,允许用户直接访问底层的NIO操作。 ### ChannelHandler `ChannelHandler`是Netty中的核心组件之一,用于处理读写...

    以netty4.1源码中的EchoServer为例对netty的源码进行分析.docx

    - `ServerBootstrap` 是 Netty 中用于配置服务器的工具类,用于设置各种参数如 `bossGroup`、`workerGroup`、`channelFactory`、`SO_BACKLOG`、`handler` 和 `childHandler`。 - `SO_BACKLOG` 参数设置连接请求...

    Android使用netty

    然后,创建Netty的客户端Bootstrap,配置好EventLoopGroup(通常使用NioEventLoopGroup,它是非阻塞I/O的实现),并设置ChannelFactory来创建客户端Channel。接着,定义Pipeline,添加自定义的处理器,处理器可以...

    咕泡学院_Tom_JavaVIP课程_深入分析Netty源码1

    在Netty中,根据不同的协议和I/O模型,会选择相应的ChannelFactory实例来创建Channel。例如,对于TCP连接,客户端使用NioSocketChannelFactory,服务器端则使用NioServerSocketChannelFactory。 Netty的灵活性在于...

    06.NettyServerBootstrap启动的详细过程类图分析.rar

    - 组建管道:通过 `channelFactory` 创建新的 Channel 实例,并通过 `childHandler` 添加 ChannelInitializer 来初始化新建立的连接的 ChannelPipeline。 2. **Channel**: - Channel 是 Netty 中的核心概念,...

    UdpServerSocketChannel:Netty udp服务器套接字通道,它为每个远程地址分配单独的通道

    UdpServerSocketChannel: 用于netty 4.1的UDP服务器,它为每个远程地址分配用户通道(就像netty TCP服务器一样) 默认情况下,分配的通道永远...import io.netty.channel.ChannelFactory; import io.netty.channel.Ch

    第九章:引导Netty应用程序.pdf

    3. 指定通道类型:`channel(Class)` 或 `channelFactory(ChannelFactory)` 4. 设置本地地址:`localAddress(SocketAddress)`,如服务器监听的端口 5. 设置通道选项:`option(ChannelOption, T)`,用于定制通道的行为...

Global site tag (gtag.js) - Google Analytics