0

我有一个方法 loadDatabase()。该方法本身非常有效。

当我创建一个单独的线程并调用方法 loadDatabase() 时，我得到如下所示的错误。在主线程上它工作正常。

有任何想法吗？注意：值 causecode、eventid 和 description 不为空，因为我已将它们打印到屏幕上。

错误

15:59:58,693 INFO  [stdout] (Thread-64) Importing EcentCauseSheet
15:59:58,694 INFO  [stdout] (Thread-64) Cause Code is 0
15:59:58,694 INFO  [stdout] (Thread-64) Event Id  4097
15:59:58,695 INFO  [stdout] (Thread-64) Description is RRC CONN SETUP-SUCCESS
15:59:58,703 ERROR [stderr] (Thread-64) Exception in thread "Thread-64" java.lang.NullPointerException
15:59:58,704 ERROR [stderr] (Thread-64)     at com.testapp.service.EntryConfig.loadDatabase(EntryConfig.java:131)
15:59:58,704 ERROR [stderr] (Thread-64)     at com.testapp.service.EntryConfig.HelloWorld(EntryConfig.java:48)
15:59:58,704 ERROR [stderr] (Thread-64)     at com.testapp.service.EntryConfig.run(EntryConfig.java:39)

类的 Java 代码

@Stateful
@LocalBean
public class EntryConfig extends Thread implements TableDao {

    @Inject
    private EntityManager em;
//.......

线程的Java代码

@Override
       public void run()
       {
        HelloWorld();

       }

公共无效HelloWorld（）{

    try {
        loadDatabase();         

    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

}

loadDatabase() 的 Java 代码

public void loadDatabase()
    {
        InputStream inp = null;
        System.out.println("Eureka Kind of .....");
        try {   
            inp = new FileInputStream("/home/ubuntu/Downloads/test.xls");  

        } catch (Exception ex) {
        } finally {
            try {
                wb = WorkbookFactory.create(inp);
            } catch (InvalidFormatException e) {

                e.printStackTrace();
            } catch (IOException e) {

                e.printStackTrace();
            }

            Sheet eventCauseTableSheet = wb.getSheetAt(1);

            for (int i = 1; i <= eventCauseTableSheet.getLastRowNum(); i++) {
                System.out.println("Importing EcentCauseSheet");

                row = eventCauseTableSheet.getRow(i);                                       
                int causeCode = (int)(row.getCell(0).getNumericCellValue());                                         
                int eventId = (int)(row.getCell(1).getNumericCellValue());                      
                String description = row.getCell(2).toString();

                System.out.println("Cause Code is " + causeCode);
                System.out.println("Event Id  " + eventId);             
                System.out.println("Description is " + description);

                EventCauseTable eventCauseTable = new EventCauseTable(causeCode,eventId,description);               
                em.persist(eventCauseTable);
                System.out.println("Persisted EventCauseSheet row" + (i+1));

            }

//............
4

1 回答 1

0

在有状态 EJB 中扩展线程通常不是一个好主意，因为它可能随时被容器钝化。您还可以考虑集群和 SFSB 复制——您的 EJB 可能被序列化到另一台机器上，而 Thread 并不真正适用于此（它不是Serializable）。

如果在 em.persists(...) 处抛出 NullPointerException，则您缺少“em”引用。最有可能的是，您尝试将 EntityManager @Inject 注入到不受容器管理的 EntryConfig 实例中。如果您想在容器之外重用此类，则需要手动设置 EntityManager（第一部分仍然适用 - 您可能应该重新设计整个组件）。

于 2013-03-24T19:24:14.230 回答