Elasticsearch设置密码，通过springboot调用。

短命女 2022-11-18 10:50 314阅读 0赞

在系统上线以后为了系统安全需要给Elasticsearch配置密码。

**配置密码访问**  
首先修改es配置文件  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RlcnJ5NzEx_size_16_color_FFFFFF_t_70]  
在最后添加，添加后要重启es

xpack.security.enabled: true

然后到bin目录下执行

bin/elasticsearch-setup-passwords interactive

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RlcnJ5NzEx_size_16_color_FFFFFF_t_70 1]  
配置kibana  
![在这里插入图片描述][202104130925416.png]  
在最后添加

elasticsearch.username: "elastic"
    elasticsearch.password: "123456"

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RlcnJ5NzEx_size_16_color_FFFFFF_t_70 2]

启动kibana 这个时候需要输入密码了

**springboot访问带有密码的Elasticsearch**

上一章写了springboot怎么访问es  
见 [springboot整合Java High Level REST Client调动elasticsearch进行增删改查][springboot_Java High Level REST Client_elasticsearch]  
修改spring.yml

elasticsearch:
      schema: http
      address: 127.0.0.1:9200
      connectTimeout: 5000
      socketTimeout: 5000
      connectionRequestTimeout: 5000
      maxConnectNum: 100
      maxConnectPerRoute: 100
      UserName: elastic
      Password: 123456

修改ElasticSearchConfiguration类

package com.zcdsj.ElasticSearch;
    
    import org.apache.http.HttpHost;
    import org.apache.http.auth.AuthScope;
    import org.apache.http.auth.UsernamePasswordCredentials;
    import org.apache.http.client.CredentialsProvider;
    import org.apache.http.impl.client.BasicCredentialsProvider;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestClientBuilder;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
     
    import java.util.ArrayList;
    import java.util.List;
     
     
    /** * @Deacription ElasticSearch 配置 * @Author x **/
    @Configuration
    public class ElasticSearchConfiguration { 
        /** 协议 */
        @Value("${elasticsearch.schema:http}")
        private String schema;
     
        /** 集群地址，如果有多个用“,”隔开 */
        @Value("${elasticsearch.address}")
        private String address;
     
        /** 连接超时时间 */
        @Value("${elasticsearch.connectTimeout}")
        private int connectTimeout;
     
        /** Socket 连接超时时间 */
        @Value("${elasticsearch.socketTimeout}")
        private int socketTimeout;
     
        /** 获取连接的超时时间 */
        @Value("${elasticsearch.connectionRequestTimeout}")
        private int connectionRequestTimeout;
     
        /** 最大连接数 */
        @Value("${elasticsearch.maxConnectNum}")
        private int maxConnectNum;
     
        /** 最大路由连接数 */
        @Value("${elasticsearch.maxConnectPerRoute}")
        private int maxConnectPerRoute;
          
        @Value("${elasticsearch.UserName}")
        private String userName;
        
        @Value("${elasticsearch.Password}")
        private String password;
        
     
        @Bean(name = "restHighLevelClient")
        public RestHighLevelClient restHighLevelClient() { 
            // 拆分地址
            List<HttpHost> hostLists = new ArrayList<>();
            String[] hostList = address.split(",");
            for (String addr : hostList) { 
                String host = addr.split(":")[0];
                String port = addr.split(":")[1];
                hostLists.add(new HttpHost(host, Integer.parseInt(port), schema));
            }
            
            final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
            credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(userName, password));
            
            // 转换成 HttpHost 数组
            HttpHost[] httpHost = hostLists.toArray(new HttpHost[]{ });
            // 构建连接对象
            RestClientBuilder builder = RestClient.builder(httpHost);
            // 异步连接延时配置
            builder.setRequestConfigCallback(requestConfigBuilder -> { 
                requestConfigBuilder.setConnectTimeout(connectTimeout);
                requestConfigBuilder.setSocketTimeout(socketTimeout);
                requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeout);
                return requestConfigBuilder;
            });
            // 异步连接数配置
            builder.setHttpClientConfigCallback(httpClientBuilder -> { 
                httpClientBuilder.setMaxConnTotal(maxConnectNum);
                httpClientBuilder.setMaxConnPerRoute(maxConnectPerRoute);
                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
            });
            return new RestHighLevelClient(builder);
        }
    }

ie中打开 http://127.0.0.1:8082/all/addDocument 密码访问就完成了

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RlcnJ5NzEx_size_16_color_FFFFFF_t_70]: /images/20221022/a62e48f8371447adb046c4a0a50c53a8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RlcnJ5NzEx_size_16_color_FFFFFF_t_70 1]: /images/20221022/acb58aeaad914846bfec6000110e98c0.png
[202104130925416.png]: /images/20221022/8c105bf51e0843129fc1dbc1c2a1651d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RlcnJ5NzEx_size_16_color_FFFFFF_t_70 2]: /images/20221022/7ab5b918e75a40ee8a14dc34149ada9a.png
[springboot_Java High Level REST Client_elasticsearch]: https://blog.csdn.net/terry711/article/details/115536259