济宁网站,建设工程教育网官网学员登录,运城做网站方式方法,编写软件的步骤前提条件#xff1a;安装好了elastic search服务#xff0c;参考#xff1a;elastic search入门_ubuntu elasticsearch 密码-CSDN博客
1、配置elastic search必须使用用户名密码授权才能访问
1.1开启x-pack验证
修改config目录下面的elasticsearch.yml文件#xff0c;添…前提条件安装好了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 [typesecurity_exception, reasonmissing authentication credentials for REST request [/users/_search?typed_keystruemax_concurrent_shard_requests5ignore_unavailablefalseexpand_wildcardsopenallow_no_indicestrueignore_throttledtruesearch_typequery_then_fetchbatched_reduce_size512ccs_minimize_roundtripstrue]]
]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_keystruemax_concurrent_shard_requests5ignore_unavailablefalseexpand_wildcardsopenallow_no_indicestrueignore_throttledtruesearch_typequery_then_fetchbatched_reduce_size512ccs_minimize_roundtripstrue], status line [HTTP/1.1 401 Unauthorized]
{error:{root_cause:[{type:security_exception,reason:missing authentication credentials for REST request [/users/_search?typed_keystruemax_concurrent_shard_requests5ignore_unavailablefalseexpand_wildcardsopenallow_no_indicestrueignore_throttledtruesearch_typequery_then_fetchbatched_reduce_size512ccs_minimize_roundtripstrue],header:{WWW-Authenticate:Basic realm\security\ charset\UTF-8\}}],type:security_exception,reason:missing authentication credentials for REST request [/users/_search?typed_keystruemax_concurrent_shard_requests5ignore_unavailablefalseexpand_wildcardsopenallow_no_indicestrueignore_throttledtruesearch_typequery_then_fetchbatched_reduce_size512ccs_minimize_roundtripstrue],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;}}运行测试方法结果如下
