J2EE - 实现持续运行的组件/守护进程

Question

我正在设计一个服务器应用程序，它应该连续处理大量数据并使用 Web 界面按需呈现结果。

操作方案大致如下：

1. 电子传感器阵列通过 USB 不断将数据溢出到 ramdisk
2. 一个“flusher”应用程序尽可能快地处理数据并将其加载到 db（暂存区）中
3. 使用触发器，db 对数据执行计算并存储结果在另一个模式（数据区域）
4. 客户端 web 应用程序可以根据需要在图形/报告等中显示已处理的数据

该解决方案理想情况下如下所示：

1. 数据库服务器 - PostgreSQL
2. 有一个管理 Web 界面，可以监视刷新器（即每个处理的记录）小时或类似的东西），如果作为单独的守护进程实现，则控制它。
3. 用 Java 编写的 Flusher 和客户端应用程序，最好使用 J2EE

现在，这个问题一直困扰着我，而且我找不到答案：如何编写 Flusher 组件，即在 J2EE 中不断在后台运行的进程。

通过搜索网络，基本上出现了三种可能性：

a) 将冲刷器编写为消息驱动 bean 并使用 JMS 从主应用程序控制它。但是：我不喜欢让 MDB 持续运行的想法，我什至不确定这是否可能

b) 将刷新器编写为 EJB 并使用计时器/调度服务控制它。然而：这些事件并不是真正定时的，它只需要无限循环运行，直到被告知不要这样做，这似乎是对该技术的错误使用。

c) 将冲刷器编写为单独的 java 应用程序，将其作为操作系统服务（Linux 或 Windows）运行，并通过从 EJB 调用的 ProcessBuilder 使用启动脚本进行控制。要监视其状态，请使用 JMS。然而：在我看来，这似乎是过于复杂的解决方案，依赖于平台，甚至可能不可靠，并且 EJB 不应该生成/管理它自己的线程，而 ProcessBuilder 基本上就是这样做的，这似乎是错误的。

基本上，这些对我来说都不合适，我无法弄清楚，在 Java/J2EE 世界中什么是正确的解决方案。

谢谢 托马斯

Answer 1

我会将“Flusher”应用程序编写为独立的 Java 进程。也许可以使用诸如 Java Service Wrapper 之类的东西将其转变为适用于您的操作系统的服务。我不太熟悉通过 Java 与 RAM 磁盘交互的选项，但是您要么最终得到一个 InputStream，您可以在进程的整个生命周期中保持打开状态并不断读取，要么您将在 while 循环内不断轮询。执行如下操作是完全可以的：

private volotile boolean stopFlag;

...

while(!stopFlag) {
  processNextInput();
}

然后，当您想要终止进程时，另一个线程中将有一些其他机制可以将 stopFlag 设置为 true。

至于监控冲洗器 JMX 似乎是一个很好的解决方案。这正是它的目的。您将创建一个 MBean，它将公开您想要的任何类型的状态或统计信息，然后其他进程可以连接到该 MBean 并查询该数据。

“客户端”应用程序将是一个简单的 servlet 应用程序，它对您的数据库进行报告，并为您的刷新器中的 MBean 提供一个漂亮的前端。或者，您可以只使用 JMX 控制台监控刷新器，甚至不需要让客户端参与系统的该部分。

我认为 EJB 对于这个系统来说并没有真正的意义。我对 EJB 有一定的偏见，因此请对我的建议持保留态度，但对我来说，我并不认为此应用程序需要它们。