3

我已经在我通过 JNDI 查找的实体 bean 上配置了工作管理器。更改背后的想法是对一些验证进行多线程处理，因为这可能很耗时，但这需要访问当前事务。

根据我的测试，似乎无法在工作线程中访问事务。我非常想在我的工作线程中访问事务 - 我可以这样做吗？

我希望做与此ExecutionContext类似的事情，其中​​在安排工作时传递 XID 对象，这意味着它继承了当前事务。WebLogic 支持吗？

这就是我所做的：

我已将工作管理器定义添加到weblogic-ejb-jar.xml如下：

  <work-manager>
    <name>wm/EJBWorkManager</name>
    <min-threads-constraint>
      <name>EJBWorkManager_MinThreadCount</name>
      <count>5</count>
    </min-threads-constraint>
  </work-manager>

在 bean 定义中添加了参考ejb-jar.xml

  <resource-ref>
    <description>Work Manager allows multi-threading of defined units of work.</description>
    <res-ref-name>wm/EJBWorkManager</res-ref-name>
    <res-type>commonj.work.WorkManager</res-type>
    <res-auth>Container</res-auth>
  </resource-ref>

然后在我的代码中，我查找了工作管理器并安排了一些工作来执行。

weblogic.transaction.Transaction tx = ( weblogic.transaction.Transaction ) weblogic.transaction.TransactionHelper.getTransactionHelper().getTransaction();
log.info( tx != null ? tx.getXid().toString() : "No Transaction" );
try {
  InitialContext initialContext = new InitialContext();
  WorkManager workManager = ( WorkManager ) initialContext.lookup( "java:comp/env/wm/EJBWorkManager" );
  List<WorkItem> workItems = new ArrayList<WorkItem>(); 
  for ( int i = 0; i < 2; i++ ) {
    Work work = new Work() {
      public void run() {
        weblogic.transaction.Transaction tx = ( weblogic.transaction.Transaction ) weblogic.transaction.TransactionHelper.getTransactionHelper().getTransaction();
        log.info( tx != null ? tx.getXid().toString() : "No Transaction" );
      }
      public boolean isDaemon() {
        return false;
      }
      public void release() {
      }
    };
    workItems.add( workManager.schedule( work ) );
  }
  workManager.waitForAll( workItems, WorkManager.INDEFINITE );
} catch ( NamingException e ) {
  throw new RemoteException( "Error", e );
} catch ( IllegalArgumentException e ) {
  throw new RemoteException( "Error", e );
} catch ( InterruptedException e ) {
  throw new RemoteException( "Error", e );
} catch ( WorkException e ) {
  throw new RemoteException( "Error", e );
}

我得到的输出如下所示，表明事务在生成的线程中不可用。是否可以将此事务共享到工作线程中？我认为他们已经将其作为 JCA 1.5 (JSR 112) 的一部分。

16 [[ACTIVE] ExecuteThread: '1' for queue: 'weblogic.kernel.Default (self-tuning)'] INFO com.tracegroup.isys.weblogic.beans.session.SimpleEJB - BEA1-0474BACB4707C088B359
16 [[STANDBY] ExecuteThread: '10' for queue: 'weblogic.kernel.Default (self-tuning)'] INFO com.tracegroup.isys.weblogic.beans.session.SimpleEJB - No Transaction
16 [[STANDBY] ExecuteThread: '10' for queue: 'weblogic.kernel.Default (self-tuning)'] INFO com.tracegroup.isys.weblogic.beans.session.SimpleEJB - No Transaction

编辑：我也尝试过使用 weblogic.connector.work.WorkManager 和 javax.resource.spi.work.WorkManager，但是在执行 JNDI 查找时这些都没有返回。这些似乎确实允许将 ExecutionContext 传递给工作管理器，从而允许给出 XID。我对这些类的初始测试似乎不起作用。也许我错过了什么？

4

1 回答 1

3

来自 Oracle 支持电话的官方消息：

不可能/不支持。JTA 有一个单线程模型。

单个事务中可能涉及多个线程的一种情况是调用远程服务器。远程服务器被登记为子协调器。即便如此，整个控制流都是单线程的，因此将此模型扩展到本地线程池不会给您带来任何好处。

于 2012-12-06T15:51:34.907 回答