长时间运行的Web服务架构

Question

我们使用 axis2 来构建 Web 服务，并使用 Jboss 服务器来运行所有应用程序的逻辑。我们被要求构建一个与 Bean 对话的 Web 服务，该 Bean 可能需要长达 1 小时才能响应（取决于请求的大小），因此我们无法在这段时间内保持与消费者的连接打开。

我们可以使用异步 Web 服务，但效果还不是很好，因此我们决定可以实现一个 bean，该 bean 将执行 Web 服务背后的逻辑，并让服务异步调用该 bean。 Web 服务将生成一个令牌，该令牌将传递给消费者，消费者可以使用它来查询请求的状态。

我的问题是：

1. 一旦我从创建该 bean 的服务中的方法返回，如何查询 Jboss 服务器上该 bean 的状态。我需要使用有状态 Bean 吗？
2. 如果我想从 Web 服务端进行异步调用，我可以使用有状态 Bean 吗？

Answer 1

您可以采取的另一种方法是使用 JMS 和数据库。

该过程将是：

1. 在 Web 服务调用中，将消息放入 JMS 队列中
2. 将记录插入数据库表中，并将该记录的唯一 id 返回给客户端
3. 在侦听队列的 MDB 中，调用 bean
4. 当 bean返回，用“完成”状态更新数据库记录
5. 当客户端调用状态时，读取数据库记录，根据记录返回“未完成”或“完成”。
6. 当客户端调用并且记录显示“Done”时，返回“Done”并删除记录

此过程对资源使用量较大，但有一些优点

• 如果您的 bean 方法抛出异常，持久 JMS 队列将重新交付
• 持久 JMS如果服务器重新启动，队列将重新传送
• 通过使用数据库表而不是某些静态数据，您可以支持集群或负载平衡环境

Answer 2

我不认为有状态会话 bean 是您问题的答案，它们是为长时间运行的会话会话而设计的，这不是您的场景。

我的建议是使用 Java5 风格 ExecutorService 线程池，使用 Executors工厂类：

1. 当Web服务服务器初始化时，创建一个ExecutorService实例。
2. Web 服务调用进来，处理程序创建 可调用。 Callable.call() 方法将以任何形式对业务逻辑 bean 进行实际调用。
3. 此 Callable 被传递给 ExecutorService.submit()，后者立即返回表示调用最终结果的 Future 对象。 Executor 将开始在单独的线程中调用您的 Callable。
4. 生成一个随机令牌，将 Future 存储在 Map 中，并以令牌作为密钥。
5. 将令牌返回给 Web 服务客户端（步骤 1 到 4 应该立即发生）
6. 稍后，Web 服务客户端再次调用请求结果，并传入令牌。
7. 服务器使用以下命令查找 Future：令牌，并在 Future 上调用 get()，并设置超时值，以便它只等待很短的时间来获取答案。 get() 调用将返回任何 Callable 调用的执行结果。
   • 如果答案可用，请将其返回给客户端，并从“Map”中删除Future。
   • 否则，请告诉客户稍后再来。

这是一个非常稳健的方法。如果您愿意，您甚至可以配置 ExecutorService 来限制可以同时执行的调用数量。