JBOSS EAP 6阻止在异步方法之后调用ejb方法

Question

我有一个无状态bean，它使用其他bean的异步方法插入一些数据（本地注入）。此数据插入需要一段时间，所以我不等待完成此操作。在此数据插入之后，我将调用相同bean的另一个方法。当我将调试点放置到方法时，server大约要等待90秒才能到达此点。可能是Jboss为异步方法等待事务完成。我不知道是怎么回事。.

   @Stateless
public class SimulationNodePersistenceBean implements SimulationNodePersistenceRemote, SimulationNodePersistenceLocal {
    @Resource
    SessionContext context;

    @EJB
    private SimulationResultGraphPersitenceBean graphPersistenceBean;

   @Asynchronous
   @TransactionAttribute(TransactionAttributeType.REQUIRED)
   private void addResultGraphsToDatabase(long id, Graph[] graphList) {

    ResultGraph paramGraph;
    ResultGraphPoint dataPoint;
    Graph graph;
    for (int i = 0; i < graphList.length; i++) {
        graph = graphList[i];
        paramGraph = new ResultGraph();

        try {
            graphPersistenceBean.persistGraph(paramGraph);
        } catch (Exception databaseException) {
            // TODO add error message to the contingency simulation messages
            // list
            logger.error("Error saving  ResultGraph:" + paramGraph);
        }
    }
    long duration = System.nanoTime() - startTime;
    logger.debug("Graphs inserted to DB in (sec) :" + (duration / NANO_SECOND_CONVERSION_FACTOR));
}

    // @Asynchronous
public void persistSimulationResults(long contingencySimulationId, Graph[] graphList,
        List<AB> reiList) {
    if (graphList != null) {
        addResultGraphsToDatabase(contingencySimulationId, graphList);
    }
    if (reiList != null) {
    //another method
    }
    calculateContSimStability(contingencySimulationId);
}

    @Override
public void calculateSimIndex(long id) {

} 

 @Stateless
public class SimulationResultGraphPersitenceBean {
    @PersistenceContext(unitName = "DBService")
    private EntityManager em;

    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    @Asynchronous
    public void persistGraph(ResultGraph graph) throws SiGuardPersistenceException {
        try {
            ResultGraphService service = new ResultGraphService(em);
            service.create(graph);
            em.flush();
        } catch (Exception ex) {
            throw new PersistenceException("Error persisting graph", ex);
        }
    }

    getSimulationEJB().persistSimulationResults(id, tsaParser.getLstFile().getGraphArray());

getSimulationEJB().calculateSimIndex(contSimId);

我已经使用JStack创建了一个线程转储。实际上，我在Jboss As 6中没有这个问题。我将我的应用程序迁移到Jboss EAP6。4.可能是我需要在配置中做一些配置更改。但我不知道该怎么办。

我检查了线程转储。我没有发现任何处于阻塞状态的线程。我应该寻找其他关键词吗？

Answer 1

正如我在注释中已经指出的，您正在混合调用异步方法和同步方法。在您的示例中，从persistSimulationResults方法（synch方法）调用addResultGraphsToDatabase方法（Asynch方法），因为您已经注释掉了上面的异步注释）。因此，现在addResultGraphsToDatabase方法的行为就像一个同步方法，尽管有异步注释。

我不确定您是否查看了我在注释中发布的链接，但您需要使用SessionContext调用异步方法。类似于这样：

在班级层面：

@Inject
SessionContext ctx;

在persistSimulationResults方法中：

ctx.addResultGraphsToDatabase

关于更详细的例子，请看一下我在评论中发布的链接。