spring boot学习第十篇:elastic search必须使用用户名密码授权后才能访问、在java代码中操作索引

本文主要是介绍spring boot学习第十篇:elastic search必须使用用户名密码授权后才能访问、在java代码中操作索引，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

前提条件：安装好了elastic search服务，参考：elastic search入门_ubuntu elasticsearch 密码-CSDN博客

1、配置elastic search必须使用用户名密码授权才能访问

1.1开启x-pack验证

修改config目录下面的elasticsearch.yml文件，添加如下代码到文件末，开启x-pack验证

xpack.security.enabled: true
xpack.security.transport.ssl.enabled: true

参数说明：
xpack.security.enabled：表示开启xpack认证机制。
xpack.security.transport.ssl.enabled：这条如果不配，es将起不来

1.2启动elastic search服务

1.3设置用户名和密码

bin/elasticsearch-setup-passwords interactive

然后访问版本说明页，需要输入用户名密码登录才能访问

登录成功，如下：

2、在spring boot框架下操作索引

之前不需用户名密码的博客：spring boot学习第八篇:操作elastic search的索引和索引中的数据-CSDN博客

方法都报错了，报错如下：

ElasticsearchStatusException[Elasticsearch exception [type=security_exception, reason=missing authentication credentials for REST request [/users/_search?typed_keys=true&max_concurrent_shard_requests=5&ignore_unavailable=false&expand_wildcards=open&allow_no_indices=true&ignore_throttled=true&search_type=query_then_fetch&batched_reduce_size=512&ccs_minimize_roundtrips=true]]
]at org.elasticsearch.rest.BytesRestResponse.errorFromXContent(BytesRestResponse.java:187)at org.elasticsearch.client.RestHighLevelClient.parseEntity(RestHighLevelClient.java:1892)at org.elasticsearch.client.RestHighLevelClient.parseResponseException(RestHighLevelClient.java:1869)at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1626)at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1583)at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1553)at org.elasticsearch.client.RestHighLevelClient.search(RestHighLevelClient.java:1069)at com.hmblogs.backend.util.ElasticsearchClientTest.search(ElasticsearchClientTest.java:156)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect.Method.invoke(Method.java:498)at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)at org.springframework.test.context.junit4.statements.RunBeforeTestExecutionCallbacks.evaluate(RunBeforeTestExecutionCallbacks.java:74)at org.springframework.test.context.junit4.statements.RunAfterTestExecutionCallbacks.evaluate(RunAfterTestExecutionCallbacks.java:84)at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75)at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86)at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84)at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:251)at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:97)at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)at org.junit.runners.ParentRunner.run(ParentRunner.java:413)at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:190)at org.junit.runner.JUnitCore.run(JUnitCore.java:137)at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69)at com.intellij.rt.junit.IdeaTestRunner$Repeater$1.execute(IdeaTestRunner.java:38)at com.intellij.rt.execution.junit.TestsRepeater.repeat(TestsRepeater.java:11)at com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:35)at com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:232)at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:55)Suppressed: org.elasticsearch.client.ResponseException: method [POST], host [http://43.138.0.199:9200], URI [/users/_search?typed_keys=true&max_concurrent_shard_requests=5&ignore_unavailable=false&expand_wildcards=open&allow_no_indices=true&ignore_throttled=true&search_type=query_then_fetch&batched_reduce_size=512&ccs_minimize_roundtrips=true], status line [HTTP/1.1 401 Unauthorized]
{"error":{"root_cause":[{"type":"security_exception","reason":"missing authentication credentials for REST request [/users/_search?typed_keys=true&max_concurrent_shard_requests=5&ignore_unavailable=false&expand_wildcards=open&allow_no_indices=true&ignore_throttled=true&search_type=query_then_fetch&batched_reduce_size=512&ccs_minimize_roundtrips=true]","header":{"WWW-Authenticate":"Basic realm=\"security\" charset=\"UTF-8\""}}],"type":"security_exception","reason":"missing authentication credentials for REST request [/users/_search?typed_keys=true&max_concurrent_shard_requests=5&ignore_unavailable=false&expand_wildcards=open&allow_no_indices=true&ignore_throttled=true&search_type=query_then_fetch&batched_reduce_size=512&ccs_minimize_roundtrips=true]","header":{"WWW-Authenticate":"Basic realm=\"security\" charset=\"UTF-8\""}},"status":401}at org.elasticsearch.client.RestClient.convertResponse(RestClient.java:302)at org.elasticsearch.client.RestClient.performRequest(RestClient.java:272)at org.elasticsearch.client.RestClient.performRequest(RestClient.java:246)at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1613)... 37 more

application.yml配置文件es节点信息改成如下：

es:host: 43.138.0.199port: 9200scheme: httpuser: elasticpassword: Woaihm13141314!

ElasticConfig文件内容如下：

package com.hmblogs.backend.util;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;@Configuration
public class ElasticConfig {@Value("${es.host}")public String host;@Value("${es.port}")public int port;@Value("${es.scheme}")public String scheme;@Value("${es.user}")public String user;@Value("${es.password}")public String password;@Bean(destroyMethod = "close")public RestHighLevelClient getRestHighLevelClient() {RestClientBuilder builder = RestClient.builder(new HttpHost(host, port, scheme));// 异步httpclient连接延时配置builder.setRequestConfigCallback(requestConfigBuilder -> {requestConfigBuilder.setConnectTimeout(30*60);requestConfigBuilder.setSocketTimeout(30*60);requestConfigBuilder.setConnectionRequestTimeout(30*60);return requestConfigBuilder;});// 用户认证对象CredentialsProvider credentialsProvider = new BasicCredentialsProvider();// 设置账号密码credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(user,password));// 异步httpclient连接数配置builder.setHttpClientConfigCallback(httpClientBuilder -> {httpClientBuilder.setMaxConnTotal(100);httpClientBuilder.setMaxConnPerRoute(100);// 设置账号密码httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);return httpClientBuilder;});builder.setHttpClientConfigCallback(httpAsyncClientBuilder ->httpAsyncClientBuilder.setDefaultCredentialsProvider(credentialsProvider));RestHighLevelClient client = new RestHighLevelClient(builder);return client;}}

运行测试方法，结果如下：