ES8的Java API client 8.0 简单示例操作 Elasticsearch

1.加入依赖

  1.       
  2.             co.elastic.clients
  3.             elasticsearch-java
  4.             8.12.2
  5.

2.配置类

  1.  
  2.  
  3. @Slf4j
  4. @Configuration
  5. public class ElasticSearchConfig {
  6.     @Value("${elasticsearch.hosts}")
  7.     private String hosts;
  8.     @Value("${elasticsearch.port}")
  9.     private int port;
  10.     @Value("${elasticsearch.username}")
  11.     private String username;
  12.     @Value("${elasticsearch.password}")
  13.     private String password;
  14.     @Value("${elasticsearch.apikey:''}")
  15.     private String apikey;
  16.  
  17.     /**
  18.      * 单节点没密码连接
  19.      *
  20.      * @return
  21.      */
  22.     @Bean
  23.     public ElasticsearchClient elasticsearchClient() {
  24.         String[] servers = hosts.split(",");
  25.         int len = servers.length;
  26.         if (0 == len) {
  27.             log.error("ElasticsearchClient 配置错误!");
  28.         }
  29.         ElasticsearchTransport transport = null;
  30.         // 不是集群时
  31.         if (1 == len) {
  32.             // 无账号、密码
  33.             if (StringUtils.isEmpty(username) && StringUtils.isEmpty(password)) {
  34.                 RestClient client = RestClient.builder(new HttpHost(servers[0], port, "http"))
  35.                         .setHttpClientConfigCallback(httpClientBuilder
  36.                                 ->httpClientBuilder.setDefaultHeaders(
  37.                                         Collections.singletonList(new BasicHeader(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.toString())))
  38.                                 .addInterceptorLast((HttpResponseInterceptor) (response, context)
  39.                                         -> response.addHeader("X-Elastic-Product", "Elasticsearch")))
  40.                         .build();
  41.                 transport = new RestClientTransport(client, new JacksonJsonpMapper());
  42.             } else {
  43.                 // 账号密码的配置
  44.                 final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
  45.                 credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));
  46.                 // 自签证书的设置，并且还包含了账号密码
  47.                 RestClientBuilder.HttpClientConfigCallback callback = httpAsyncClientBuilder -> httpAsyncClientBuilder
  48.                         .setDefaultCredentialsProvider(credentialsProvider)
  49.                         .addInterceptorLast(
  50.                                 (HttpResponseInterceptor)
  51.                                         (response, context) ->
  52.                                                 response.addHeader("X-Elastic-Product", "Elasticsearch"));
  53.  
  54.                 RestClient client = RestClient.builder(new HttpHost(servers[0], port, "http"))
  55.                         .setHttpClientConfigCallback(callback)
  56.                         .build();
  57.                 transport = new RestClientTransport(client, new JacksonJsonpMapper());
  58.             }
  59.         } else {
  60.             // 集群时无账号、密码
  61.             if (StringUtils.isEmpty(username) && StringUtils.isEmpty(password)) {
  62.                 transport = getElasticsearchTransport(toHttpHost());
  63.             } else {
  64.                 transport = getElasticsearchTransport(username, password, toHttpHost());
  65.             }
  66.         }
  67.         return new ElasticsearchClient(transport);
  68.     }
  69.  
  70.  
  71.     private HttpHost[] toHttpHost() {
  72.         if (hosts.split(",").length == 0) {
  73.             throw new RuntimeException("invalid elasticsearch configuration");
  74.         }
  75.         String[] hostArray = hosts.split(",");
  76.         HttpHost[] httpHosts = new HttpHost[hostArray.length];
  77.         HttpHost httpHost;
  78.         for (int i = 0; i < hostArray.length; i++) {
  79.             String[] strings = hostArray[i].split(":");
  80.             httpHost = new HttpHost(strings[0], Integer.parseInt(strings[1]), "http");
  81.             httpHosts[i] = httpHost;
  82.         }
  83.         return httpHosts;
  84.     }
  85.  
  86.     private static ElasticsearchTransport getElasticsearchTransport(String username, String password, HttpHost... hosts) {
  87.         // 账号密码的配置
  88.         final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
  89.         credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));
  90.  
  91.         // 自签证书的设置，并且还包含了账号密码
  92.         RestClientBuilder.HttpClientConfigCallback callback = httpAsyncClientBuilder -> httpAsyncClientBuilder
  93.                 .setSSLContext(buildSSLContext())
  94.                 .setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE)
  95.                 .setDefaultCredentialsProvider(credentialsProvider)
  96.                 .setDefaultHeaders(
  97.                         Stream.of(new BasicHeader(
  98.                                 HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.toString())).collect(toList())
  99.                 ).addInterceptorLast(
  100.                         (HttpResponseInterceptor)
  101.                                 (response, context) ->
  102.                                         response.addHeader("X-Elastic-Product", "Elasticsearch"))
  103.                 .addInterceptorLast((HttpResponseInterceptor) (response, context)
  104.                         -> response.addHeader("X-Elastic-Product", "Elasticsearch"));
  105.         // 用builder创建RestClient对象
  106.         RestClient client = RestClient
  107.                 .builder(hosts)
  108.                 .setHttpClientConfigCallback(callback)
  109.                 .build();
  110.  
  111.         return new RestClientTransport(client, new JacksonJsonpMapper());
  112.     }
  113.  
  114.     private static ElasticsearchTransport getElasticsearchTransport(HttpHost... hosts) {
  115.         // 用builder创建RestClient对象
  116.         RestClient client = RestClient
  117.                 .builder(hosts)
  118.                 .build();
  119.  
  120.         return new RestClientTransport(client, new JacksonJsonpMapper());
  121.     }
  122.  
  123.     private static SSLContext buildSSLContext() {
  124.         ClassPathResource resource = new ClassPathResource("es01.crt");
  125.         SSLContext sslContext = null;
  126.         try {
  127.             CertificateFactory factory = CertificateFactory.getInstance("X.509");
  128.             Certificate trustedCa;
  129.             try (InputStream is = resource.getInputStream()) {
  130.                 trustedCa = factory.generateCertificate(is);
  131.             }
  132.             KeyStore trustStore = KeyStore.getInstance("pkcs12");
  133.             trustStore.load(null, null);
  134.             trustStore.setCertificateEntry("ca", trustedCa);
  135.             SSLContextBuilder sslContextBuilder = SSLContexts.custom().loadTrustMaterial(trustStore, null);
  136.             sslContext = sslContextBuilder.build();
  137.         } catch (CertificateException | IOException | KeyStoreException | NoSuchAlgorithmException |
  138.                  KeyManagementException e) {
  139.             log.error("ES连接认证失败", e);
  140.         }
  141.         return sslContext;
  142.     }
  143. }

3.相关api

前提：

注入ElasticsearchClient

  1. @Autowired
  2. private ElasticsearchClient client;

3.1 创建索引

  1.  public void createIndex() throws IOException {
  2.         ElasticsearchIndicesClient indices = client.indices();
  3.         //是否存在
  4.         //1.lambda
  5.         boolean isExit = indices.exists(req -> req.index("ttt")).value();
  6.         //2.builder,of
  7.         ExistsRequest existsRequestOf = ExistsRequest.of(req -> req.index("ttt"));
  8.         ExistsRequest existsRequest = new ExistsRequest.Builder().index("ttt").build();
  9.         boolean builderExist = indices.exists(existsRequest).value();
  10.         if (isExit){
  11.             log.info("已经存在ttt");
  12.         }else {
  13.             //1.lambda
  14.             boolean isSuccess = indices.create(req -> req.index("ttt")).acknowledged();
  15.             //2.builder,of
  16.             CreateIndexRequest createIndexRequestOf = CreateIndexRequest.of(req -> req.index("ttt"));
  17.             CreateIndexRequest createIndexRequest = new CreateIndexRequest.Builder().index("ttt").build();
  18.             boolean buildIsSuccess = indices.create(createIndexRequest).acknowledged();
  19.             if (isSuccess){
  20.                 log.info("创建成功");
  21.             }else {
  22.                 log.info("创建失败");
  23.             }
  24.         }
  25.     }

3.2 删除索引

  1. public void deleteIndex() throws IOException {
  2.         //1.lambda
  3.         boolean isSuccess = client.indices().delete(req -> req.index("ttt")).acknowledged();
  4.         //2.builder,of
  5.         DeleteIndexRequest deleteRequestOf = DeleteIndexRequest.of(req -> req.index("ttt"));
  6.         DeleteIndexRequest deleteRequest = new DeleteIndexRequest.Builder().index("ttt").build();
  7.         boolean buildDeleteRequest = client.indices().delete(deleteRequest).acknowledged();
  8.     }

3.3查询索引

  1.  public void queryIndex() throws IOException {
  2.         //1.lambda
  3.         //查询单个
  4.         Map tttIndex = client.indices().get(req -> req.index("ttt")).result();
  5.         //查询索引
  6.         Set all = client.indices().get(req -> req.index("*")).result().keySet();
  7.         //2.builder
  8.         GetIndexRequest getIndexRequestOf = GetIndexRequest.of(req -> req.index("ttt"));
  9.         GetIndexRequest getIndexRequest = new GetIndexRequest.Builder().index("ttt").build();
  10.         Map result = client.indices().get(getIndexRequest).result();
  11.     }

3.4 插入文档

  1.  public void addDoc() throws IOException {
  2.         Goods goods = new Goods("3212334","华为mate60", 9999.0);
  3.  
  4.         //1.lambda
  5.         client.index(i->i
  6.                 .index("goods")
  7.                 .id(goods.getSku())
  8.                 .document(goods));
  9.         //2.builder-of
  10.         IndexRequest addIndexRequestOf = IndexRequest.of(t -> t.id(goods.getSku()).document(goods).index("goods"));
  11.         IndexRequest addIndexRequest = new IndexRequest<>.Builder()
  12.                 .index("goods")
  13.                 .id(goods.getSku())
  14.                 .document(goods).build();
  15.         IndexResponse index = client.index(addIndexRequest);
  16.  
  17.     }

3.5 批量插入文档

  1. public void addBatchDoc() throws IOException {
  2.  
  3.         List goodsList = List.of(new Goods("1","手机",999.0));
  4.         BulkRequest.Builder br = new BulkRequest.Builder();
  5.         for (Goods goods : goodsList) {
  6.             br.operations(op->op.
  7.                     index(idx->idx.index("goods")
  8.                             .id(goods.getSku())
  9.                             .document(goods)));
  10.         }
  11.         BulkResponse result = client.bulk(br.build());
  12.         // Log errors, if any
  13.         if (result.errors()) {
  14.             log.error("Bulk had errors");
  15.             for (BulkResponseItem item: result.items()) {
  16.                 if (item.error() != null) {
  17.                     log.error(item.error().reason());
  18.                 }
  19.             }
  20.         }
  21.     }

3.6查询文档

  1. public void queryDoc() throws IOException {
  2.         //1.lambda
  3.         GetResponse response = client.get(g ->  g
  4.                         .index("goods")
  5.                         .id("00000")
  6.                 , Goods.class);
  7.         //2.builder,of
  8.         GetRequest request = GetRequest.of(g -> g.index("goods").id("00000"));
  9.  
  10.         GetRequest ofRequest = new GetRequest.Builder().index("goods").id("00000").build();
  11.  
  12.  
  13.         GetResponse response1 = client.get(request, Goods.class);
  14.         if (response.found()){
  15.             Goods source = response.source();
  16.             System.out.println(source);
  17.         }
  18.     }

3.7修改文档

  1.  public void updateDoc() throws IOException {
  2.         //全量
  3.         Goods goods = new Goods("1","2",3.0);
  4.         UpdateResponse update = client.update(u -> u
  5.                         .doc(goods)
  6.                         .id(goods.getSku())
  7.                 , Goods.class);
  8.         //of
  9.         UpdateRequest of = UpdateRequest.of(u -> u.id(goods.getSku()).doc(goods));
  10.         UpdateResponse update1 = client.update(of, Goods.class);
  11.     }
    12.  

    3.8删除文档
     

    1.    */
    2.     public void deleteDoc() throws IOException {
    3.         DeleteResponse goods = client.delete(d -> d
    4.                 .index("goods")
    5.                 .id("0000"));
    6.  
    7.         //of
    8.         DeleteRequest deleteRequest = DeleteRequest.of(d -> d.index("goods").id("0000"));
    9.         client.delete(deleteRequest);
    10.     }
     

    3.9 DSL 匹配查询
     

    1. public void query() throws IOException {
    2.         String text = "华为mate60";
    3.         SearchResponse response = client.search(s -> s
    4.                         .index("goods")
    5.                         .query(q -> q
    6.                                 .match(m -> m
    7.                                         .field("name")
    8.                                         .query(text))
    9.                         )
    10.                 , Goods.class);
    11.  
    12.         //of
    13.         SearchRequest request = SearchRequest.of(s -> s.index("goods")
    14.                 .query(q -> q
    15.                         .match(m ->
    16.                                 m.field("").field(""))
    17.                 ));
    18.         SearchResponse search = client.search(request, Goods.class);
    19.         //结果
    20.         //总数
    21.         TotalHits total = response.hits().total();
    22.         assert total != null;
    23.         boolean isExactResult = total.relation() == TotalHitsRelation.Eq;
    24.         if (isExactResult) {
    25.             log.info("找到 " + total.value() + " 个结果");
    26.         } else {
    27.             log.info("找到超过 " + total.value() + " 个结果");
    28.         }
    29.         List> hits = response.hits().hits();
    30.         for (Hit hit : hits) {
    31.             Goods goods = hit.source();
    32.             System.out.println(goods);
    33.         }
    34.     }
     

    3.10 多精确terms
     

    1. public void terms(){
    2.         List v = new ArrayList<>();
    3.         FieldValue tag2 = FieldValue.of("tag2");
    4.         FieldValue tag1 = FieldValue.of("tag1");
    5.         v.add(tag1);v.add(tag2);
    6.         TermsQuery tags = TermsQuery.of(t -> t.field("tags").terms(tm -> tm.value(v)));
    7.         SearchRequest of = SearchRequest.of(s -> s.index("goods")
    8.                 .query(q -> q
    9.                         .bool(b -> b
    10.                                 .must(m -> m
    11.                                         .terms(tags)
    12.                                 )
    13.                                 .should(sh -> sh
    14.                                         .match(ma -> ma
    15.                                                 .field("")
    16.                                                 .query("")
    17.                                         )
    18.                                 )
    19.                         )
    20.                 )
    21.                 .from(0)
    22.                 .size(10)
    23.  
    24.         );
    25.         
    26.     }
     

    3.11 布尔查询
     

    1.  
    2.  
    3.  
    4. @Slf4j
    5. @Service
    6. public class EsTest {
    7.  
    8.     @Autowired
    9.     private ElasticsearchClient client;
    10.  
    11.     
    12.     /**
    13.      * bool
    14.      */
    15.     public void boolQuery() throws IOException {
    16.         Map map = new HashMap<>();
    17.         map.put("title", HighlightField.of(hf -> hf.preTags("").postTags("")));
    18.         map.put("description", HighlightField.of(hf -> hf.preTags("").postTags("")
    19.                 .numberOfFragments(4).fragmentSize(50)));
    20.         //numberOfFragments(4)，表示将字段分割为最多4个片段，并设置 fragmentSize(50)，表示每个片段的大小为50个字符。
    21.  
    22.         Highlight highlight = Highlight.of(
    23.                 h -> h.type(HighlighterType.Unified)
    24.                         .fields(map)
    25.                         .fragmentSize(50)//设置默认的高亮片段大小为50个字符，如果字段没有单独设置，则使用此默认值。
    26.                         .numberOfFragments(5)//设置每个字段的最大高亮片段数为5个。
    27.         );
    28.  
    29.         String text = "华为mate60";
    30.         SearchResponse search = client.search(s -> s
    31.                         .index("goods")
    32.                         .query(q -> q
    33.                                 .bool(b -> b
    34.                                         .must(m -> m
    35.                                                 .term(t -> t
    36.                                                         .field("品牌")
    37.                                                         .value("华为")
    38.                                                 )
    39.                                         )
    40.                                         .should(sd -> sd
    41.                                                 .match(mh -> mh
    42.                                                         .field("name")
    43.                                                         .query("mate60")))
    44.                                 )
    45.                         )
    46.                         .from(0)
    47.                         .size(10)
    48.                         .highlight(highlight)
    49.                 , Goods.class);
    50.         //of
    51.         SearchRequest of = SearchRequest.of(s -> s.index("goods")
    52.                 .query(q -> q
    53.                         .bool(b -> b
    54.                                 .must(m -> m
    55.                                         .term(t -> t.field("品牌")
    56.                                                 .value("华为")
    57.                                         )
    58.                                 )
    59.                                 .should(sh -> sh
    60.                                         .match(ma -> ma
    61.                                                 .field("")
    62.                                                 .query("")
    63.                                         )
    64.                                 )
    65.                         )
    66.                 )
    67.                 .from(0)
    68.                 .size(10)
    69.                 .highlight(highlight)
    70.  
    71.         );
    72.  
    73.         SearchResponse response = client.search(of, Goods.class);
    74.         List> hits = response.hits().hits();
    75.         for (Hit hit : hits) {
    76.             Goods goods = hit.source();
    77.             if (goods == null){
    78.                 continue;
    79.             }
    80.             Map> highlightList = hit.highlight();
    81.             highlightList.forEach((key, Value)->{
    82.                 if (Objects.equals(key,goods.getName())){
    83.                     //存入
    84.                 }else {
    85.                     //无高亮
    86.                 }
    87.                }
    88.             );
    89.             System.out.println(goods);
    90.         }
    91.  
    92.     }
    93.     
    94. }
     

    3.12构建排序
     

    1. /**
    2.      * 构建排序
    3.      */
    4.     private List buildSort(SearchDTO dto) {
    5.         if (dto.getTimeSort() != null){
    6.             SortOptions sortOptions ;
    7.             if (dto.getTimeSort() == 0){
    8.                 sortOptions = SortOptions.of(s -> s.field(FieldSort.of(f -> f.field(SearchConstants.TIMESTAMP).order(SortOrder.Asc))));
    9.             }else {
    10.                 sortOptions = SortOptions.of(s -> s.field(FieldSort.of(f -> f.field(SearchConstants.TIMESTAMP).order(SortOrder.Desc))));
    11.             }
    12.             return List.of(sortOptions);
    13.         }else {
    14.             return Collections.emptyList();
    15.         }
    16.  
    17.     }
     

    ...........
    
                
    
        
    
                
                
    
                    注：本文转载自blog.csdn.net的it-shiyadi的文章"https://blog.csdn.net/m0_73363097/article/details/142617941"。版权归原作者所有，此博客不拥有其著作权，亦不承担相应法律责任。如有侵权，请联系我们删除。
                
    
                
    
                    
    
                        
    
                            
    
                                
                                
                                
                                
                                    
                                
                                
                                
                                
                                
                                
                                
                                
                                
                                
                                
    
                                    复制链接
                                    
                                
    
                                
    
                                    
                                    
    
                                        
    
                                            
    
                                        
    
                                    
    
                                
    
                            
    
                        
    
                    
    
                
    

                
    
                    
    




                        
                    
    
                
    
                
    
                
            
    


            
            
    
                
    相关推荐
    
                
    
                    
    
                    
    
                
    
            
    
            
    
                
    
                    
    
                        
    
							
								发表评论
                        
    
                        
                    
    
                    
    
                        
    
                            
    
								
                            
    
                            
    
                                
    
                                    
    
                                        
                                    
    
                                    
    
                                        
                                    
    
                                
    
                            
    
                            
    
                                
                            
    
                        
    
                        
    评论记录：
    
                        
                        
                        
                        
                        
                        
    未查询到任何数据！