JestClient 使用教程,教你完成大部分ElasticSearch的操作。

Stella981
• 阅读 771

  本篇文章代码实现不多,主要是教你如何用JestClient去实现ElasticSearch上的操作。

  授人以鱼不如授人以渔。

一、说明

  1、elasticsearch版本:6.2.4 。

    jdk版本:1.8(该升级赶紧升级吧,现在很多技术都是最低要求1.8)。

    jest版本:5.3.3。

  2、一些不错的文章

    一些基本概念的讲解:http://www.gaowm.com/categories/Elasticsearch/

    es配置文件参数介绍:https://www.jianshu.com/p/149a8da90bbc

    中文ik插件安装:https://blog.csdn.net/zjcjava/article/details/78653753

    linux启动需要更改的一些参数:https://www.cnblogs.com/woxpp/p/6061073.html

二、前提:

       1、最好已经大概看过es的官方文档,附上文档地址:

        中文:https://www.elastic.co/guide/cn/elasticsearch/guide/cn/index.html   虽然已经有点老了,不过还是可以看看的。(我英文不好看的这个)

        英文:https://www.elastic.co/guide/en/elasticsearch/reference/current/index.html   英文好的直接看英文版的,毕竟是最新的。

      2、知道自己需要的es命令:

        比如想用jest进行索引模版的相关操作,需要知道操作模版的命令是“template” 等等。然后能在官方文档里查到相关命令的详细操作。

        简单说就是现在已经知道怎么在 es里进行相关操作了。现在想要用jest进行实现。

三、开始:

  1、pom依赖:

JestClient 使用教程,教你完成大部分ElasticSearch的操作。 JestClient 使用教程,教你完成大部分ElasticSearch的操作。

<project xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>ceshi</groupId>
    <artifactId>ceshi</artifactId>
    <version>0.0.1-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>io.searchbox</groupId>
            <artifactId>jest</artifactId>
            <version>5.3.3</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>6.2.4</version>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <!-- java编译插件 -->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

pom.xml

   2、jest初始化,这里就不说了。直接开始操作了,简单说几个命令抛砖引玉:

    索引模版:es命令地址:https://www.elastic.co/guide/cn/elasticsearch/guide/cn/index-templates.html

     文档中可以看到命令是“_template”。 JestClient 使用教程,教你完成大部分ElasticSearch的操作。

     现在在jest的jar包里找 “template”相关的类JestClient 使用教程,教你完成大部分ElasticSearch的操作。

其实写到这 大概应该知道啥意思了。补张图:

JestClient 使用教程,教你完成大部分ElasticSearch的操作。

 写的有点乱,以后整理吧。

-------------------------2018-07-17------------------------------------

附上自己的代码实现(index的一些操作)。数据操作之后整理完,再发。

创建index
public void createIndex(String index) {
    try {
        JestResult jestResult = jestClient.execute(new CreateIndex.Builder(index).build());
        System.out.println("createIndex:{}" + jestResult.isSucceeded());
    } catch (IOException e) {
        e.printStackTrace();
    }
}
删除index
public void deleteIndex(String index) {
    try {
        JestResult jestResult = jestClient.execute(new DeleteIndex.Builder(index).build());
        System.out.println("deleteIndex result:{}" + jestResult.isSucceeded());
    } catch (IOException e) {
        e.printStackTrace();
    }

}

设置index的mapping(设置数据类型和分词方式)
public void createIndexMapping(String index, String type, String mappingString) {
    //mappingString为拼接好的json格式的mapping串
    PutMapping.Builder builder = new PutMapping.Builder(index, type, mappingString);
    try {
        JestResult jestResult = jestClient.execute(builder.build());
        System.out.println("createIndexMapping result:{}" + jestResult.isSucceeded());
        if (!jestResult.isSucceeded()) {
            System.err.println("settingIndexMapping error:{}" + jestResult.getErrorMessage());
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}
获取index的mapping
public String getMapping(String indexName, String typeName) {
        GetMapping.Builder builder = new GetMapping.Builder();
        builder.addIndex(indexName).addType(typeName);
        try {
            JestResult result = jestClient.execute(builder.build());
            if (result != null && result.isSucceeded()) {
                return result.getSourceAsObject(JsonObject.class).toString();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

获取索引index设置setting
public boolean getIndexSettings(String index) {
        try {
            JestResult jestResult = jestClient.execute(new GetSettings.Builder().addIndex(index).build());
            System.out.println(jestResult.getJsonString());
            if (jestResult != null) {
                return jestResult.isSucceeded();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return false;
    }

更改索引index设置setting
public boolean updateIndexSettings(String index) {
        String source;
        XContentBuilder mapBuilder = null;
        try {
            mapBuilder = XContentFactory.jsonBuilder();
            mapBuilder.startObject().startObject("index").field("max_result_window", "1000000").endObject().endObject();
            source = mapBuilder.string();
            JestResult jestResult = jestClient.execute(new UpdateSettings.Builder(source).build());
            System.out.println(jestResult.getJsonString());
            if (jestResult != null) {
                return jestResult.isSucceeded();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return false;
    }
获取索引 别名
public boolean getIndexAliases(String index) {
        try {
            JestResult jestResult = jestClient.execute(new GetAliases.Builder().addIndex(index).build());
            System.out.println(jestResult.getJsonString());
            if (jestResult != null) {
                return jestResult.isSucceeded();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return false;
    }
添加索引别名
public void addAlias(List<String> index, String alias) {
    try {
        AddAliasMapping build = new AddAliasMapping.Builder(index, alias).build();
        JestResult jestResult = jestClient.execute(new ModifyAliases.Builder(build).build());
        System.out.println("result:" + jestResult.getJsonString());
    } catch (IOException e) {
        e.printStackTrace();
    }
}
获取索引模版
public void getTemplate(String template) {
    try {
        JestResult jestResult = jestClient.execute(new GetTemplate.Builder(template).build());
        System.out.println("result:" + jestResult.getJsonString());
    } catch (IOException e) {
        e.printStackTrace();
    }

}
添加索引模版
public void putreturnreportTemplate() {
    String source;
    XContentBuilder mapBuilder = null;
    try {
        mapBuilder = XContentFactory.jsonBuilder();
        mapBuilder.startObject().field("template", "df_returnreport*").field("order", 1)//
                .startObject("settings").field("number_of_shards", 5)//五个分片
                .startObject("index").field("max_result_window", "1000000")//一次查询最大一百万
                .endObject()//
                .endObject()//
                .startObject("mappings")//
                
                .startObject("df_returnreport")//type名
                .startObject("properties")//
                .startObject("id").field("type", "long").endObject()//
                .startObject("username").field("type", "keyword").endObject()//
                .startObject("content").field("type", "text").field("analyzer", "ik_max_word").endObject()//
                .startObject("returntime").field("type", "date").field("format", "yyyy-MM-dd HH:mm:ss").endObject()//
                .startObject("gateway").field("type", "integer").endObject()//
                .endObject()//
                .endObject()//
                
                .endObject()//
                .startObject("aliases").startObject("df_returnreport").endObject().endObject()//别名
                .endObject();//
        source = mapBuilder.string();
        JestResult jestResult = jestClient.execute(new PutTemplate.Builder("my_returnreport", source).build());
        System.out.println("result:" + jestResult.getJsonString());
    } catch (IOException e) {
        e.printStackTrace();
    }
}
索引优化
public void optimizeIndex() {
    Optimize optimize = new Optimize.Builder().build();
    jestClient.executeAsync(optimize, new JestResultHandler<JestResult>() {
        public void completed(JestResult jestResult) {
            System.out.println("optimizeIndex result:{}" + jestResult.isSucceeded());
        }
        public void failed(Exception e) {
            e.printStackTrace();
        }
    });
}
清理缓存
public void clearCache() {
    try {
        ClearCache clearCache = new ClearCache.Builder().build();
        jestClient.execute(clearCache);
    } catch (IOException e) {
        e.printStackTrace();
    }
}
点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
Easter79 Easter79
3年前
swap空间的增减方法
(1)增大swap空间去激活swap交换区:swapoff v /dev/vg00/lvswap扩展交换lv:lvextend L 10G /dev/vg00/lvswap重新生成swap交换区:mkswap /dev/vg00/lvswap激活新生成的交换区:swapon v /dev/vg00/lvswap
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
4个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Wesley13 Wesley13
3年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Wesley13 Wesley13
3年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
10个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这