如何在取消部署之前停止消息处理？

Question

给定：

• JMS 消息队列。
• 定时器服务定期将消息（从数据库）放入该队列。
• 从队列读取的 JEE6 消息驱动 bean。
• 计时器服务和消息驱动 bean 是不同部署单元的一部分。

问题：

只要消息正在处理中，就无法在不破坏工作流状态的情况下取消部署消息驱动 Bean。因此，我们首先停止计时器服务并等待所有消息完成。

有没有办法使这种行为自动化？或者如果计时器服务仍在运行，是否可以防止取消部署？我们目前使用的是 JBoss 4.2.3。

非解决方案：

• 重构部署单元，因为这会涉及多个部门。
• 我知道系统崩溃不会被涵盖，并且防弹解决方案应该包括恢复策略。

Answer 1

每个部署的 MDB 都有一个 JMX 管理接口 MBean。此 MBean 的 ObjectName 根据部署的不同而有所不同（并且 JBoss 版本之间也可能有所不同）。我使用的是 JBoss 4.3，ObjectName 格式为：

Domain Name:    jboss.j2ee
service:    EJB3
name:   <MDB Name>
ear:    <EAR Name>  (if applicable)
jar:    <JAR Name>

如果您的计时器服务是 JBoss ServiceMBean，您可以使用 JBoss 让您的 MDB 依赖 于计时器@Depends("定时器服务ObjectName")注释。这将强制计时器服务在 MDB 启动之前启动（因此最好让计时器服务有一些启动后延迟），但更重要的是，我相信在取消部署时会发生相反的情况，并且计时器服务应该首先停止，然后是 MDB。

如果有效，它会负责排序，但我认为您不能强制 MDB 在计时器运行时不取消部署。您的应用程序的详细信息可能不支持这一点，但您可能考虑解决此问题的一种方法是使用 JBoss Quartz JCA Inflow Adapter 本质上将定时器和消息处理器绑定到一个（它就像一个 MDB，但它接收定时器事件而不是消息），让您摆脱解决两个组件之间的依赖关系。

=================================
尝试#2
================================

好的，所以您想防止 MDB 在馈送队列有深度时停止大于零。这种方法应该适合您，尽管它是针对 JBoss 的。

1. 实现一个 JMX NotificationListener 来侦听状态更改MDB 委托 MBean。
2. 您还可以实现 JMX NotificationFilter 来缩小范围您想收听的特定事件。
3. 您要查找的状态更改位于属性 State 上，您要查找的转换是 3 --> 1（已启动 --> 正在停止）
4. [此版本] JBoss 中的 JMX 通知是同步发出的，并且会阻塞，直到通知侦听器返回。当您的侦听器收到此通知时，在 MDB 的馈送队列 MBean 上启动轮询循环（没有询问您是否正在使用 JBoss Messaging，但我假设您正在使用）。而 MessageCount 为 > 0，你继续轮询。当队列的消息计数为零时，侦听器返回并且 MDB 将停止。
5. 确保在轮询循环中添加短暂的睡眠，以及轮询超时（以防事情变得异常）。
6. 您还可以考虑在至少 n 个轮询循环中消息计数为 0 之前不返回，以防传输中存在一些未提交的消息，这些消息可能不会显示在消息计数中。

最重要的是，当您的属性更改侦听器被调用时，消息将继续被处理。当属性更改侦听器返回时，MDB 停止将继续。

如果您的 JMS 实现是本地 VM 内 JBoss Messaging，则队列消息计数将在队列的管理 MBean 中可用。对于任何其他设置，您可能需要进行专有的 JMS API 调用来获取队列的消息计数，或者使用更强力的方法，您可以简单地请求 JMS QueueBrowser 并计算消息数。