springboot整合es

 
        
            org.elasticsearch.client
            elasticsearch-rest-client
            7.6.2
        
        
            org.elasticsearch.client
            elasticsearch-rest-high-level-client
            7.6.2
            
                
                    elasticsearch-rest-client
                    org.elasticsearch.client
                
                
                    org.elasticsearch
                    elasticsearch
                
            
        
        
            org.elasticsearch
            elasticsearch
            7.6.2
        

@Configuration
public class ESConfig {
    @Bean
    public RestHighLevelClient restHighLevelClient(){
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                        new HttpHost("192.168.8.125", 9200, "http")));
        return client;
    }
}

package com.kv.es.service.impl;

import com.kv.es.model.SearchQuery;
import com.kv.es.service.SearchService;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;


@Service
public class SearchServiceImpl implements SearchService {
    @Autowired
    private RestHighLevelClient restHighLevelClient;
    
    @Override
    public void search(SearchQuery searchQuery) {
        // 创建请求对象
        GetRequest request = new GetRequest().index("knowledge_base").id("1");
        try {
            // 客户端发送请求，获取响应对象
            GetResponse response = restHighLevelClient.get(request, RequestOptions.DEFAULT);
            //打印结果
            System.out.println("_index:"+response.getIndex());
            System.out.println("_type:"+response.getType());
            System.out.println("_id:"+response.getId());
            System.out.println("source:"+response.getSourceAsString());
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}