在 EJB 环境中是否有类似 .wait() 和 .notify() 的行为？

Question

我知道我不能修改 EJB 容器中的线程，因此我不知道如何在 EJB 环境中以正确的方式执行以下操作：

参与人员：

• 无状态会话 Bean“客户端”
• 无状态会话 Bean“服务器”
• 消息队列“队列”
• 消息驱动 Bean“Mdb”，它处理来自“队列”的消息
• n 无状态会话 Bean W1 到 Wn

场景是：

Client 调用Server 的方法，该方法又向Queue 发送若干消息。之后，Server 会做一些其他的事情。同时，Mdb 消费一条消息，调用 Wi 进行一些相当长的计算，并得到结果。现在Mdb 将结果提供给Server。当 Server 获得它发送的每条消息的所有“结果”时，它会使用 W 的结果进行更多计算，并将结果返回给 Client .

我的问题：

在 Java SE 中，我只需 .wait() 让 Server 在 Server 之后等待 W 的结果发送消息后的工作。然后 mdb 将在设置结果时 .notify() 。由于我不能修改 EJB 容器中的线程，正如规范所述，我迷失了，因为我没有找到任何合适的方法来在 EJB 环境中实现相同的行为。

对于这个问题的任何帮助将不胜感激，在此先感谢。

P.S.：我正在使用 JBoss 5.1.0，以防有任何供应商特定的措施来解决这个问题。

Answer 1

什么对象充当 MDB 返回所有消息的服务器？它可能需要某种 CountDownLatch 来等待，消息数量的大小（由 MDB 更改直到达到零）。当它变为零时，它会唤醒可以运行返回客户端的代码。 请参阅 CountDownLatch 的 API 文档。

Answer 2

对此的适当解决方案是消息传递的“请求/响应”模式。简而言之，您可以通过消息传递系统执行“同步”操作，方法是发送消息并等待响应消息（所有这些在 J2EE 世界中都是合法的）。在实践中，您可以通过多种方式实现此目的，但总体思路是您发送带有某种唯一标识符的请求消息，然后使用为您的请求 ID 设置的消息过滤器等待响应消息发送（这通常是 "correlationId" field 的用途）。 MDB 将获取请求消息，处理它们，并使用请求消息中指定的唯一标识符发送响应消息。你可以用一个队列来完成所有这些，或者你可以使用单独的请求/响应队列，或者你可以做一些疯狂的事情，比如创建"temporary" response queues（每个请求）。您可以使用Message.setJMSReplyTo 方法告诉M​​DB 将请求消息发送到哪里。

一般模式是：

1. 客户端调用服务器
2. 服务器：
   1. 创建消息，设置correlationId 和replyTo
   2. 创建 QueueSender，发送消息
3. mdb（对每条消息重复）：
   1. 收到消息
   2. 处理消息
   3. 发送带有correlationId的响应消息
4. 服务器：
   1. 使用correlationId 创建消息过滤器
   2. 使用消息选择器创建 QueueReceiver
   3. 调用receive()，直到收到并处理所有消息（或超时）
   4. 进行最终处理，响应客户端

（很明显，服务器直接从第2步到第4步，我就是这样写来突出控制流的。）