小编hic*_*our的帖子

用Java调度系统设计的消息

我正在为以下用例寻找轻量级和高效的解决方案:

  • 网关模块接收为不同接收者传递的资源.
  • 每个接受者排队的资源(按到达顺序).
  • 清除进程会扫描这些队列,如果资源可用于某些接受者,则他将它们捆绑在某个标记(唯一ID)下,并发送新捆绑可用的通知.

系统特点:

  • 接受者的数量是动态的.
  • 对一个包中的资源数量没有限制.

消息调度系统

该模块将在Java 7(非集群)下的Tomcat 7中使用.

我考虑了以下解决方案:

  1. JMS - 每个接受者的dymanic队列配置,是否可以使用队列中的所有可用消息?每个队列的线程配置(不可扩展)?
  2. AKKA演员.没有找到合适的使用模式.
  3. 朴素的纯Java实现,其中队列将由一个线程(循环)扫描.

我认为这是讨论此问题的可用解决方案的正确位置.请在考虑以下几点时分享您的想法:

  • 合适的第三方框架.
  • 资源队列可扩展扫描.

提前致谢.

java performance multithreading akka

2
推荐指数
1
解决办法
598
查看次数

标签 统计

akka ×1

java ×1

multithreading ×1

performance ×1