xiaopeng187
去旅行吧
2014-04-29 08:51
浏览 386
已采纳

mina2多线程疑问

在mina2中，如果在代码中使用了dfcb.addLast("executor", new ExecutorFilter(Executors.newCachedThreadPool()));拦截器，并且开了很多的客户端测试，发现后台的pool-3-thread线程会很多，有时候这个线程过多会出现内存溢出了说不能创建新的线程，最后会把客户端关闭了一部分或者自己停了;如果不加这个拦截器发现后天的NioProcessor会随着时间的增加阻塞总数也不断变大，不知道最后会不会回崩掉？mina2的线程到底该如何设置啊，网上也看了很多资料也了解了上面两种方式配与不配的区别。说一下我的业务：1、接收客户端数据，2、解析数据3、数据入库
  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 邀请回答

2条回答 默认 最新

  • scriptguy
    scriptguy 2014-04-29 09:10
    已采纳

    回答一下问题：
    如果不加这个拦截器发现后天的NioProcessor会随着时间的增加阻塞总数也不断变大，不知道最后会不会回崩掉？

    不加拦截器的话，接收客户端数据与业务处理均在IoProcessor引用的线程池里处理，可能会产生阻塞，客户端延迟严重，最终会导致工作队列不断累积，内存不断增长

    解决办法：

    通用的做法是修改dfcb.addLast("executor", new ExecutorFilter(Executors.newCachedThreadPool()));

    将cachedThreadPool修改为有上限的线程池，防止线程无限增长。

    点赞 评论
  • weixin_42697030
    weixin_42697030 2014-05-01 12:20

    1、首先将Executors.newCachedThreadPool()替换为自定义的ThreadPoolExecutor
    设置合理的核心线程数、线程总数、采用定长阻塞容器、设置失败策略

    2、解决接收和处理能力不匹配问题，主要是你接收速度快，处理速度慢，这个是和你业务有关系的，所以还要从业务上优化下

    点赞 评论
提交

相关推荐

  • mina2多线程疑问
    2014-04-29 08:51
    回答 2 已采纳 回答一下问题： 如果不加这个拦截器发现后天的NioProcessor会随着时间的增加阻塞总数也不断变大，不知道最后会不会回崩掉？ 不加拦截器的话，接收客户端数据与业务处理均在IoProcess
  • log4j日志存入数据库的多线程并发问题
    2015-01-08 08:30
    回答 3 已采纳 数据库可以共享同一个连接，然后你写入数据库，由数据库自己来做数据并发处理
  • mina疑问，请各位大神帮忙
    2011-07-08 14:04
    回答 3 已采纳 长连接就是只要客户端程序不退出，连接不出异常，你就一直用同一个连接发送数据，不要每次发送都去创建新的连接。 如果用短连接的话，通常客户端都会有一个连接池用于复用这些连接。例如JDK的HTTP支持
  • mina心跳的实现和业务逻辑之间的问题 java
    2016-04-01 07:28
    回答 1 已采纳 心跳包内容是固定的啊。在解码完成后，可以判断出来了。 我记得可以添加心跳类，里面有判断吧。 ``` KeepAliveMessageFactory heartBeatFactory = n
  • 关于Mina中服务器给客户端发送数据的问题
    2012-04-11 11:39
    回答 1 已采纳 Runnable不能直接调用run()，应该调用start()
  • 关于Mina中Processor线程池的数量的问题
    2010-04-11 18:00
    回答 1 已采纳 感觉上有点像骆驼上压最后一根稻草，可能是为了最低限度确保cpu能够完全利用起来。 线程太多存在资源互斥等开销，太少又无法完全利用系统性能。
  • android利用mina框架保持长连接通信 android
    2015-02-03 07:43
    回答 3 已采纳 做过类似的功能，正准备整合成框架发布到Github一直没时间。 思路对的，推荐建立连接的方法放在service中，然后如何和服务端保持连接是个很重要的问题，因为移动端是会进入休眠状态的，需要定时唤醒
  • mina netty
    2011-11-14 15:21
    回答 1 已采纳 两种不同的通信框架使用上略有区别。可以尝试在Context的附件方法中使用。 [code="java"] @Override public void channelClosed(Channel
  • Mina 过滤器的问题？
    2011-09-01 20:44
    回答 1 已采纳 既然你知道你的消息是以‘\0’结尾的，那里只需要在构造TextLineCodecFactory时指定这个标识就好了啊，而且TextLineCodecFactory也提供了这个接口： [code="j
  • 线程池实现socket 通信问题，不能长时间运行。
    2012-05-08 17:54
    回答 5 已采纳 哦，我不是很清楚 MINA的实现，Netty里，是用线程池模型的，可以控制生成线程的上限。 Mina里如果找不到控制线程数的地方，我建议还是用Netty吧。 至少Netty算是公司在维护 :