Elasticsearch Rest Client实战

Elasticsearch Rest Client实战

Elasticsearch官方推荐使用Java REST客户端连接集群并进行数据操作。Java REST client有两种:一种是Java Low Level REST Client, 使用该客户端需要将http请求的body手动拼成json格式,http响应也必须将返回的json数据手动封装成对象;另外一种是Java High Level REST Client, 该客户端基于低级客户端实现,提供API解决低级客户端需要手动转换数据格式的问题。

Java High Level REST Client

使用Java High Level REST Client访问集群,示例步骤与代码如下:

1 添加maven依赖

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>5.6.11</version>
</dependency>

2 实战代码

import org.apache.http.HttpHost;
import org.apache.log4j.Logger;
import org.elasticsearch.ElasticsearchException;
import org.elasticsearch.action.DocWriteResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.rest.RestStatus;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;
/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: bellengao, bellengao@tencent.com
 * Date: 2018-08-27
 * Time: 下午6:00
 */
public class TestHighLevelRestClient {
    private static Logger logger = Logger.getLogger(TestHighLevelRestClient.class);

    public  static void main(String[]args){
        // 初始化RestClient, hostName和port填写集群的内网vip地址与端口
        RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200, "http"));
        // 设置超时时间
        builder.setMaxRetryTimeoutMillis(10000);
        RestClient restClient = builder.build();
        // 由Low Level Client构造High Level Client
        RestHighLevelClient client = new RestHighLevelClient(restClient);

        // 索引文档
        Map<String, Object> jsonMap = new HashMap<String, Object>();
        jsonMap.put("user", "bellen");
        jsonMap.put("name", new Date());
        jsonMap.put("message", "trying out Elasticsearch");
        IndexRequest indexRequest = new IndexRequest("posts", "doc", "1")
                .source(jsonMap);

        try {
            // 获取响应结果
            IndexResponse indexResponse = client.index(indexRequest);
            String index = indexResponse.getIndex();
            String type = indexResponse.getType();
            String id = indexResponse.getId();
            long version = indexResponse.getVersion();

            if (indexResponse.getResult() == DocWriteResponse.Result.CREATED) {
                logger.info("doc indexed, index: "+ index +", type:"+ type +",id:"+ id+",version:"+version);
            } else if (indexResponse.getResult() == DocWriteResponse.Result.UPDATED) {
                logger.info("doc updated, index: "+ index +", type:"+ type +",id:"+ id+",version:"+version);
            }
        }catch(ElasticsearchException e) {
            if (e.status() == RestStatus.CONFLICT) {
                logger.error("version conflict");

            }
        }catch(Exception e){
            logger.error("execute index api failed, "+ e.toString());
        }


        // 查询文档
        GetRequest getRequest = new GetRequest(
                "posts",
                "doc",
                "1");
        try {
            // 获取响应结果
            GetResponse getResponse = client.get(getRequest);
            String index = getResponse.getIndex();
            String type = getResponse.getType();
            String id = getResponse.getId();
            if (getResponse.isExists()) {
                long version = getResponse.getVersion();
                String sourceAsString = getResponse.getSourceAsString();
                logger.info("get doc, index: "+ index +", type:"+ type +",id:"+ id+",version:"+version +", source:"+ sourceAsString);
            }
        }catch (ElasticsearchException e) {
            if (e.status() == RestStatus.NOT_FOUND) {
                logger.warn("doc not found");
            }
        }
        catch(Exception e){
            logger.error("execute get api failed, "+ e.toString());
        }

        // 关闭客户端
        try {
            restClient.close();
        }catch (Exception e){
            logger.error("close rest client exception:"+ e.toString());
        }
    }
}

注意事项

  1. client版本需要与ES集群版本保持一致,否则可能会出现兼容性问题
  2. Java High Level Client构建于Java Low Level Client之上,两种client都是基于http协议连接ES集群,Java High Level Client可提供的API种类随着版本升级会越来越多,如果当前版本的Java High Level Client提供的API不满足需求,可以通过升级ES集群版本和Client版本解决。
  3. 使用TCP协议连接ES集群的Transport Client官方已经不再维护,建议使用使用HTTP协议连接集群的Java High Level Client或者Java Low Level Client。可以参考官方文档由TransportClient迁移至Java High Level Client:https://www.elastic.co/guide/en/elasticsearch/client/java-rest/5.6/java-rest-high-level-migration.html

原创声明,本文系作者授权云+社区发表,未经许可,不得转载。

如有侵权,请联系 yunjia_community@tencent.com 删除。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏老码农专栏

使用 maven 生成一个支持端到端自动测试的 RESTful 服务项目脚手架

2024
来自专栏我的小碗汤

这几个注解的你了解吗

<mvc:annotation-driven />与<context:annotation-config />

1083
来自专栏Java工程师日常干货

写出我的第一个框架:迷你版Spring MVC前期准备关于自定义注解编写核心控制器:DispatcherServletMake it run!

OK,到这里,一个迷你版的Spring MVC就开发完成了,以前,都是用Spring MVC,从没有想过可以自己开发一个出来,这是我的第一次,我的能量超乎我的想...

1104
来自专栏Java学习网

java开发中spring和springboot常用注解总结,开发人员必学

这个注解可以用于类和方法上,用于类上,表示父路径,如类上是demo,方法上是/demo1,那么访问路径就是demo/demo1

1315
来自专栏大内老A

《WCF技术剖析(卷2)》目录

第1章 异常处理 (Exception Handling) 1.1. WCF基本异常处理模式 1.1.1. 当异常从服务端抛出(S101) 1.1.2. 异常细...

2099
来自专栏zhisheng

Spring Boot 2.0 新特性详解

背景 在 3 月 1 号,Spring Boot2.0.0.RELEASE正式发布,这是 Spring Boot1.0 发布 4 年之后第一次重大修订,因此有多...

4035
来自专栏coder修行路

让你成功安装vscode中go的相关插件

注意:该演示环境是windows环境,linux和mac环境操作思路一样 vscode中有很多go的相关插件,非常好用如下: gocode gopkgs go-...

2.7K7
来自专栏吴生的专栏

使用 maven 生成一个支持端到端自动测试的 RESTful 服务项目脚手架

和传统后端页面生成技术相较, RESTful 数据服务专注与数据逻辑, 而将数据呈现完全交给前端应用. 这样做可以让后端开发更加单纯, 而且更容易测试. 本文将...

3645
来自专栏码匠的流水账

使用SseEmitter不断向网页输出结果

之前写过一篇文章:springmvc不断输出文本到网页,采用的是对response不断进行write和flush实现的。在spring 4.2版本的时候提供了一...

3091
来自专栏学习力

《Java从入门到放弃》框架入门篇:springMVC数据传递 (二)

1774

扫码关注云+社区

领取腾讯云代金券