Elasticsearch rest-high-level-client 基本操作 _生活百科

Elasticsearch rest-high-level-client 基本操作

本篇主要讲解一下 rest-high-level-client 去操作 Elasticsearch , 虽然这个客户端在后续版本中会慢慢淘汰,但是目前大部分公司中使用Elasticsearch 版本都是6.x所以这个客户端还是有一定的了解

文章插图
前置准备

准备一个SpringBoot环境2.2.11 版本
准备一个Elasticsearch 环境我这里是8.x版本
引入依赖 elasticsearch-rest-high-level-client7.4.2

1.配置依赖注意: 我使用的是 springboot 2.2.11 版本 , 它内部的 elasticsearch 和 elasticsearch-rest-client 都是 6.8.13 需要注意

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!-- 引入 elasticsearch 7.4.2--><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.4.2</version><exclusions><exclusion><artifactId>log4j-api</artifactId><groupId>org.apache.logging.log4j</groupId></exclusion></exclusions></dependency><!-- 排除 elasticsearch-rest-client , 也可不排除 为了把maven冲突解决--><dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>7.4.2</version><exclusions><exclusion><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-client</artifactId></exclusion><exclusion><artifactId>elasticsearch</artifactId><groupId>org.elasticsearch</groupId></exclusion></exclusions></dependency><!-- 不引入会导致可能 使用 springboot的 elasticsearch-rest-client 6.8.13 --><dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-client</artifactId><version>7.4.2</version></dependency><!-- elasticsearch 依赖 2.x 的 log4j --><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-core</artifactId><version>2.8.2</version><!--排除掉 log4j-api 因为springbootstarter 中引入了loging模块 --><exclusions><exclusion><artifactId>log4j-api</artifactId><groupId>org.apache.logging.log4j</groupId></exclusion></exclusions></dependency><!-- junit 单元测试 --><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></dependency>

2.构建 RestHighLevelClienthighlevelclient 是高级客户端需要通过它去操作 Elasticsearch ,它底层也是要依赖 rest-client 低级客户端

@Slf4jpublic class TestEsClient {private RestHighLevelClient client = null;private ObjectMapper objectMapper = new ObjectMapper();//构建 RestHighLevelClient@Beforepublic void prepare() {// 创建Client连接对象String[] ips = {"172.16.225.111:9200"};HttpHost[] httpHosts = new HttpHost[ips.length];for (int i = 0; i < ips.length; i++) {httpHosts[i] = HttpHost.create(ips[i]);}RestClientBuilder builder = RestClient.builder(httpHosts);client = new RestHighLevelClient(builder);}}

3.创建索引 client.indices().create创建索引需要使用 CreateIndexRequest 对象 , 操作索引基本上是 client.indices().xxx
构建 CreateIndexRequest 对象

@Testpublic void test1() {CreateIndexRequest request = new CreateIndexRequest("blog1");try {CreateIndexResponse createIndexResponse =client.indices().create(request, RequestOptions.DEFAULT);boolean acknowledged = createIndexResponse.isAcknowledged();log.info("[create index blog :{}]", acknowledged);} catch (IOException e) {e.printStackTrace();}}

4.删除索引 client.indices().delete构建 DeleteIndexRequest 对象

@Testpublic void testDeleteIndex(){DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("blog1");try {AcknowledgedResponse response = client.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);log.info("[delete index response: {}", response.isAcknowledged());} catch (IOException e) {e.printStackTrace();}}

4.查询索引 client.indices().get构建 GetIndexRequest 对象

@Testpublic void testSearchIndex() {GetIndexRequest request = new GetIndexRequest("blog1");try {GetIndexResponse getIndexResponse =client.indices().get(request, RequestOptions.DEFAULT);Map<String, List<AliasMetaData>> aliases = getIndexResponse.getAliases();Map<String, MappingMetaData> mappings = getIndexResponse.getMappings();Map<String, Settings> settings = getIndexResponse.getSettings();log.info("[aliases: {}]", aliases);log.info("[mappings: {}]", mappings);log.info("[settings: {}", settings);} catch (IOException e) {e.printStackTrace();}}
上一页
1
2
下一页
		  	

    
    




    
    
    


推荐阅读

           
                  
              
                  白羊座最适合的运动 
                
                   
                
              
            

                  
              
                  职工医保和城乡居民医保哪个划算？交哪个好 
                
                   
                
              
            

                  
              
                  关于来不及诉说简述 来不及诉说 
                
                   
                
              
            

                  
              
                  形容教室里很多人的成语 
                
                   
                
              
            

                  
              
                  肉煎饺的做法步骤 肉煎饺的做法步骤 
                
                   
                
              
            

                  
              
                  越在乎你才会越嫌弃你的星座，天蝎上榜！ 
                
                   
                
              
            

                  
              
                  伊美婷成分  伊美婷胶原蛋白安全吗 
                
                   
                
              
            

                  
              
                  保护视力的绘画作品 保护视力的绘画作品画法 
                
                   
                
              
            

                  
              
                  属兔的适合住什么楼层最好 住几楼大吉？ 
                
                   
                
              
            

                  
              
                  攀升MaxBook P2参数_攀升MaxBook P2配置 
                
                   
                
              
            

                  
              
                  荞麦茶的功效有哪些 荞麦茶有什么作用功效 
                
                   
                
              
            

                  
              
                  铝锅煮汤对人体有害吗，不建议经常使用铝锅煮汤 
                
                   
                
              
            

                  
              
                  发朋友圈运动的幽默句子 发朋友圈运动句子 
                
                   
                
              
            

                  
              
                  《四季豆一定要焯水吗》 
                
                   
                
              
            

                  
              
                  王丽云主演的电视剧有哪些 王丽云演的全部电视剧 
                
                   
                
              
            

                  
              
                  大连金普新区文旅场馆7月19日起取消查验核酸报告 
                
                   
                
              
            

                  
              
                  江苏省公务员abc类区别 江苏省公务员abc类的区别 
                
                   
                
              
            

                  
              
                  电脑版微信怎么发朋友圈 电脑版微信怎么发朋友圈视频 
                
                   
                
              
            

                  
              
                  芋头和香芋一样吗？芋头什么人不能多吃 
                
                   
                
              
            

                  
              
                  鱼鳞痣怎么祛除掉 鱼鳞痣怎么祛除 
                
                   
                
              
            

          

Hyperf使用ElasticSearch记录 

Mysql通过Canal同步Elasticsearch 

4 Java注解：一个真实的Elasticsearch案例 

3 Java注解：一个真实Elasticsearch案例 

2. 单主机 Elasticsearch 双节点或多节点集群环境部署 

JuiceFS 在 Elasticsearch/ClickHouse 温冷数据存储中的实践 

elasticsearch怎么读 search怎么读