Maven依赖
依赖版本号和elasticsearch版本号对应起来
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-client</artifactId><version>7.17.6</version></dependency><!-- elasticSearch --><dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>7.17.6</version></dependency><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.17.6</version><scope>compile</scope></dependency>
YML配置
spring:elasticsearch:rest:uris: http://127.0.0.1:9200,http://127.0.0.1:9201username: elasticpassword: ******
ElasticSearchConfig
集群带用户名密码
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;import java.util.Arrays;@Configuration
public class ElasticSearchConfig {@Value("${spring.elasticsearch.rest.uris}")private String[] uris;@Value("${spring.elasticsearch.rest.username}")private String userName;@Value("${spring.elasticsearch.rest.password}")private String passWord;@Beanpublic RestHighLevelClient restHighLevelClient() {HttpHost[] httpHosts = Arrays.stream(uris).map(HttpHost::create).toArray(HttpHost[]::new);RestClientBuilder builder = RestClient.builder(httpHosts);CredentialsProvider credentialsProvider = new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(userName, passWord));builder.setHttpClientConfigCallback(f -> f.setDefaultCredentialsProvider(credentialsProvider));return new RestHighLevelClient(builder);
}
集群无用户名密码
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;import java.util.Arrays;@Configuration
public class ElasticSearchConfig {@Value("${spring.elasticsearch.rest.uris}")private String[] uris;@Beanpublic RestHighLevelClient restHighLevelClient() {HttpHost[] httpHosts = Arrays.stream(uris).map(HttpHost::create).toArray(HttpHost[]::new);RestClientBuilder builder = RestClient.builder(httpHosts);return new RestHighLevelClient(builder);}}
实体类
@Data
public class CallingLog implements Serializable {private static final long serialVersionUID = 6211869625504817559L;private String id;private String index;private String type;private Date beginTime;private Date endTime;private String request;private String response;private String remark;private String callType;//调用类别
}
插入数据
import com.alibaba.fastjson.JSONObject;
import org.apache.poi.ss.formula.functions.T;
import org.elasticsearch.action.DocWriteRequest;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.core.TimeValue;
import org.elasticsearch.xcontent.XContentType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.lang.reflect.Field;
import java.util.Date;
@Component
public class EsClientUtils {private static final Logger logger = LoggerFactory.getLogger(EsClientUtils.class);/*** 默认超时时间*/private long timeOut = 1L;@Autowiredprivate RestHighLevelClient restHighLevelClient;private Class<? extends T> tClass;/*** 单条数据插入** @param t 放入的对象* @return 响应信息，放入es的基本信息(index、type、id)*/public IndexResponse add(CallingLog t) throws NoSuchFieldException {if (checkIndexTypeId(t)) {return null;}// 按actv_log_230713 格式生成索引String indexStr = DateUtils.formatDate(new Date(), "yyMMdd");String index = t.getIndex();String type = "_doc";String id = IdUtils.fastUUID();final String jsonString = JSONObject.toJSONString(t);final IndexRequest request = new IndexRequest(t.getIndex() + indexStr, type, id).source(jsonString, XContentType.JSON).opType(DocWriteRequest.OpType.CREATE).timeout(TimeValue.timeValueSeconds(timeOut));IndexResponse indexResponse = null;try {indexResponse = restHighLevelClient.index(request, RequestOptions.DEFAULT);} catch (Exception e) {logger.error("es(index:{},type:{},id:{})添加失败：", index, e);}return indexResponse;}/*** 检验必要的值** @param t 与es存储对应的对象* @return true不符合，false符合*/private boolean checkIndexTypeId(CallingLog t) {return t == null || t.getIndex() == null;}}
使用实例
EsClientUtils esClientUtils = ApplicationContextHelper.getBean(EsClientUtils.class);CallingLog callingLog = new CallingLog();callingLog.setIndex("actv_test");callingLog.setCallName("3333");callingLog.setRequest("7777");callingLog.setRemark("6666");callingLog.setBeginTime(new Date());callingLog.setEndTime(new Date());callingLog.setResponse("2222");callingLog.setServiceNum("3333333");esClientUtils.add(crmCallingLog);
