2

非同期メソッドを含むステートレス 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 ソケット タイムアウトにより、クライアントは、termination.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 アノテーションには構成オプションがありません。

私の質問は、クライアントサーバー通信ソケットのタイムアウトをどのように増やすことができるか、そして非同期メソッドの呼び出し中に確立された接続に対してのみ可能な場合です。

ありがとう、トーマス

4

1 に答える 1

1

Nayan Wadekar によって投稿されたリンクは、正しい方向を示しています。JBoss AS でソケットを管理するコンポーネントはJBoss リモーティングです。これは、接続するトランスポートに適した呼び出しハンドラを呼び出すためのいわゆるコネクタを提供します。

EJB メソッド呼び出しの場合、担当のコネクターは DefaultEjb3Connector のように見えます。そのパラメーターは deploy フォルダー内のファイル 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 のみに適合したコネクタを追加することが実際に可能かどうかはわかりません。

于 2012-01-06T17:33:33.330 に答える