Javaでのelasticsearch利用について

konchan · August 17, 2015, 3:19am

現在、以下のようにプログラムを組んでいます。
import static org.elasticsearch.node.NodeBuilder.*;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.util.Date;
import java.util.StringTokenizer;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.node.Node;

/**

Servlet implementation class InsertServlet
*/
@WebServlet("/InsertServlet")
public class InsertServlet extends HttpServlet {
private static final long serialVersionUID = 1L;

/**
- @see HttpServlet#HttpServlet()
  */
  public InsertServlet() {
  super();
  // TODO Auto-generated constructor stub
  }
/**
- @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
  */
  protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  // TODO Auto-generated method stub
  try {
  //ファイルを読み込む
  FileReader fr = new FileReader("C:\work\logs\shiken.log");
  BufferedReader br = new BufferedReader(fr);
```
 //読み込んだファイルを１行ずつ処理する
 String line;
 StringTokenizer token;
 while ((line = br.readLine()) != null) {
 	System.out.println(line);
 	String json=line;

 	Node node = nodeBuilder().node();
 	Client client = node.client();
 	IndexResponse inres = client.prepareIndex("renshu", "ren")
 			.setSource(json)
 			.execute()
 			.actionGet();

 	node.close();

 }
 br.close();
```
  }catch (IOException ex) {
  //例外発生時処理
  ex.printStackTrace();
  }
  ServletContext context=getServletContext();
  RequestDispatcher rd = context.getRequestDispatcher("/Start.html");
  rd.forward(request, response);
  }
  private static boolean checkBeforeWritefile(File file){
  if (file.exists()){
  if (file.isFile() && file.canWrite()){
  return true;
  }
  }
  return false;
  }
/**
- @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
  */
  protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  // TODO Auto-generated method stub
  }

}

ファイル読み込み処理中のnodeのところでエラーが起きてしまいます
原因はなんでしょうか？
解決策を教えてください。

追加したjarのバージョンはelasticsearch-1.3.2.jar、lucene-core-5.2.1.jarです。

johtani · August 17, 2015, 4:17am

エラーの内容は前回記載されていたものと変わりはないということで良いでしょうか？
コンパイル時にエラーが出るのでしょうか？
それとも実行時にエラーが出るのでしょうか？

konchan · August 17, 2015, 5:35am

前回と変わりないです
実行時にエラーが起こります

johtani · August 17, 2015, 5:49am

実行時にエラーが起こるのであれば、
ライブラリの読み込みなどに問題があるかと思います。

クラスパスに他のバージョンのjarなどが含まれていないか、確認してみるのが良いかと思います。

konchan · August 17, 2015, 6:26am

確認したところ他のバージョンのjarはありませんでした。

johtani · August 17, 2015, 6:40am

その他にはログにエラーなどは出ていないのでしょうか？
ログの前後にはどのようなメッセージが出ているのでしょうか？

konchan · August 17, 2015, 6:52am

以下のログが出てます

Servlet.service() for servlet [InsertServlet] in context with path [/Kibana] threw exception [サーブレットの実行により例外を投げました] with root cause
java.lang.ClassNotFoundException: org.elasticsearch.node.NodeBuilder
at org.apache.catalina.loader.WebappClassLoader.loadClass(WebappClassLoader.java:1701)
at org.apache.catalina.loader.WebappClassLoader.loadClass(WebappClassLoader.java:1546)
at InsertServlet.doGet(InsertServlet.java:74)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:621)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:224)
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:169)
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:168)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:98)
at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:927)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:407)
at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:987)
at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:579)
at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:307)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)

johtani · August 17, 2015, 7:05am

そもそも、作られているServletアプリからelasticsearchのjarファイルが読み込めていないようです。
（ClassNotFoundExceptionが出ているため。）

アプリの設定や配置の方法を確認したほうが良いかと。

konchan · August 24, 2015, 8:08am

jarの構成など見直して実行したところ
下記のログが表示されました。
これはデータの格納が成功したということでいいのでしょうか？

8 24, 2015 4:53:31 午後 org.elasticsearch.node.internal.InternalNode
情報: [Diamanda Nero] version[1.6.0], pid[11416], build[cdd3ac4/2015-06-09T13:36:34Z]
8 24, 2015 4:53:31 午後 org.elasticsearch.node.internal.InternalNode
情報: [Diamanda Nero] initializing ...
8 24, 2015 4:53:31 午後 org.elasticsearch.plugins.PluginsService
情報: [Diamanda Nero] loaded [], sites []
8 24, 2015 4:53:31 午後 org.elasticsearch.env.NodeEnvironment maybeLogPathDetails
情報: [Diamanda Nero] using [1] data paths, mounts [[(C:)]], net usable_space [103gb], net total_space [224.8gb], types [NTFS]
8 24, 2015 4:53:31 午後 org.elasticsearch.node.internal.InternalNode
情報: [Diamanda Nero] initialized
8 24, 2015 4:53:31 午後 org.elasticsearch.node.internal.InternalNode start
情報: [Diamanda Nero] starting ...
8 24, 2015 4:53:31 午後 org.elasticsearch.transport.TransportService doStart
情報: [Diamanda Nero] bound_address {inet[/0:0:0:0:0:0:0:0:9301]}, publish_address {inet[/10.25.107.40:9301]}
8 24, 2015 4:53:31 午後 org.elasticsearch.discovery.DiscoveryService doStart
情報: [Diamanda Nero] elasticsearch/jFFi3dE4ThuZTiCCs7HFEQ
8 24, 2015 4:53:34 午後 org.elasticsearch.cluster.service.InternalClusterService$UpdateTask run
情報: [Diamanda Nero] detected_master [Morgan Le Fay][ylESzb88QGW8fa0ZeKHoIw][A003664589][inet[/:9300]], added {[Morgan Le Fay][ylESzb88QGW8fa0ZeKHoIw][A003664589][inet[/:9300]],}, reason: zen-disco-receive(from master [[Morgan Le Fay][ylESzb88QGW8fa0ZeKHoIw][A003664589][inet[/:9300]]])
8 24, 2015 4:53:34 午後 org.elasticsearch.http.HttpServer doStart
情報: [Diamanda Nero] bound_address {inet[/0:0:0:0:0:0:0:0:9201]}, publish_address {inet[/:9201]}
8 24, 2015 4:53:34 午後 org.elasticsearch.node.internal.InternalNode start
情報: [Diamanda Nero] started
8 24, 2015 4:53:34 午後 org.elasticsearch.node.internal.InternalNode stop
情報: [Diamanda Nero] stopping ...
8 24, 2015 4:53:34 午後 org.elasticsearch.node.internal.InternalNode stop
情報: [Diamanda Nero] stopped
8 24, 2015 4:53:34 午後 org.elasticsearch.node.internal.InternalNode close
情報: [Diamanda Nero] closing ...
8 24, 2015 4:53:34 午後 org.elasticsearch.node.internal.InternalNode close
情報: [Diamanda Nero] closed

Topic		Replies	Views
Elasticsearchにデータを保存する方法について日本語による質問・議論はこちら	5	3928	July 6, 2017
Elastic Searchのロードマップについて日本語による質問・議論はこちら	3	818	December 20, 2018
Elasticsearchのスナップショット利用設定について日本語による質問・議論はこちら	3	2125	June 26, 2017
Elasticsearchへアクセスする際のセキュリティ日本語による質問・議論はこちら	3	910	November 27, 2017
Pdf等の検索について日本語による質問・議論はこちら	10	3362	July 6, 2017

Javaでのelasticsearch利用について

Related topics