Skip to content

A
amos-boot-biz
Commit 1326bb66 authored by tangwei's avatar tangwei
Browse files
Options

修改数据

parent 12e87036
Hide whitespace changes
Inline Side-by-side
Showing with 69 additions and 69 deletions
amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/config/ElasticSearchClientConfig.java
View file @ 1326bb66
package com.yeejoin.amos.boot.module.jxiop.biz.config; //package com.yeejoin.amos.boot.module.jxiop.biz.config;
import org.apache.commons.lang3.StringUtils; //import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpHost; //import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope; //import org.apache.http.auth.AuthScope;
import org.apache.http.auth.Credentials; //import org.apache.http.auth.Credentials;
import org.apache.http.auth.UsernamePasswordCredentials; //import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider; //import org.apache.http.client.CredentialsProvider;
import org.apache.http.client.config.RequestConfig; //import org.apache.http.client.config.RequestConfig;
import org.apache.http.impl.client.BasicCredentialsProvider; //import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder; //import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
import org.apache.http.message.BasicHeader; //import org.apache.http.message.BasicHeader;
import org.apache.tomcat.util.codec.binary.Base64; //import org.apache.tomcat.util.codec.binary.Base64;
import org.elasticsearch.client.RestClient; //import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder; //import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient; //import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Qualifier; //import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value; //import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean; //import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; //import org.springframework.context.annotation.Configuration;
//
@Configuration //@Configuration
public class ElasticSearchClientConfig { //public class ElasticSearchClientConfig {
//
@Value("${spring.elasticsearch.rest.uris}") // @Value("${spring.elasticsearch.rest.uris}")
private String uris; // private String uris;
@Value("${elasticsearch.username}") // @Value("${elasticsearch.username}")
private String username; // private String username;
//
@Value("${elasticsearch.password}") // @Value("${elasticsearch.password}")
private String password; // private String password;
//
@Bean // @Bean
@Qualifier("highLevelClient") // @Qualifier("highLevelClient")
public RestHighLevelClient restHighLevelClient() { // public RestHighLevelClient restHighLevelClient() {
//
try { // try {
String url = uris.replace("http://", ""); // String url = uris.replace("http://", "");
final String[] parts = StringUtils.split(url, ":"); // final String[] parts = StringUtils.split(url, ":");
HttpHost httpHost = new HttpHost(parts[0], Integer.parseInt(parts[1]), "http"); // HttpHost httpHost = new HttpHost(parts[0], Integer.parseInt(parts[1]), "http");
RestClientBuilder builder = RestClient.builder(httpHost); // RestClientBuilder builder = RestClient.builder(httpHost);
//增加安全配置，使用kibana,勿删 // //增加安全配置，使用kibana,勿删
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider(); // final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, // credentialsProvider.setCredentials(AuthScope.ANY,
new UsernamePasswordCredentials(username, password)); // new UsernamePasswordCredentials(username, password));
builder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() { // builder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
// 该方法接收一个RequestConfig.Builder对象，对该对象进行修改后然后返回。 // // 该方法接收一个RequestConfig.Builder对象，对该对象进行修改后然后返回。
@Override // @Override
public RequestConfig.Builder customizeRequestConfig( // public RequestConfig.Builder customizeRequestConfig(
RequestConfig.Builder requestConfigBuilder) { // RequestConfig.Builder requestConfigBuilder) {
return requestConfigBuilder.setConnectTimeout(5000 * 1000) // 连接超时（默认为1秒） // return requestConfigBuilder.setConnectTimeout(5000 * 1000) // 连接超时（默认为1秒）
.setSocketTimeout(6000 * 1000);// 套接字超时（默认为30秒）//更改客户端的超时限制默认30秒现在改为100*1000分钟 // .setSocketTimeout(6000 * 1000);// 套接字超时（默认为30秒）//更改客户端的超时限制默认30秒现在改为100*1000分钟
} // }
});// 调整最大重试超时时间（默认为30秒）.setMaxRetryTimeoutMillis(60000); // });// 调整最大重试超时时间（默认为30秒）.setMaxRetryTimeoutMillis(60000);
//增加安全配置，使用kibana,勿删 // //增加安全配置，使用kibana,勿删
builder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() { // builder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
@Override // @Override
public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) { // public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
httpClientBuilder.disableAuthCaching(); // httpClientBuilder.disableAuthCaching();
return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider); // return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
} // }
}); // });
return new RestHighLevelClient(builder); // return new RestHighLevelClient(builder);
} catch (Exception e) { // } catch (Exception e) {
throw new IllegalStateException("Invalid ES nodes " + "property '" + uris + "'", e); // throw new IllegalStateException("Invalid ES nodes " + "property '" + uris + "'", e);
} // }
} // }
} //}
amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/DemoController.java
View file @ 1326bb66
...@@ -114,7 +114,7 @@ public class DemoController extends BaseController { ...@@ -114,7 +114,7 @@ public class DemoController extends BaseController {
for (MonitorFanIndicator monitorFanIndicator : list) { for (MonitorFanIndicator monitorFanIndicator : list) {
ESEquipments eSEquipments=new ESEquipments( ESEquipments eSEquipments=new ESEquipments(
0.33355, null,
monitorFanIndicator.getAddressGateway(), monitorFanIndicator.getAddressGateway(),
monitorFanIndicator.getIndexAddress(), monitorFanIndicator.getIndexAddress(),
monitorFanIndicator.getDataType(), monitorFanIndicator.getDataType(),
...@@ -208,7 +208,7 @@ public class DemoController extends BaseController { ...@@ -208,7 +208,7 @@ public class DemoController extends BaseController {
ESEquipments eSEquipments=new ESEquipments( ESEquipments eSEquipments=new ESEquipments(
0.33355, null,
monitorFanIndicator.getAddressGateway(), monitorFanIndicator.getAddressGateway(),
monitorFanIndicator.getIndexAddress(), monitorFanIndicator.getIndexAddress(),
monitorFanIndicator.getDataType(), monitorFanIndicator.getDataType(),
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment