ElasticSearch整合SpringBoot搭建配置

<? xml version = "1.0" encoding = "UTF-8" ?>

< project xmlns = "http://maven.apache.org/POM/4.0.0"

          xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"

          xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >

     < modelVersion >4.0.0</ modelVersion >

     < groupId >org.example</ groupId >

     < artifactId >springboot-es-all</ artifactId >

     < version >1.0-SNAPSHOT</ version >

     < properties >

         < java.version >1.8</ java.version >

     </ properties >

     < parent >

         < groupId >org.springframework.boot</ groupId >

         < artifactId >spring-boot-starter-parent</ artifactId >

         < version >2.1.3.RELEASE</ version >

     </ parent >

     < dependencies >

         <!--test-->

         < dependency >

             < groupId >org.springframework.boot</ groupId >

             < artifactId >spring-boot-starter-test</ artifactId >

         </ dependency >

         <!--ElasticSearch 客户端依赖-->

         < dependency >

             < groupId >org.elasticsearch.client</ groupId >

             < artifactId >elasticsearch-rest-client</ artifactId >

             < version >7.8.0</ version >

         </ dependency >

         < dependency >

             < groupId >org.elasticsearch</ groupId >

             < artifactId >elasticsearch</ artifactId >

             < version >7.8.0</ version >

         </ dependency >

         < dependency >

             < groupId >org.elasticsearch.client</ groupId >

             < artifactId >elasticsearch-rest-high-level-client</ artifactId >

             < version >7.8.0</ version >

         </ dependency >

         <!--Hutool依赖-->

         < dependency >

             < groupId >cn.hutool</ groupId >

             < artifactId >hutool-all</ artifactId >

             < version >5.8.4</ version >

         </ dependency >

         <!--fast-json-->

         < dependency >

             < groupId >com.alibaba</ groupId >

             < artifactId >fastjson</ artifactId >

             < version >1.2.58</ version >

         </ dependency >

         < dependency >

             < groupId > org.slf4j </ groupId >

             < artifactId > slf4j-api </ artifactId >

             < version > 1.6.4 </ version >

         </ dependency >

         < dependency >

             < groupId >org.slf4j</ groupId >

             < artifactId >slf4j-simple</ artifactId >

             < version >1.7.25</ version >

             < scope >compile</ scope >

         </ dependency >

         < dependency >

             < groupId >org.projectlombok</ groupId >

             < artifactId >lombok</ artifactId >

         </ dependency >

     </ dependencies >

     < build >

         < plugins >

             < plugin >

                 < groupId >org.springframework.boot</ groupId >

                 < artifactId >spring-boot-maven-plugin</ artifactId >

                 < version >2.1.3.RELEASE</ version >

             </ plugin >

         </ plugins >

     </ build >

</ project >

@SpringBootApplication

public class EsStudyApplication {

     public static void main(String[] args) {

         SpringApplication.run(EsStudyApplication. class , args);

     }

}

server:

   port: 9000

elasticsearch:

   host: 0.0.0.0

   port: 9200

   username:

   password:

@Configuration

public class EsClientConfig {

     @Value ( "${elasticsearch.host}" )

     private String host;

     @Value ( "${elasticsearch.port}" )

     private int port;

     @Value ( "${elasticsearch.username}" )

     private String userName;

     @Value ( "${elasticsearch.password}" )

     private String password;

     @Bean

     public RestHighLevelClient restHighLevelClient() {

         final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();

         credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(userName, password));

         RestHighLevelClient restHighLevelClient = new RestHighLevelClient(

                 RestClient.builder( new HttpHost( host, port, "http" )).setHttpClientConfigCallback(httpClientBuilder -&gt; {

                     httpClientBuilder.setMaxConnTotal( 500 );

                     httpClientBuilder.setMaxConnPerRoute( 300 );

                     return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);

                 })

         );

         return restHighLevelClient;

     }

}

@Slf4j

@SpringBootTest

public class IndexApi {

     /**

      * es 索引

      */

     public static final String index = "study" ;

     @Autowired

     private RestHighLevelClient client;

     @Test

     public void ping() throws IOException {

         if (client.ping(RequestOptions.DEFAULT)) {

             log.info( "链接成功" );

         } else {

             log.info( "链接失败 !" );

         }

     }

}   

@RunWith (SpringRunner. class )

@SpringBootTest (classes = { EsStudyApplication. class })

public class IndexApi {....}

/**

      * 创建索引

      */

     @Test

     public void createIndex() throws IOException {

         CreateIndexRequest request = new CreateIndexRequest(index);

         CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);

         log.info( "创建索引 ===> " + JSONObject.toJSONString(createIndexResponse)); // 创建索引 ===> {"acknowledged":true,"fragment":false,"shardsAcknowledged":true}

     }

// alias

request.alias( new Alias( "study_alias" ));

// index settings

request.settings(

         Settings.builder()

                 .put( "index.number_of_shards" , 3 )

                 .put( "index.number_of_replicas" , 2 )

);

// index mappings

//        {

//            "mapping": {

//            "_doc": {

//                "properties": {

//                    "name": {

//                        "type": "text"

//                    }

//                }

//            }

//        }

//        }

XContentBuilder builder = XContentFactory.jsonBuilder();

builder.startObject();

{

     builder.startObject( "properties" );

     {

         builder.startObject( "name" );

         {

             builder.field( "type" , "text" );

         }

         builder.endObject();

     }

     builder.endObject();

}

builder.endObject();

request.mapping(builder);

// 请求设置

request.setTimeout(TimeValue.timeValueMinutes( 1 ));

/**

     * 判断索引是否存在

     * @throws IOException

     */

@Test

public void existIndex() throws IOException {

     GetIndexRequest request = new GetIndexRequest(index);

     boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);

     log.info( "索引{}存在 ===> {}" , index, exists);

}

/**

     * 删除索引

     * @throws IOException

     */

@Test

public void delIndex() throws IOException {

     DeleteIndexRequest request = new DeleteIndexRequest(index);

     AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);

     log.info( "删除索引 ===> {}" , JSONObject.toJSONString(delete)); // 删除索引 ===> {"acknowledged":true,"fragment":false}

}