Spring Boot整合Elasticsearch超详细教程

冷不防 2024-04-03 12:34 111阅读 0赞

#### 文章目录 ####

*   *   *  SpringBoot整合Elasticsearch超详细教程
         *   *  最新高级版
             *  总结：

--------------------

#### SpringBoot整合Elasticsearch超详细教程 ####

##### 最新高级版 #####

**（1）导入springboot整合ES高级别客户端的坐标**

<dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
    </dependency>

**(2)使用编程的形式设置连接的ES服务器，并获取客户端对象**

@SpringBootTest
    class HighClientTest {
        
        private RestHighLevelClient client;
          @Test
          void testCreateClient() throws IOException {
        
              HttpHost host = HttpHost.create("http://localhost:9200");
              RestClientBuilder builder = RestClient.builder(host);
              client = new RestHighLevelClient(builder);
      
              client.close();
          }
    }

**（3)Book实体类**

@Data
    public class Book {
        
        private Integer id;
        private String type;
        private String name;
        private String description;
    }

**(4)连接Dao层**

@Mapper
    public interface BookDao extends BaseMapper<Book> {
        
    }

**(5)使用客户端对象操作ES**

例如创建索引：（这里需要先执行上面的删除索引操作，否则会报错）

@SpringBootTest
    class HighClientTest{
        
        private RestHighLevelClient client;
          @Test
          void testCreateIndex() throws IOException {
        
              HttpHost host = HttpHost.create("http://localhost:9200");
              RestClientBuilder builder = RestClient.builder(host);
              client = new RestHighLevelClient(builder);
              
              CreateIndexRequest request = new CreateIndexRequest("books");
              client.indices().create(request, RequestOptions.DEFAULT); 
              
              client.close();
          }
    }

**(6)创建索引（IK分词器）**

@Test
    void testCreateIndexByIK() throws IOException {
        
        CreateIndexRequest request = new CreateIndexRequest("books");
        String json = "{\n" +
                "    \"mappings\":{\n" +
                "        \"properties\":{\n" +
                "            \"id\":{\n" +
                "                \"type\":\"keyword\"\n" +
                "            },\n" +
                "            \"name\":{\n" +
                "                \"type\":\"text\",\n" +
                "                \"analyzer\":\"ik_max_word\",\n" +
                "                \"copy_to\":\"all\"\n" +
                "            },\n" +
                "            \"type\":{\n" +
                "                \"type\":\"keyword\"\n" +
                "            },\n" +
                "            \"description\":{\n" +
                "                \"type\":\"text\",\n" +
                "                \"analyzer\":\"ik_max_word\",\n" +
                "                \"copy_to\":\"all\"\n" +
                "            },\n" +
                "            \"all\":{\n" +
                "                \"type\":\"text\",\n" +
                "                \"analyzer\":\"ik_max_word\"\n" +
                "            }\n" +
                "        }\n" +
                "    }\n" +
                "}";
        //设置请求中的参数
        request.source(json, XContentType.JSON);
        client.indices().create(request, RequestOptions.DEFAULT);
    }

\*\*注：\*\*IK分词器是通过请求参数的形式进行设置的，设置请求参数使用request对象中的source方法进行设置，至于参数是什么，取决于你的操作种类。当请求中需要参数时，均可使用当前形式进行参数设置。

**(7)添加文档**：

@Test
        //添加文档
        void testCreateDoc() throws IOException {
        
            Book book = bookDao.selectById(1);
            IndexRequest request = new IndexRequest("books").id(book.getId().toString());
            String json = JSON.toJSONString(book);
            request.source(json,XContentType.JSON);
            client.index(request,RequestOptions.DEFAULT);
        }

添加文档使用的请求对象是IndexRequest，与创建索引使用的请求对象不同

**(8)批量添加文档**：

//批量添加文档
        @Test
        void testCreateDocAll() throws IOException{
        
            List<Book> bookList = bookDao.selectList(null);
            BulkRequest bulk = new BulkRequest();
            for (Book book : bookList) {
        
                IndexRequest request = new IndexRequest("books").id(book.getId().toString());
                String json = JSON.toJSONString(book);
                request.source(json,XContentType.JSON);
                bulk.add(request);
            }
            client.bulk(bulk,RequestOptions.DEFAULT);
        }

\*\*注：\*\*批量做时，先创建一个BulkRequest的对象，可以将该对象理解为是一个保存request对象的容器，将所有的请求都初始化好后，添加到BulkRequest对象中，再使用BulkRequest对象的bulk方法，一次性执行完毕。

**按id查询文档**：

//根据id查询文档
        @Test
        void testGet() throws IOException {
        
            GetRequest request = new GetRequest("books","1");
            GetResponse response = client.get(request, RequestOptions.DEFAULT);
            String json = response.getSourceAsString();
            System.out.println(json);
        }

根据id查询文档使用的请求对象是GetRequest。

**按条件查询文档**：

@Test
    //按条件查询
    void testSearch() throws IOException {
        
        SearchRequest request = new SearchRequest("books");
        SearchSourceBuilder builder = new SearchSourceBuilder();
        builder.query(QueryBuilders.termQuery("all","spring"));
        request.source(builder);
    
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        for (SearchHit hit : hits) {
        
            String source = hit.getSourceAsString();
            //System.out.println(source);
            Book book = JSON.parseObject(source, Book.class);
            System.out.println(book);
        }
    }

\*\*注：\*\*按条件查询文档使用的请求对象是SearchRequest，查询时调用SearchRequest对象的termQuery方法，需要给出查询属性名，此处支持使用合并字段，也就是前面定义索引属性时添加的all属性。

**根据id删除：**

@Test
        void testDelete() throws IOException {
        
           DeleteRequest request = new DeleteRequest("books","1");
           client.delete(request,RequestOptions.DEFAULT);
        }

##### 总结： #####

1.添加单个文档用index，添加所有文档用bulk，按id查询用get，按id删除用delete，按id更新用update。

2.操作索引用indices；