免费的信息发布平台,哪个网站seo做的最好,网站建设与维护教程,网站建设去超速云建站如何处理#xff1a;
代码的心跳代码删除#xff0c;服务linux内核参数修改 客户端时间要小于服务端时间#异常代码
public RestHighLevelClient elasticsearchClient() {// 初始化 RestClient, hostName 和 port 填写集群的内网 IP 地址与端口
// String[] hosts nod…如何处理
代码的心跳代码删除服务linux内核参数修改 客户端时间要小于服务端时间#异常代码
public RestHighLevelClient elasticsearchClient() {// 初始化 RestClient, hostName 和 port 填写集群的内网 IP 地址与端口
// String[] hosts nodes1.split(,);
// HttpHost[] httpHosts new HttpHost[hosts.length];
// for (int i 0; i hosts.length; i) {
// httpHosts[i] new HttpHost(hosts[i], port1, http);
// }String[] hosts uris.split(:);HttpHost[] httpHosts new HttpHost[1];httpHosts[0] new HttpHost(hosts[0], Integer.valueOf(hosts[1]), http);// 设置认证信息CredentialsProvider credentialsProvider new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));RestClientBuilder builder RestClient.builder(httpHosts);//异步链接延时配置builder.setRequestConfigCallback(requestConfigBuilder -requestConfigBuilder .setConnectTimeout(5000) //5秒.setSocketTimeout(5000 * 1000).setConnectionRequestTimeout(5000 * 1000));//异步链接数配置builder.setHttpClientConfigCallback(httpClientBuilder - {//最大连接数100个httpClientBuilder.setMaxConnTotal(100);//最大路由连接数httpClientBuilder.setMaxConnPerRoute(100);httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);// 设置KeepAlive为5分钟的时间不设置默认为-1也就是持续连接然而这会受到外界的影响比如Firewall会将TCP连接单方面断开从而会导致Connection reset by peer的报错
httpClientBuilder.setKeepAliveStrategy((response, context) - TimeUnit.MINUTES.toMillis(3))
.setDefaultIOReactorConfig(IOReactorConfig.custom().setIoThreadCount(1).setSoKeepAlive(true).build()); return new RestHighLevelClient(builder);} 正确代码 public RestHighLevelClient elasticsearchClient() {// 初始化 RestClient, hostName 和 port 填写集群的内网 IP 地址与端口
// String[] hosts nodes1.split(,);
// HttpHost[] httpHosts new HttpHost[hosts.length];
// for (int i 0; i hosts.length; i) {
// httpHosts[i] new HttpHost(hosts[i], port1, http);
// }String[] hosts uris.split(:);HttpHost[] httpHosts new HttpHost[1];httpHosts[0] new HttpHost(hosts[0], Integer.valueOf(hosts[1]), http);// 设置认证信息CredentialsProvider credentialsProvider new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));RestClientBuilder builder RestClient.builder(httpHosts);//异步链接延时配置builder.setRequestConfigCallback(requestConfigBuilder -requestConfigBuilder//.setConnectTimeout(5000) //5秒//.setSocketTimeout(5000 * 1000).setConnectionRequestTimeout(5000 * 1000));//异步链接数配置builder.setHttpClientConfigCallback(httpClientBuilder - {//最大连接数100个httpClientBuilder.setMaxConnTotal(100);//最大路由连接数httpClientBuilder.setMaxConnPerRoute(100);httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);// 设置KeepAlive为5分钟的时间不设置默认为-1也就是持续连接然而这会受到外界的影响比如Firewall会将TCP连接单方面断开从而会导致Connection reset by peer的报错httpClientBuilder.setDefaultIOReactorConfig(IOReactorConfig.custom().setSoKeepAlive(true).build());return httpClientBuilder;});return new RestHighLevelClient(builder);}
