API操作

新建工程并导入依赖：

  1. <dependency>
  2.   <groupId>org.apache.httpcomponents</groupId>
  3.   <artifactId>httpclient</artifactId>
  4.   <version>4.5.5</version>
  5. </dependency>
  7. <dependency>
  8.   <groupId>org.apache.httpcomponents</groupId>
  9.   <artifactId>httpmime</artifactId>
  10.   <version>4.3.6</version>
  11. </dependency>
  13. <dependency>
  14.   <groupId>io.searchbox</groupId>
  15.   <artifactId>jest</artifactId>
  16.   <version>5.3.3</version>
  17. </dependency>
  19. <dependency>
  20.   <groupId>net.java.dev.jna</groupId>
  21.   <artifactId>jna</artifactId>
  22.   <version>4.5.2</version>
  23. </dependency>
  25. <dependency>
  26.   <groupId>org.codehaus.janino</groupId>
  27.   <artifactId>commons-compiler</artifactId>
  28.   <version>2.7.8</version>
  29. </dependency>
  31. <dependency>
  32.   <groupId>org.elasticsearch</groupId>
  33.   <artifactId>elasticsearch</artifactId>
  34.   <version>6.6.0</version>
  35. </dependency>

写数据

1）单条数据写入

  1. //1.创建ES客户端构建器
  2. JestClientFactory factory = new JestClientFactory();
  4. //2.创建ES客户端连接地址
  5. HttpClientConfig httpClientConfig = new HttpClientConfig.Builder("http://hadoop102:9200").build();
  7. //3.设置ES连接地址
  8. factory.setHttpClientConfig(httpClientConfig);
  10. //4.获取ES客户端连接
  11. JestClient jestClient = factory.getObject();
  13. //5.构建ES插入数据对象
  14. Index index = new Index.Builder("{\n" +
  15.                                 "  \"id\":\"1002\",\n" +
  16.                                 "  \"movie_name\":\”姜子牙\”\n" +
  17.                                 "}").index("movie_test1").type("_doc").id("1002").build();
  19. //6.执行插入数据操作
  20. jestClient.execute(index);
  22. //7.关闭连接
  23. jestClient.shutdownClient();
  25. 2）批量数据写入
  26. //1.创建客户端对象
  27. JestClientFactory jestClientFactory = new JestClientFactory();
  29. //2.设置连接参数
  30. HttpClientConfig httpClientConfig = new HttpClientConfig
  31. .Builder("http://hadoop102:9200")
  32.     .build();
  33. jestClientFactory.setHttpClientConfig(httpClientConfig);
  35. //3.获取客户端对象
  36. JestClient jestClient = jestClientFactory.getObject();
  38. Movie movie1 = new Movie("1005", "二十不惑");
  39. Movie movie2 = new Movie("1006", "三十而立");
  40. Movie movie3 = new Movie("1007", "寄生虫");
  41. Index index1 = new Index.Builder(movie1).id("1005").build();
  42. Index index2 = new Index.Builder(movie2).id("1006").build();
  43. Index index3 = new Index.Builder(movie3).id("1007").build();
  45. Bulk bulk = new Bulk.Builder()
  46.     .defaultIndex("movie_test1")
  47.     .defaultType("_doc")
  48.     .addAction(index1)
  49.     .addAction(index2)
  50.     .addAction(index3)
  51.     .build();
  52. jestClient.execute(bulk);
  53. jestClient.shutdownClient();

读数据

  1. //1.创建ES客户端连接池
  2. JestClientFactory factory = new JestClientFactory();
  4. //2.创建ES客户端连接地址
  5. HttpClientConfig httpClientConfig = new HttpClientConfig.Builder("http://hadoop102:9200").build();
  7. //3.设置ES连接地址
  8. factory.setHttpClientConfig(httpClientConfig);
  10. //4.获取ES客户端连接
  11. JestClient jestClient = factory.getObject();
  13. //5.构建查询数据对象
  14. Search search = new Search.Builder("{\n" +
  15. "  \"query\": {\n" +
  16. "    \"match\": {\n" +
  17. "      \"name\": \"zhangsan\"\n" +
  18. "    }\n" +
  19. "  }\n" +
  20. "}").addIndex("test5").addType("_doc").build();
  22. //6.执行查询操作
  23. SearchResult searchResult = jestClient.execute(search);
  25. //7.解析查询结果
  26. System.out.println(searchResult.getTotal());
  27. List<SearchResult.Hit<Map, Void>> hits = searchResult.getHits(Map.class);
  28. for (SearchResult.Hit<Map, Void> hit : hits) {
  29. System.out.println(hit.index + "--" + hit.id);
  30. }
  32. //8.关闭连接
  33. jestClient.shutdownClient();