2012-08-16 62 views
1

您好长时间运行的线程在Postconstruct中启动并定期更新数据库。EJB 3.1中长时间运行的线程异常StartUp singleton postconstruct方法

貌似这个

public void postconstruct() { 
    Runnable runnable; 
    runnable = new Runnable() { 
     @Override 
     public void run() { 
      int interval = poissonRandomNumber(15); 
      while (true) { 
       try { 
        Map<Account, AccountUpdate> recentUpdates = 
          simulator.getRecentUpdates(tickDAO, securityDAO); 
        for (Map.Entry<Account, AccountUpdate> entry : recentUpdates.entrySet()) { 
         Account account = entry.getKey(); 
         //       String realised = getAccountReturn(parts, account); 
         Account accountByName = accountDAO.findAccountByName(account.getName()); 
         if(accountByName == null ) 
         { 
          account.setAccountId(null); 
          accountByName = accountDAO.create(account); 
         } 
         int realised = new Random().nextInt(50); 
         boolean nextBoolean = new Random().nextBoolean(); 
         realised = nextBoolean == true ? realised : -realised; 
         AccountUpdate accountUpdate = entry.getValue(); 
         accountUpdate.setAccountId(accountByName); 
         accountUpdate.setDateCreated(new Date()); 
         accountUpdate.setUnRealisedPL(new BigDecimal(realised)); 
         accountUpdateDAO.create(accountUpdate); 
        } 
        Thread.sleep(interval); 
       } catch (Exception ex) { 
        Logger.getLogger(ApplicationManager.class.getName()).log(Level.SEVERE, null, ex); 
       } 
      } 
     } 
    }; 
    Thread tickThread = new Thread(runnable); 
    tickThread.start(); 

每当我启动我得到很多的例外,因为它看起来像集装箱还没有准备好

我需要知道如何最好地使用DAO的应用程序,以及如何检测所述conytainer是就绪

该异常是如下所示

SEVERE: java.lang.NullPointerException 
at com.sun.ejb.containers.util.pool.NonBlockingPool.returnObject(NonBlockingPool.java:285) 
at com.sun.ejb.containers.StatelessSessionContainer.releaseContext(StatelessSessionContainer.java:602) 
at com.sun.ejb.containers.BaseContainer.postInvoke(BaseContainer.java:2055) 
at com.sun.ejb.containers.BaseContainer.postInvoke(BaseContainer.java:1994) 
at com.sun.ejb.containers.EJBLocalObjectInvocationHandler.invoke(EJBLocalObjectInvocationHandler.java:222) 
at com.sun.ejb.containers.EJBLocalObjectInvocationHandlerDelegate.invoke(EJBLocalObjectInvocationHandlerDelegate.java:89) 
at $Proxy270.create(Unknown Source) 
at ucl.atrade.rnpvms.server.services.ApplicationManager$1.run(ApplicationManager.java:126) 
at java.lang.Thread.run(Thread.java:722) 

SEVERE: javax.ejb.EJBException: Attempt to invoke when container is in Undeployed 
    at com.sun.ejb.containers.BaseContainer.postInvoke(BaseContainer.java:1999) 
    at com.sun.ejb.containers.BaseContainer.postInvoke(BaseContainer.java:1994) 
    at com.sun.ejb.containers.EJBLocalObjectInvocationHandler.invoke(EJBLocalObjectInvocationHandler.java:222) 
    at com.sun.ejb.containers.EJBLocalObjectInvocationHandlerDelegate.invoke(EJBLocalObjectInvocationHandlerDelegate.java:89) 
    at $Proxy265.findSecurityBySymbol(Unknown Source) 
    at ucl.atrade.rnpvms.server.datafeed.AccountUpdateSimulator.getRecentUpdates(AccountUpdateSimulator.java:74) 
    at ucl.atrade.rnpvms.server.services.ApplicationManager$1.run(ApplicationManager.java:108) 
    at java.lang.Thread.run(Thread.java:722) 
+1

http://docs.oracle.com/javaee/6/tutorial/doc/bnboy.html,恕我直言,由JAVA EE中的应用程序代码启动长时间运行的线程是非常糟糕的做法。 – esej 2012-08-16 09:08:58

+0

为什么问题的标题是关于取消部署,问题是关于启动?如果您的EJB需要定期更新,那么为什么不使用EJB定时器,这是管理EJB内部线程的最佳方式(也许是唯一允许的方式)?还请记住在您发布的代码中插入注释/成员实例 – perissf 2012-08-16 09:10:21

+0

我已更新代码以反映完整方法。我无法使用A计时器,因为帐户更新是随机的。 – 2012-08-16 09:24:11

回答

2

在此link作为很好的解释,

EJB规范分配给EJB容器管理线程的责任。允许企业bean实例创建和管理线程会干扰容器控制其组件生命周期的能力。

这意味着在您的EJB中使用Runnable是不可行的。

如果你想运行给定频率的代码,你可以使用Timer Service

如果你需要运行一些代码时更新到数据库做的其他方式,即异步,你必须使用其他技术,如JMS或数据库触发器或持久化上下文共享/传播,或Entity Listeners,取决于您的应用程序的要求。

相关问题