首页 / JAVA / Elasticsearch Java客户端

Elasticsearch Java客户端

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Elasticsearch Java客户端，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9046字，纯文字阅读大概需要13分钟。

内容图文

在Elasticsearch中，为java提供了2种客户端，一种是REST风格的客户端，另一种是Java API的客户端。

REST客户端：

　　Elasticsearch提供了2种REST客户端，一种是低级客户端，一种是高级客户端。
　　　　Java Low Level REST Client：官方提供的低级客户端。该客户端通过http来连接Elasticsearch集群。用户在使用该客户端时需要将请求数据手动拼接成Elasticsearch所需JSON格式进行发送，收到响应时同样也需要将返回的JSON数据手动封装成对象。虽然麻烦，不过该客户端兼容所有的Elasticsearch版本。
　　　　Java High Level REST Client：官方提供的高级客户端。该客户端基于低级客户端实现，它提供了很多便捷的API来解决低级客户端需要手动转换数据格式的问题。
　　1.构造数据

　　　　POST /haoke/house/_bulk

{"index":{"_index":"haoke","_type":"house"}}
{"id":"1001","title":"整租 · 南丹大楼 1居室 7500","price":"7500"}
{"index":{"_index":"haoke","_type":"house"}}
{"id":"1002","title":"陆家嘴板块，精装设计一室一厅，可拎包入住诚意租。","price":"8500"}
{"index":{"_index":"haoke","_type":"house"}}
{"id":"1003","title":"整租 · 健安坊 1居室 4050","price":"7500"}
{"index":{"_index":"haoke","_type":"house"}}
{"id":"1004","title":"整租 · 中凯城市之光+视野开阔+景色秀丽+拎包入住","price":"6500"}
{"index":{"_index":"haoke","_type":"house"}}
{"id":"1005","title":"整租 · 南京西路品质小区 21213三轨交汇 配套齐* 拎包入住","price":"6000"}
{"index":{"_index":"haoke","_type":"house"}}
{"id":"1006","title":"祥康里 简约风格 *南户型 拎包入住 看房随时","price":"7000"}

　　2.REST低级客户端

　　　　创建工程，引入依赖：

<dependencies>
        <!-- elasticsearch rest客户端 -->
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
            <version>6.5.4</version>
        </dependency>
        <!-- json格式化工具 -->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.9.4</version>
        </dependency>
        <!-- 单元测试 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
    </dependencies>

　　　　编写测试用例：

public class ESRestTest {

    private static final ObjectMapper MAPPER = new ObjectMapper();
    private RestClient restClient;

    @Before
    public void init() {
        RestClientBuilder restClientBuilder = RestClient.builder(
                new HttpHost("192.168.43.182", 9200, "http"),
                new HttpHost("192.168.43.182", 9201, "http"),
                new HttpHost("192.168.43.182", 9202, "http"));
        restClientBuilder.setFailureListener(new RestClient.FailureListener() {
            @Override
            public void onFailure(Node node) {
                System.out.println("出错了 -> " + node);
            }
        });
        this.restClient = restClientBuilder.build();
    }

    @After
    public void after() throws IOException {
        restClient.close();
    }

    // 查询集群状态
    @Test
    public void testGetInfo() throws IOException {
        Request request = new Request("GET", "/_cluster/state");
        request.addParameter("pretty", "true"); // 格式化json数据
        Response response = this.restClient.performRequest(request);
        System.out.println(response.getStatusLine()); // 状态行
        System.out.println(EntityUtils.toString(response.getEntity())); // 响应体
    }

    // 新增数据
    @Test
    public void testCreateData() throws IOException {
        Request request = new Request("POST", "/haoke/house");
        Map<String, Object> data = new HashMap<>();
        data.put("id", "2001");
        data.put("title", "张江高科");
        data.put("price", "3500");
        request.setJsonEntity(MAPPER.writeValueAsString(data));
        Response response = this.restClient.performRequest(request);
        System.out.println(response.getStatusLine());
        System.out.println(EntityUtils.toString(response.getEntity()));
    }

    // 根据id查询数据
    @Test
    public void testQueryData() throws IOException {
        Request request = new Request("GET", "/haoke/house/at6XFXEBO18vQ71rkF2P");
        Response response = this.restClient.performRequest(request);
        System.out.println(response.getStatusLine());
        System.out.println(EntityUtils.toString(response.getEntity()));
    }

    // 搜索数据
    @Test
    public void testSearchData() throws IOException {
        Request request = new Request("POST", "/haoke/house/_search");
        String searchJson = "{\"query\": {\"match\": {\"title\": \"拎包入住\"}}}";
        request.setJsonEntity(searchJson);
        request.addParameter("pretty", "true");
        Response response = this.restClient.performRequest(request);
        System.out.println(response.getStatusLine());
        System.out.println(EntityUtils.toString(response.getEntity()));
    }
}

　　　　从使用中，可以看出，基本和我们使用RESTful api使用几乎是一致的。

　　3.REST高级客户端

　　　　引入依赖：

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

　　　　编写测试用例：

public class RestHighLevelTest {

    private RestHighLevelClient client;

    @Before
    public void init() {
        RestClientBuilder restClientBuilder = RestClient.builder(
                new HttpHost("192.168.43.182", 9200, "http"),
                new HttpHost("192.168.43.182", 9201, "http"),
                new HttpHost("192.168.43.182", 9202, "http"));
        restClientBuilder.setFailureListener(new RestClient.FailureListener() {
            @Override
            public void onFailure(Node node) {
                System.out.println("出错了 -> " + node);
            }
        });
        this.client = new RestHighLevelClient(restClientBuilder);
    }

    @After
    public void after() throws Exception {
        this.client.close();
    }

    /**
     * 新增文档，同步操作
     *
     * @throws Exception
     */
    @Test
    public void testCreate() throws Exception {
        Map<String, Object> data = new HashMap<>();
        data.put("id", "2002");
        data.put("title", "南京西路 拎包入住 一室一厅");
        data.put("price", "4500");
        IndexRequest indexRequest = new IndexRequest("haoke", "house").source(data);
        IndexResponse indexResponse = this.client.index(indexRequest, RequestOptions.DEFAULT);
        System.out.println("id->" + indexResponse.getId());
        System.out.println("index->" + indexResponse.getIndex());
        System.out.println("type->" + indexResponse.getType());
        System.out.println("version->" + indexResponse.getVersion());
        System.out.println("result->" + indexResponse.getResult());
        System.out.println("shardInfo->" + indexResponse.getShardInfo());
    }

    /**
     * 新增文档，异步操作
     *
     * @throws Exception
     */
    @Test
    public void testCreateAsync() throws Exception {
        Map<String, Object> data = new HashMap<>();
        data.put("id", "2003");
        data.put("title", "南京东路 最新房源 二室一厅");
        data.put("price", "5500");
        IndexRequest indexRequest = new IndexRequest("haoke", "house").source(data);
        this.client.indexAsync(indexRequest, RequestOptions.DEFAULT, new
                ActionListener<IndexResponse>() {
                    @Override
                    public void onResponse(IndexResponse indexResponse) {
                        System.out.println("id->" + indexResponse.getId());
                        System.out.println("index->" + indexResponse.getIndex());
                        System.out.println("type->" + indexResponse.getType());
                        System.out.println("version->" + indexResponse.getVersion());
                        System.out.println("result->" + indexResponse.getResult());
                        System.out.println("shardInfo->" + indexResponse.getShardInfo());
                    }

                    @Override
                    public void onFailure(Exception e) {
                        System.out.println(e);
                    }
                });

        System.out.println("ok");
        Thread.sleep(20000);
    }

    /**
     * 根据id查询数据
     *
     * @throws Exception
     */
    @Test
    public void testQuery() throws Exception {
        GetRequest getRequest = new GetRequest("haoke", "house", "bd7GFXEBO18vQ71roF3y");
        // 指定返回的字段
        String[] includes = new String[]{"title", "id"};
        String[] excludes = Strings.EMPTY_ARRAY;
        FetchSourceContext fetchSourceContext = new FetchSourceContext(true, includes, excludes);
        getRequest.fetchSourceContext(fetchSourceContext);
        GetResponse response = this.client.get(getRequest, RequestOptions.DEFAULT);
        System.out.println("数据 -> " + response.getSource());
    }

    /**
     * 判断是否存在
     *
     * @throws Exception
     */
    @Test
    public void testExists() throws Exception {
        GetRequest getRequest = new GetRequest("haoke", "house", "bd7GFXEBO18vQ71roF3y");
        // 不返回的字段
        getRequest.fetchSourceContext(new FetchSourceContext(false));
        boolean exists = this.client.exists(getRequest, RequestOptions.DEFAULT);
        System.out.println("exists -> " + exists);
    }

    /**
     * 删除数据
     *
     * @throws Exception
     */
    @Test
    public void testDelete() throws Exception {
        DeleteRequest deleteRequest = new DeleteRequest("haoke", "house", "bd7GFXEBO18vQ71roF3y");
        DeleteResponse response = this.client.delete(deleteRequest, RequestOptions.DEFAULT);
        System.out.println(response.status());// OK 或者 NOT_FOUND
    }

    /**
     * 更新数据
     *
     * @throws Exception
     */
    @Test
    public void testUpdate() throws Exception {
        UpdateRequest updateRequest = new UpdateRequest("haoke", "house", "at6XFXEBO18vQ71rkF2P");
        Map<String, Object> data = new HashMap<>();
        data.put("title", "张江高科2");
        data.put("price", "5000");
        updateRequest.doc(data);
        UpdateResponse response = this.client.update(updateRequest, RequestOptions.DEFAULT);
        System.out.println("version -> " + response.getVersion());
    }

    /**
     * 全文搜索
     *
     * @throws Exception
     */
    @Test
    public void testSearch() throws Exception {
        SearchRequest searchRequest = new SearchRequest("haoke");
        searchRequest.types("house");

        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(QueryBuilders.matchQuery("title", "拎包入住"));
        // 设置分页
        sourceBuilder.from(0);
        sourceBuilder.size(5);
        // 设置搜索的超时时间
        sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));

        searchRequest.source(sourceBuilder);
        SearchResponse search = this.client.search(searchRequest, RequestOptions.DEFAULT);
        System.out.println("搜索到 " + search.getHits().totalHits + " 条数据.");
        SearchHits hits = search.getHits();
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }
    }
}

内容总结

以上是互联网集市为您收集整理的Elasticsearch Java客户端全部内容，希望文章能够帮你解决Elasticsearch Java客户端所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/636473.html

来源：【匿名】

【上一篇】Java笔记之Mybatis(五):多对多【下一篇】JAVA/JSP学习系列之五

更多 ►

【Elasticsearch Java客户端】教程文章相关的互联网学习教程文章

java TCP客户端服务端互访

服务端： 1，创建socket服务器服务，服务器端为了让客户端可以连接上，必须提供端口，监听一个端口 2，获取客户端对象，通过客户端的socket流和对应的客户端进行通信 3，获取客户端的socket流的读取流 4，读取数据并显示在服务器端 5，关闭资源 package cn.net.tcp;import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.So...

java socket 单服务器多客户端实时通信【图】

想用JAVA做一个服务器，请问怎么利用TCP和线程，实现多个客户端同时在线，能与服务器进行交互？服务器监听端口做个无限循环接到一个连接就创建一个通道线程，并将通道线程存储到一个list集合中1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374import java.io.BufferedReader;import java.io.IOException;import java.io.InputStr...

java客户端数据发送到服务器（POST请求）总结

今天为了测试服务处理请求的功能，自己学了从客户端发送模拟浏览器发送请求，现在总结如下：首先看写的相关的代码客户端：客户端主要用到的类是URLConnectionURL url = new URL("http://localhost:8080/yiliaotest/RetransServlet");URLConnection con = url.openConnection();// post请求必须设置下面两项con.setDoOutput(true);con.setDoInput(true);// 不使用缓存con.setUseCaches(false);String personjson = "[{\"xingming\":...

Java Web学习(15)：客户端请求、服务器响应及其HTTP状态码【代码】【图】

一JSP客户端请求当浏览器请求一个网页时，它会向网络服务器发送一系列不能被直接读取的信息，因为这些信息是作为HTTP信息头的一部分来传送的。我们可以查阅HTTP协议来获得更多的信息。下表列出了浏览器端信息头的一些重要内容，在以后的网络编程中将会经常见到这些信息： (1)HttpServletRequest类 request对象是javax.servlet.http.HttpServletRequest类的实例。每当客户端请求一个页面时，JSP引...

一个java 的tcp聊天程序的客户端

?123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161importjava.io.*;importja...

java客户端向单机版kafka发送消息没有接收到

kafka版本：kafka_2.11-0.10.0.0在kafka服务器命令发送消息，消费者可以接受到，但是在java客户端向kafka发送消息时消费者接受不到，在kafka/config/sever.properties把这个注解打开advertised.listeners=PLAINTEXT://ip.137:9092 #本机服务器ip意思就是说：hostname、port都会广播给producer、consumer。如果你没有配置了这个属性的话，则使用listeners的值，如果listeners的值也没有配置的话，则使用 java.net.InetAddre...

Java基础知识强化之网络编程笔记10：TCP之客户端读取文本文件服务器控制台输出【代码】

1. TCP之客户端读取文本文件服务器控制台输出（1）客户端：（发送数据到服务端） 1package cn.itcast_10;2 3import java.io.BufferedReader;4import java.io.BufferedWriter;5import java.io.FileReader;6import java.io.IOException;7import java.io.OutputStreamWriter;8import java.net.Socket;910/*11 * 客户端文本文件，服务器输出到控制台 12*/13publicclass ClientDemo { 14publicstaticvoid main(String[] args) throws IO...

spring 集成redis客户端jedis(java)【代码】

jedis是redis的java客户端，spring将redis连接池作为一个bean配置。“redis.clients.jedis.JedisPool”，这是单机环境适用的redis连接池。 1、maven导入相关包： <dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version></dependency> 2、下面是单机环境下redis连接池的配置： <?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springfra...

简单服务器开发（八）响应动态：客户端访问小Java程序【代码】【图】

上一个例子中，浏览器客户端发送的请求是 http://127.0.0.1:8080/oa/index.html，从请求路径上看到浏览器客户端访问的是 WebApp 中的静态 html 页面，服务器找到该静态页面之后直接将html页面响应到浏览器即可　　但是如果浏览器发送这样的请求：http://127.0.0.1:8080/oa/login?username=admin&password=123，从请求路径的字面意思上理解，这是浏览器向服务器发送了一个登录的请求，需要服务器端执行一段“Java 程序”来处理这次的...

Java 获取客户端浏览器中的语言设置

获取客户端的首选语言javax.servlet.ServletRequest.getLocale()根据Accept-Language请求头返回客户端的首选语言。如果客户端请求没有Accept-Language请求头，则此方法返回服务器的默认语言环境。获取虚拟机的默认语言java.util.Locale.getDefault()获取此Java虚拟机实例的默认语言环境的值。可以使用setDefault方法更改这个值。原文：https://www.cnblogs.com/danhuang/p/12821915.html

java Socket通信，客户端与服务端相互发消息【代码】【图】

1.通信过程网络分为应用层，http、ssh、telnet就是属于这一类，建立在传输层的基础上、其实就是定义了各自的编码解码格式，分层如下： 2.Socket连接上述通信都要先在传输层有建立连接的基础上才能完成，TCP通过三次握手建立连接： Socket与http的区别可以看下这个： https://www.cnblogs.com/meier1205/p/5971313.html 还有搜索：http下午茶3.JAVA socket 客户端与服务端互发消息实现结构图：客户端和服务端分别通过俩个线...

java socket 实现多个客户端向服务器上传文件【代码】【图】

服务器端：package cn.com.test09;import java.io.DataInputStream; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket;publicclass t10 {publicstaticvoid main(String[] args) {new ServerO("F:\\",8080);} }class ServerO {private String path;privateint port;private ServerSocket ss;public ServerO(String s, int p) {this.path ...

JAVA后端生成Token（令牌），用于校验客户端，防止重复提交

转自：https://www.cnblogs.com/fengli9998/p/9251631.html 转：https://blog.csdn.net/u011821334/article/details/79390980转:https://blog.csdn.net/joshua1830/article/details/78931420转:https://blog.csdn.net/IAlexanderI/article/details/80253158(mysql的防重复提交)转:https://blog.csdn.net/sinat_34454743/article/details/73867178(springboot中防止表单重复提交的方法)转:https://blog.csdn.net/u011244202/article...

使用Java客户端对Redis进行操作【图】

一、背景上篇文章我们介绍了如何在centos7下面进行安装单机版redis以及redis集群。这篇文章，我们来聊一聊如何使用java客户端来进行操作redis。我们知道redis的java客户端有很多,如：jedis、redission等。这篇文章着重介绍我们平常使用最多的redis的java客户端jedis。二、通过单元测试来小试牛刀　　1.首先在maven的pom.xml中引入jedis-client的依赖　　2.使用junit进行单元测试三、在项目中，使用Spring集成Redis1.redis.properti...

CAS Java客户端登录相关过滤器的处理流程

首先了解一下CAS登录原理：CAS结构中一般包含CAS服务器、应用服务器、客户端三个部分。客户端向应用服务器发出请求，由于未登录，会被跳转到CAS服务器登录。登录成功后跳转回应用服务器的登录前的URL，但是CAS服务器会给URL加上一个ticket参数。应用服务器拿着ticket去CAS服务器验证，验证成功后即加入一个session表示已登录，以后就不用再次登录了。在web.xml配置中，AuthenticationFilter和TicketValidationFilter两个过滤器是负...

首页 / JAVA / Elasticsearch Java客户端

Elasticsearch Java客户端

内容导读

内容图文

内容总结

内容备注

内容手机端

【Elasticsearch Java客户端】教程文章相关的互联网学习教程文章

java TCP客户端服务端互访

java socket 单服务器多客户端实时通信【图】

java客户端数据发送到服务器（POST请求）总结

Java Web学习(15)：客户端请求、服务器响应及其HTTP状态码【代码】【图】

一个java 的tcp聊天程序的客户端

java客户端向单机版kafka发送消息没有接收到

Java基础知识强化之网络编程笔记10：TCP之客户端读取文本文件服务器控制台输出【代码】

spring 集成redis客户端jedis(java)【代码】

简单服务器开发（八）响应动态：客户端访问小Java程序【代码】【图】

Java 获取客户端浏览器中的语言设置

java Socket通信，客户端与服务端相互发消息【代码】【图】

java socket 实现多个客户端向服务器上传文件【代码】【图】

JAVA后端生成Token（令牌），用于校验客户端，防止重复提交

使用Java客户端对Redis进行操作【图】

CAS Java客户端登录相关过滤器的处理流程

SEARCH - 相关标签

JAVA - 相关标签

JAVA - 技术教程分类

JAVA - 最新教程

JAVA - 最热教程