2014-09-29 41 views
0

我正在開發一個用於信息檢索的Web應用程序(使用JSF),我使用Lucene來讀取和索引文件.pdf。我讀了一個關於LockObtainFailedException的前一個問題(LockObtainFailedException at new IndexWriter()),但我仍然無法解決我的問題,所以我將簡要解釋它。LockObtainFailedException和索引器的實例化

我有一個managedBean誰指標用此方法文檔:

 @ManagedBean 
     @RequestScoped 
     public class managedBeanIB{ 


     @EJB 
     private Indexer indexer; 


     private Part file;; 
     private long ISBN; 
     private String author; 
     private String title; 
     private String content; // getter and setter for each field 

     ... 

     public String add() throws IOException{ 


       indexer = new Indexer(); 
       InputStream is = file.getInputStream(); 
       PDDocument doc = PDDocument.load(is); 
       contenuto = new PDFTextStripper().getText(doc); 
       doc.close(); 
       Book book = new Libro(ISBN,author,title,content); 
       indexer.index(book); 
       indexer.close(); 




       return "home"; 

    } 
}//class 

類索引如下:

@Stateless 
public class Indexer implements Serializable { 


private static final String directory = "C:\\Users\\EngineFM\\Documents\\NetBeansProjects\\SIA\\SIA-ejb\\src\\resources\\index\\"; 

    public static final String ENG = "english"; 


    private IndexWriter iw; 

    public Indexer() { 



     try { 
      if (iw == null) { 


       iw = new IndexWriter(FSDirectory.open(new File(directory)), 
         new IndexWriterConfig(Version.LATEST, new EnglishAnalyzer())); 

      } 
     } catch (IOException ex) { 
      System.out.println("something wrong"); 
      ex.printStackTrace(); 

     } 

    } 



    public void index(Book item) throws IOException{ 

     iw.deleteDocuments(new Term(Book.ID, String.valueOf(item.getISBN()))); 



     Document doc = new Document(); 


     doc.add(new LongField(Book.ID, item.getISBN(),Field.Store.YES)); 
     doc.add(new StringField(Book.AUTHOR, item.getAuthor(),Field.Store.YES)); 
     doc.add(new StringField(Book.TITLE, item.getTitle(),Field.Store.YES)); 
     doc.add(new TextField(Libro.CONTENT, item.getContent(),Field.Store.YES)); 



     iw.addDocument(doc); 
     iw.commit(); 

    } 

    public void close() throws IOException { 
     iw.close(); 
    } 

當我開始我的應用程序(主頁),我注意到,索引器實例化,以及我的託管bean。然後,我繼續添加頁面,填寫所需的所有信息,然後單擊「添加文檔」。在這種情況下,索引再次實例化,但以前的鎖仍然是開放的(我猜),所以不存儲在文檔中,我有以下異常:

墓:org.apache.lucene.store.LockObtainFailedException :鎖 獲取超時: NativeFSLock @ C:\ Users \ EngineFM \ Documents \ NetBeansProjects \ SIA \ SIA-ejb \ src \ resources \ index \ write.lock at org.apache.lucene.store.Lock.obtain( Lock.java:89) org.apache.lucene.index.IndexWriter。(IndexWriter.java:755)at pack.Indexer。(Indexer.java:62)at managedBean.managedBeanIB.add(managedBeanIB.java: 107)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native M ethod)在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 在java.lang.reflect.Method.invoke(Method.java :483)at javax.el.E​​LUtil.invokeMethod(ELUtil.java:332)at javax.el.BeanELResolver.invoke(BeanELResolver.java:537)at javax.el.CompositeELResolver.invoke(CompositeELResolver.java:256 )at com.sun.el.parser.AstValue.invoke(AstValue.java:283)at com.sun.el.MethodExpressionImpl.invoke(MethodExpressionImpl.java:304) at com.sun.faces.facelets。 el.TagMethodExpression.invoke(TagMethodExpression.java:105) 在 javax.faces.component.MethodBindingMethodExpressionAdapter.invoke(MethodBindingMethodExpressionAdapter.java:87) 在 com.sun.faces.application.ActionListenerImpl.processAction(ActionListenerImpl.java:102) 在javax.faces.component.UICommand。廣播(UICommand.java:315)在 javax.faces.component.UIViewRoot.broadcastEvents(UIViewRoot.java:790) 在 javax.faces.component.UIViewRoot.processApplication(UIViewRoot.java:1282) 在 融爲一體。 sun.faces.lifecycle.InvokeApplicationPhase.execute(InvokeApplicationPhase.java:81) at com.sun.faces.lifecycle.Phase.doPhase(Phase.java:101)at com.sun.faces.lifecycle.LifecycleImpl.execute( LifecycleImpl.java:19 8) 在javax.faces.webapp.FacesServlet.service(FacesServlet.java:646)在 org.apache.catalina.core.StandardWrapper.service(StandardWrapper.java:1682) 在 org.apache.catalina.core .ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:344) 在 org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:214) 在 org.glassfish.tyrus.servlet.TyrusServletFilter.doFilter(TyrusServletFilter。的java:295) 在 org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:256) 在 org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:214) 在 有機.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:316) 在 org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:160) 在 org.apache.catalina.core.StandardPipeline .doInvoke(StandardPipeline.java:734) at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:673) at com.sun.enterprise.web.WebPipeline.i nvoke(WebPipeline.java:99)在 org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:174) 在 org.apache.catalina.connector.CoyoteAdapter.doService(CoyoteAdapter.java:415) 在 org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:282) 在 com.sun.enterprise.v3.services.impl.ContainerMapper $ HttpHandlerCallable.call(ContainerMapper.java:459) 在 com.sun.enterprise.v3.services.impl.ContainerMapper.service(ContainerMapper.java:167) 在 org.glassfish.grizzly.http.server.HttpHandler.runService(HttpHandler.java:201) 在 組織。 glassfish.grizzly.http.ser ver.HttpHandler.doHandle(HttpHandler.java:175) 在 org.glassfish.grizzly.http.server.HttpServerFilter.handleRead(HttpServerFilter.java:235) 在 org.glassfish.grizzly.filterchain.ExecutorResolver $ 9.execute (ExecutorResolver.java:119) 在 org.glassfish.grizzly.filterchain.DefaultFilterChain.executeFilter(DefaultFilterChain.java:284) 在 org.glassfish.grizzly.filterchain.DefaultFilterChain.executeChainPart(DefaultFilterChain.java:201) 在 org.glassfish.grizzly.filterchain.DefaultFilterChain.execute(DefaultFilterChain.java:133) at org.glassfish.grizzly.filterchain.DefaultFilterChain.process(DefaultFilterChain.jav一:112) 在 org.glassfish.grizzly.ProcessorExecutor.execute(ProcessorExecutor.java:77) 在 org.glassfish.grizzly.nio.transport.TCPNIOTransport.fireIOEvent(TCPNIOTransport.java:561) 在 有機.glassfish.grizzly.strategies.AbstractIOStrategy.fireIOEvent(AbstractIOStrategy.java:112) 在 org.glassfish.grizzly.strategies.WorkerThreadIOStrategy.run0(WorkerThreadIOStrategy.java:117) 在 org.glassfish.grizzly.strategies.WorkerThreadIOStrategy .access $ 100(WorkerThreadIOStrategy.java:56) at org.glassfish.grizzly.strategies.WorkerThreadIOStrategy $ WorkerThreadRunnable.run(WorkerThreadIOStrategy.java:137) 在 org.glassfish.grizzly.threadpool.AbstractThreadPool $ Worker.doWork(AbstractThreadPool.java:565) 在 org.glassfish.grizzly.threadpool.AbstractThreadPool $ Worker.run(AbstractThreadPool.java:545) 是java。 lang.Thread.run(Thread.java:745)

我該如何避免這種情況?我正在考慮解鎖()方法(如https://lucene.apache.org/core/4_1_0/core/org/apache/lucene/index/IndexWriter.html#close()中所建議的),但我不知道將它放在哪裏。任何幫助表示讚賞。

在femtoRgon的建議,我tryed修改我的代碼,以避免實例爲每一個add()操作:

public String add() throws IOException{ 



        InputStream is = file.getInputStream(); 
        PDDocument doc = PDDocument.load(is); 
        contenuto = new PDFTextStripper().getText(doc); 
        doc.close(); 
        Book book = new Libro(ISBN,author,title,content); 
        indexer.index(book); 
        indexer.close(); 




        return "home"; 

     } 

不幸的是,結果是一樣的,並似乎對write.lock一些衝突。我不知道怎麼可能。也許可以爲每個請求重新生成bean,我有兩個或更多的鎖?我應該更改@RequestScoped註釋嗎?

+0

請勿使用'unlock()'。一次只能在索引上打開一個「IndexWriter」實例。這就是鎖存在的原因。 'unlock()'應該僅用於應用程序無法正常退出的情況,並且保持索引被鎖定,即使您確定當前沒有進程正在訪問它。 – femtoRgon 2014-09-29 17:51:22

+0

@femtoRgon是的,但我不控制web應用程序啓動時的實例化。我能怎麼做? – Fabrizio 2014-09-29 17:53:25

+0

對,你用'@EJB'註解它,所以它會這樣做,如果我沒有弄錯的話。那麼,爲什麼要構建和關閉你的'Indexer'作爲add()方法的一部分呢? – femtoRgon 2014-09-29 17:59:52

回答

0

我發現了我的問題的解決方案。正如我之前所說的,它取決於管理bean的範圍。在@RequestScoped的情況下,爲每個請求創建託管bean:在我的情況下,這意味着也爲每個請求生成索引器。我在Indexer構造函數中實例化了IndexWriter,因此實例是在開始時生成的(當應用程序啓動時),當我嘗試計算一個請求時,它再次生成,並且在寫入鎖定時存在衝突問題。我解決了在index()方法中推遲IndexWriter的實例化。在這裏我的代碼:

public void index(Book item) throws IOException{ 



     if (iw == null) { 

       iw = new IndexWriter(FSDirectory.open(new File(directory)), 
         new IndexWriterConfig(Version.LATEST, new EnglishAnalyzer())); 


      } 


     iw.deleteDocuments(new Term(Book.ID, String.valueOf(item.getISBN()))); 



     Document doc = new Document(); 





     doc.add(new LongField(Book.ID, item.getISBN(),Field.Store.YES)); 
     doc.add(new StringField(Book.AUTHOR, item.getAuthor(),Field.Store.YES)); 
     doc.add(new StringField(Book.TITLE, item.getTitle(),Field.Store.YES)); 
     doc.add(new TextField(Book.CONTENT, item.getContent(),Field.Store.YES)); 




     iw.addDocument(doc); 
     iw.commit(); 

    } 

而且我刪除的指令

indexer.close()在類managedBeanIB

從add()方法,因爲它必須只在叫應用程序結束。