我将 Spring Boot Starter Data Elasticsearch 2.2.3.RELEASE 与 Elasticsearch v6.8.6 结合使用。我配置了 RestHighLevelClient 以连接到集群。
现在我在不同的操作中不断收到 SocketTimeoutException:
java.net.SocketTimeoutException: 5,000 milliseconds timeout on connection http-outgoing-95 [ACTIVE]
at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:387) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92) ~[httpasyncclient-4.1.4.jar!/:4.1.4]
at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39) ~[httpasyncclient-4.1.4.jar!/:4.1.4]
at org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:261) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:502) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:211) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_201]
我可以在 Spring Boot 应用程序中配置套接字超时吗?如果可以,在哪里配置。
我尝试配置 ClientConfiguration 的套接字超时,我创建了 RestHighLevelClient,但没有效果:
ClientConfiguration clientConfiguration = ClientConfiguration.builder()
.connectedTo(nodes)
.withSocketTimeout(Duration.ofSeconds(30))
.build();
RestHighLevelClient client = RestClients.create(clientConfiguration).rest();
简而言之,你应该使用setConnectTimeout
方法(构建时
休息客户端)。
因此,这是我一直在 ES (6.5v) 使用的 Java String Boot (2.1.1.RELEASE) 配置(成功设置连接和套接字超时)。
在直接使用以下源之前,请正确设置 ENV 变量(在 .yml 文件中)。
//yml设置
elasticsearch:
hosts:
host1: // you can set as an array with > sign
name: hostname
port: 9200
username:
password:
connectTimeout: 6000
socketTimeout: 6000
// 配置类
@Configuration
public class ElasticSearchConfig {
@Autowired
private Environment environment;
@Bean(destroyMethod = "close", name = "esHighLevelRestClient")
public RestHighLevelClient highLevelClient() {
return new RestHighLevelClient(restClientBuilder());
}
@Bean(destroyMethod = "close")
public RestClient restClient() {
return restClientBuilder().build();
}
private RestClientBuilder restClientBuilder() {
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY,
new UsernamePasswordCredentials(
environment.getProperty("elasticsearch.username"),
environment.getProperty("elasticsearch.password")));
// you can set N hosts
List<HttpHost> hosts = new ArrayList<>();
hosts.add(new HttpHost(
environment.getProperty("elasticsearch.hosts.host1.name", String.class),
environment.getProperty("elasticsearch.hosts.host1.port", Integer.class),
"http"));
return RestClient.builder(Iterables.toArray(hosts, HttpHost.class))
.setRequestConfigCallback(requestConfigBuilder -> requestConfigBuilder
.setConnectTimeout(environment.getProperty("elasticsearch.connectTimeout", Integer.class))
.setSocketTimeout(environment.getProperty("elasticsearch.socketTimeout", Integer.class)))
.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
}}
希望能帮助到你!
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)