在不使用线程的情况下处理 EJB3 中的超时

Question

我有以下情况。我有一个工作：

• 在给定的时间后可能超时，如果发生需要抛出异常
• 如果没有超时，将返回结果
• 如果此工作返回结果，则必须尽快返回有可能，因为性能是一个很大的问题。因此，异步解决方案是不可行的，并且自然地通过锤击来捆绑系统也不是一种选择。
• 最后，系统必须符合 EJB 标准，因此据我所知，使用普通线程不是一个选择，因为这是严格禁止的。

我们当前的解决方案使用一个线程，该线程在存在一定时间后不会被外部进程中断，会抛出异常，但是由于这显然违反了 EJB 标准，因此我们正在尝试通过其他方式来解决它。

有什么想法吗？

编辑添加：当然，超时的作业也需要删除（或中断）。

编辑添加2： 这个问题似乎没有任何解决方案，因为按照纯 EJB3 标准检测死锁似乎几乎是不可能的。由于 Enno Shioji 下面的评论反映了这一点，因此我将他的建议设置为正确答案。

Answer 1

这更像是一个澄清请求，但它太长了，不适合作为评论。

我不确定你现在是怎么做的，因为从你写的内容来看，只使用请求处理线程似乎就是这样去。像这样：

//Some webservice method (synchronous)
public Result process(Blah blah){
    try{
        return getResult(TimeUnit.SECONDS, 10);
    }catch(InterruptedException e){
        //No result within 10 seconds!
        throw new ServiceUnavailableException("blah");
    }
}

我根本不知道你为什么要创建线程。如果由于 getResult 方法根本不会超时而被迫使用线程，则会出现线程泄漏。如果它在较长时间后超时，因此您想“快捷”地回复用户，这将是我考虑使用线程的唯一情况，就像我想象的那样使用它。这可能会导致线程在负载下堆积，我会努力避免这种情况。

也许您可以发布一些代码，让我们知道您为什么要在服务中进行创建？

另外，你的客户端界面是什么？听起来像是同步网络服务之类的？

---

In that case, if I were you I would use a HashedWheelTimer as a singleton... this mechanism should work great with your requirement (here is an implementation). However, this unfortunately seem to conflict with the ban on threading AND the ban on singleton in the EJB spec. In reality though there really isn't a problem if you would do this. See this discussion for example. We have also used the singleton pattern in our EJB app. which used JBoss. However, if this isn't a viable choice then I might look at isolating the processing in its own JVM by defining a new web service (and deploy it in a web-container or something), and call that service from the EJB app. This would however obviously incur performance hit and now you would have another whole new app.

Answer 2

使用 Bean Managed Transaction，可以使用 UserTransaction 接口指定特定事务的超时。

修改超时值
与已启动的交易相关
由当前线程开始
方法。

void setTransactionTimeout(int seconds) throws SystemException

• 事务将在指定秒数后超时可能无法进一步传播。如果没有隐式抛出异常，则可以根据结果显式抛出异常。
• 在指定时间内成功完成将返回结果。
• 可以将其与无状态会话 bean 一起使用，因此可能不会出现性能问题。
• 它的 EJB 标准因此实施起来不会有问题。

通过一些解决方案，它应该可以在给定的场景中正常工作。

编辑： 还可以使用服务器特定属性来管理事务超时。

JBoss：可以在类或方法级别应用注释@TransactionTimeout(100)。

Weblogic：在 weblogic-ejb-jar.xml 中指定参数

<transaction-descriptor>
     <trans-timeout-seconds>100</trans-timeout-seconds> 
</transaction-descriptor>

GlassFish：在 sun- 中使用可选的 cmt-timeout-in-seconds 元素ejb-jar.xml

Answer 3

将进程及其超时线程放入使用 @WebService 注释的类中，将该类放入 WAR 中，然后从 EJB 调用 WebService。

WAR 没有与 EJB 相同的限制或存在于相同的契约下，因此它们可以安全地运行线程。

是的，我认为这是一个“黑客”，但它满足了要求，而且是可移植的。

Answer 4

您可以使用 commonj WorkManager 创建线程。 WebSphere 和 Weblogic，因为他们提出了该标准，但您也可以找到其他应用程序服务器的实现。

基本上，WorkManager 允许您在容器内创建托管线程，就像在常规 Java 中使用 Executor 一样。您唯一的其他选择是使用 MDB，但这将是一个“更重”的解决方案。

由于我不知道您的实际平台，因此您必须自己在 google commonj 上搜索您的平台 8-)

这是一个 非 IBM或 Oracle 解决方案。

注意：这不是实际标准，但它广泛适用于不同平台，并且应该非常适合您的目的。

Answer 5

对于EJB，有一个“容器管理事务”的概念。通过在 bean 或特定方法上指定 @TransactionAttribute，容器将在调用方法时创建一个事务。如果代码的执行时间超过事务阈值，容器将抛出异常。如果调用在事务阈值以下完成，它将照常返回。您可以在调用代码中捕获异常并进行适当的处​​理。

有关容器管理事务的更多信息，请查看：http://java .sun.com/j2ee/tutorial/1_3-fcs/doc/Transaction3.html 和 http://download.oracle.com/javaee/5/tutorial/doc/bncij .html

Answer 6

您可以使用 @TimeOut。像这样的东西：

@Stateless
public class TimedBean {

  @Resource
  private TimerService timerService;

  static private AtomicInteger counter = new AtomicInteger(0);
  static private Map<Integer, AtomicBoolean> canIRunStore = new ...;

  public void doSomething() {
    Integer myId = counter.getAndIncrement();
    AtomicBoolean canIRun = new AtomicBoolean(true);
    canIRunStore.put(myId, canIRun);

    timerService.createTimer(1000, 0, myId);

    while (canIRun.get() /* && some other condition */) {
      // do my work ... untill timeout ... 
    }
  }

  @Timeout
  @PermitAll
  public void timeout(Timer timer) {
    Integer expiredId = (Integer) timer.getInfo();
    AtomicBoolean canHeRun = canIRunStore.get(expiredId);
    canIRunStore.remove(expiredId);
    canHeRun.set(false);
  }
}