JBoss 6套接字超时等待@Asynchronous方法结果

Question

我有一个无状态的 EJB-3.1 会话 bean，其中包含一个异步方法，该方法执行一些昂贵的处理并向客户端返回一个未来，从而允许它在准备好后显示处理结果：

@Asynchronous
@TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
public Future<String> importModules() {
   String result = doSomeHeavyStuff();
   return new AsyncResult<String>(result);
}

此 bean 在 JBoss 6 实例上运行并从 Swing 客户端远程调用：

final Future<String> termination =
            Proxy.getProxy().getMenfpImportService().importModules();

SwingWorker<String, Object> worker = new SwingWorker<String, Object>() {

    @Override
    protected String doInBackground() {
        /* ... */
        if (termination.isDone()) {
             return termination.get();
        }
        /* ... */
    }

    /* ... */
}

虽然处理通常会成功完成，但有些计算需要超过 300 秒才能完成。

对于这些计算，JBoss 套接字超时会导致客户端在调用 terminate.get() 时收到 ExecutionException 而不是计算结果：

10:26:16,301     INFO Application:1150 - Execution exception during modules import: 
java.util.concurrent.ExecutionException: org.jboss.remoting.InvocationFailureException: Socket timed out.  Waited 300000 milliseconds for response while calling on InvokerLocator [socket://degotte:3873/?timeout=300000]; nested exception is: 
java.net.SocketTimeoutException: Read timed out
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
at java.util.concurrent.FutureTask.get(FutureTask.java:83)
at org.jboss.ejb3.async.spi.AsynchronousClientFuture.get(AsynchronousClientFuture.java:113)
at org.jboss.ejb3.async.impl.util.concurrent.LocalJvmSerializableFutureWrapper.get(LocalJvmSerializableFutureWrapper.java:161)
at lu.lippmann.forminitiale.client.gui.Application$2.doInBackground(Application.java:1137)
at lu.lippmann.forminitiale.client.gui.Application$2.doInBackground(Application.java:1)
at javax.swing.SwingWorker$1.call(SwingWorker.java:277)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at javax.swing.SwingWorker.run(SwingWorker.java:316)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)

很遗憾，@Asynchronous 注解没有提供任何配置选项。

我的问题是如何增加客户端服务器通信套接字的超时时间，以及是否以任何可能的方式仅用于在调用异步方法期间建立的连接。

谢谢， 托马斯

Answer 1

Nayan Wadekar 发布的链接指向了正确的方向。负责管理 JBoss AS 上的套接字的组件是 JBoss remoting，它提供了所谓的连接器来为连接传输调用合适的调用处理程序。

在 EJB 方法调用的情况下，负责的连接器似乎是 DefaultEjb3Connector，其参数可以在部署文件夹中的文件 ejb3-connectors-jboss-beans.xml 中配置，例如在

$JBOSS_HOME/server/default/deploy/ejb3-connectors-jboss-beans.xml

如果使用默认配置文件。

在套接字 URL 被证明有效后提高超时参数。

<bean name="org.jboss.ejb3.RemotingConnector"
class="org.jboss.remoting.transport.Connector">

<property name="invokerLocator">

  <value-factory bean="ServiceBindingManager"
    method="getStringBinding">
    <parameter>
      jboss.remoting:type=Connector,name=DefaultEjb3Connector,handler=ejb3
    </parameter>
    <parameter>
      <null />
    </parameter>
    <!-- <parameter>socket://${hostforurl}:${port}?timeout=300000</parameter> -->
    <parameter>socket://${hostforurl}:${port}?timeout=1200000</parameter>
    <parameter>
      <null />
    </parameter>
    <parameter>3873</parameter>
  </value-factory>

</property>
<property name="serverConfiguration">
  <inject bean="ServerConfiguration" />
</property>

但是，这会提高所有 EJB 方法调用的超时时间。鉴于我已经阅读了有关 JBoss 远程处理概念的内容，我不确定是否实际上可能只为某些会话 bean 添加适配的连接器。