【郑州校区】Java的新项目学成在线笔记-day11（六） - 黑马程序员技术交流社区

[AppleScript] 纯文本查看 复制代码

server:   port: 40100 spring:   application:     

name: xc‐search‐service elasticsearch:  

 hostlist: 127.0.0.1:9200 #多个结点中间用逗号分隔 

  course:     index: xc_course  

   type: doc

[AppleScript] 纯文本查看 复制代码

package com.xuecheng.search.config;  

 import org.apache.http.HttpHost;

 import org.elasticsearch.client.RestClient; 

import org.elasticsearch.client.RestHighLevelClient;

 import org.springframework.beans.factory.annotation.Value;

[AppleScript] 纯文本查看 复制代码

import org.springframework.context.annotation.Bean;

 import org.springframework.context.annotation.Configuration;     @Configuration public class ElasticsearchConfig {     

  @Value("${xuecheng.elasticsearch.hostlist}") 

    private String hostlist;   

    @Bean  

   public RestHighLevelClient restHighLevelClient(){   

      //解析hostlist配置信息   

      String[] split = hostlist.split(",");    

     //创建HttpHost数组，其中存放es主机和端口的配置信息   

      HttpHost[] httpHostArray = new HttpHost[split.length];      

   for(int i=0;i<split.length;i++){        

     String item = split;       

      httpHostArray = new HttpHost(item.split(":")[0], Integer.parseInt(item.split(":") [1]), "http");     

    }     

    //创建RestHighLevelClient客户端   

      return new RestHighLevelClient(RestClient.builder(httpHostArray)); 

    }   

    @Bean     public RestClient restClient(){     

    //解析hostlist配置信息       

  String[] split = hostlist.split(",");     

    //创建HttpHost数组，其中存放es主机和端口的配置信息      

   HttpHost[] httpHostArray = new HttpHost[split.length];   

      for(int i=0;i<split.length;i++){      

       String item = split;         

    httpHostArray = new HttpHost(item.split(":")[0], Integer.parseInt(item.split(":") [1]), "http");  

       }      

   return RestClient.builder(httpHostArray).build();  

   }   }