最近用flash + java做一个实时应用,
服务器端用mina2.0.4作为通讯框架,
封装了自己的消息格式,采用byte流的方式进行交互,
在测试过程中,并发量50以下正常运行,
在超过100时,服务器无法正常发送消息,问题描述如下:
以调试模式启动服务器,
此时停止所有客户端,
1,重新连接一个新的客户端,服务端能在sessionOpen中捕获并处理客户连接;
2,服务器只有第一条消息被发出,
跟踪filter,编码解码都正常,
ExecutorFilter的messageReceived成功将解码消息压入tasksQueue,
此时客户端收到第一条消息;
3,当客户端下一个消息到达时,
ExecutorFilter的messageReceived成功将解码消息压入tasksQueue,
但是IoHandler没有触发messageReceived,
在对应的SessionTasksQueue中,可以看到第一条已发送的消息并没有被删除(仍然存在此queue中!),
此后所有此客户端的收发消息都没有正常处理,而线程池并没有run out,也没有检测到线程被挂起,
我使用的是OrderedThreadPoolExecutor,
// 编码解码
chain.addLast("codec", new ProtocolCodecFilter(new FireProtocolCodecFactory()));
// 业务线程
executor = new OrderedThreadPoolExecutor(100, 1000,
5, TimeUnit.SECONDS, Executors.defaultThreadFactory(), null);
chain.addLast("threadPool", new ExecutorFilter(executor));
4,打开minadebug,关键log如下:
正常:
2013-02-18 15:11:53,282 - Adding event SESSION_OPENED to session 2
Queue : [SESSION_OPENED, ]
2013-02-18 15:11:53,316 - Adding event MESSAGE_SENT to session
Queue : [MESSAGE_SENT, ]
2013-02-18 15:11:53,318 - Adding event MESSAGE_SENT to session 2
Queue : [MESSAGE_SENT, , MESSAGE_SENT, ]
2013-02-18 15:12:03,361 - Adding event MESSAGE_RECEIVED to session 2
Queue : [MESSAGE_RECEIVED, ]
异常:
2013-02-18 15:09:03,055 - Adding event SESSION_OPENED to session 114
Queue : [SESSION_OPENED, ]
2013-02-18 15:09:03,056 - Adding event MESSAGE_SENT to session 114
Queue : [MESSAGE_SENT, ]
2013-02-18 15:09:03,056 - Adding event MESSAGE_SENT to session 114
Queue : [MESSAGE_SENT, , MESSAGE_SENT, ]
2013-02-18 15:09:13,113 - Adding event MESSAGE_RECEIVED to session 114
Queue : [MESSAGE_SENT, , MESSAGE_SENT, , MESSAGE_RECEIVED, ]
求指教和探讨,问题如有描述不清晰请指明,谢谢
分享到:
相关推荐
一款基于机器学习的Web日志统计分析与异常检测命令行工具_hy4
基于RBAC权限控制的资产管理系统_hy5
318 Series Hardened Access Points 370 Series Outdoor Access Points 310 Series Campus Access Points IAP-315 IAP-314
最强PMP备考计划、知识整理、试题,并以本系统来展示_hy5
【官方】计算机职业英语一级考试样卷.pdf 【官方】全国机等级考试二级笔试样卷:存取(Access)数据库程序设计.pdf 【官方】全国计算机等级考试二级笔试样卷:C++语言程序设计.pdf 【官方】全国计算机等级考试二级笔试样卷:C语言程序设计.pdf 【官方】全国机等级考试二级笔试样卷:德尔菲(Delphi)语言程序设计.pdf 【官方】全国机等级考试二级笔试样卷:Java语言程序设计.pdf 【官方】全国机等级考试二级笔试样卷:视觉基础语言程序设计.pdf 【官方】全国机等级考试二级笔试样卷:视讯FoxPro数据库程序设计.pdf 【官方】全国计算机等级考试三级笔试样卷:PC技术,pdf 【官方】全国计算机等级考试三级笔试样卷:网络技术.pdf 【官方】全国计算机等级考试三级笔试样卷:信息管理技术,pdf 【官方】全国计算机等级考试四级笔试样卷:软件测试工程师.pdf 【官方】全国计算机等级考试四级笔试样卷:数据库工程师,pdf 【官方】全国计算机等级考试四级笔试样卷:数据库技术,pdf 【官方】全国计算机等级考试四级笔试样卷:网络工程师.pdf
SpringBoot网上商城#java#毕业设计#网上商城#springboot#课程设计#编程#thymeleaf_hy4
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
360 Series Outdoor Access Points 303 Series Campus Access Points 303H Series Hospitality Access Points 300 Series Campus Access Points
肽质量指纹图谱提取区域检测系统源码分享[一条龙教学YOLOV8标注好的数据集一键训练_70+全套改进创新点发刊_Web前端展示]
分布式事务实战_hy4
python网络爬虫按月爬cctv新闻30分的视频_hy4
【golang】企业微信群机器人接口Golang封装
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。
mumu-activemq是一个对老牌mq消息中间件的学习和测试项目,本人通过这个项目来熟悉activemq的消息发送流_hy4
【Python+HTML】基于flask的rbac学生权限管理系统,redis存储session_pgj
一步一步学springboot2:微服务项目实战(第二版)_hy5
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。
新建 DOC 文档.doc
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。