-
大小: 9KB文件类型: .java金币: 1下载: 0 次发布日期: 2021-05-14
- 语言: Java
- 标签: elastic es restclient 索引操作
资源简介
改类封装elasticsearch5.x以rest风格操作的索引的部分api。类中有详细的注释,可供参考学习。希望能帮到有需要的同学。
代码片段和文件信息
package com.minstone.statisplatform.manager.elasticsearch;
import java.io.IOException;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import org.apache.http.HttpEntity;
import org.apache.http.HttpHost;
import org.apache.http.StatusLine;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.entity.ContentType;
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
import org.apache.http.impl.nio.reactor.IOReactorConfig;
import org.apache.http.nio.entity.NStringEntity;
import org.elasticsearch.action.DocWriteRequest;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.Response;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.rest.RestStatus;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import com.alibaba.fastjson.JSON;
import com.minstone.statisplatform.common.exception.ESIndexException;
import com.minstone.statisplatform.manager.statis.model.ArchiveMapper;
import com.minstone.statisplatform.manager.statis.model.ArchiveMapperVo;
/**
* ClassName: ESTransportClient
* @Description: Elasticsearch操作类
* 索引操作API:
* low level https://www.elastic.co/guide/en/elasticsearch/client/java-rest/5.6/java-rest-low.html
* high level https://www.elastic.co/guide/en/elasticsearch/client/java-rest/5.6/java-rest-high.html
* @author JornTang
* @date 2017年12月21日
*/
public class ESRestClient {
private static Logger log = LoggerFactory.getLogger(ESRestClient.class);
private static RestClient lowLevelRestClient = null;
private static RestHighLevelClient highLevelRestClient = null;
/**
* @Description: 初始化
* @return void
* @throws
* @author JornTang
* @date 2017年12月23日
*/
public void init(){
RestClientBuilder builder = RestClient.builder(new HttpHost(“127.0.0.1“ 9200));
builder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
@Override
public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder requestConfigBuilder) {
requestConfigBuilder.setConnectTimeout(10000);
requestConfigBuilder.setSocketTimeout(30000);
requestConfigBuilder.setConnectionRequestTimeout(10000);
return requestConfigBuilder;
}
});
builder.setHttpClientConfigCallback(new RestClientBuilder.Http
相关资源
- Java 文件加密传输
- java access 仓库管理系统 源码
- DES(CFB) JAVA
- 超级好的纯jsp写的聊天室
- java多人五子棋源码
- jsp 统计在线人数利用HttpSessionListene
- Advanced Design and Implementation of Virtual
- jersey1.18 jar包
- C#和Java实现互通的RSADES加解密算法
-
JAVA代码注释规范codetemplates.xm
l - Data Structures and Algorithm Analysis in Java
- SU5×T13纹理中的三重最大混合
- android-support-design.jar(24.0.0版本)
- charles 3.10.2破解文件
- Notes.jar NCSO.jar Domino
- rest项目所需的jar包
- Android-AccessibilityService无障碍服务库一
- JS实现AES-GCM加密,java实现AES-GCM解密。
- moco-runner-0.12.0-sources.jar
- pdf-chinese.zip
- DES加密解密算法论文
- JAVA+access综合测评系统毕业设计(源代
- TestAR安装包
- 全世界最经典的数据结构教材,Horo
- design-pattern-java-刘伟.pdf
- 一个仿当当的网上商城 Eshop System 前台
- UVPaint (Skinned Mesh Decal System) 1.84e.
- 小型图书管理系统java+access
- java 超级简易java图书管理系统源码
- charles 4.1.3破解替换文件
评论
共有 条评论